producer

type EventMeshProducer interface {
	Send(sctx SendMessageContext, callback *connector.SendCallback) error
	Request(sctx SendMessageContext, callback *connector.RequestReplyCallback, timeout time.Duration) error
	Reply(sctx SendMessageContext, callback *connector.SendCallback) error
	Start() error
	Shutdown() error
	Status() consts.ServiceState
	String() string
}

type Processor interface {
	AsyncMessage(ctx context.Context, producerMgr ProducerManager, msg *pb.SimpleMessage) (*pb.Response, error)
	ReplyMessage(ctx context.Context, producerMgr ProducerManager, emiter emitter.EventEmitter, msg *pb.SimpleMessage) error
	RequestReplyMessage(ctx context.Context, producerMgr ProducerManager, msg *pb.SimpleMessage) (*pb.SimpleMessage, error)
	BatchPublish(ctx context.Context, producerMgr ProducerManager, msg *pb.BatchMessage) (*pb.Response, error)
}

type ProducerGroupConfig struct {
	GroupName string `json:"groupName"`
}

type ProducerManager interface {
	GetProducer(groupName string) (EventMeshProducer, error)
	CreateProducer(producerGroupConfig *ProducerGroupConfig) (EventMeshProducer, error)
	Start() error
	Shutdown() error
}

type ProducerService struct {
	pb.UnimplementedPublisherServiceServer
	// contains filtered or unexported fields
}

type SendMessageContext struct {
	Ctx         context.Context
	Event       *cloudv2.Event
	BizSeqNO    string
	ProducerAPI EventMeshProducer
	CreateTime  time.Time
}