func closeEventMeshClient()

in internal/protocol/message.go [32:38]


func closeEventMeshClient(client pgrpc.Interface) {
	if client != nil {
		if err := client.Close(); err != nil {
			log.Get(constants.LogSchedule).Errorf("close eventmesh client error:%v", err)
		}
	}
}