kafka

type KafkaProducerHandler interface {
	SinglePublish(context.Context, *MessageRequest, *MessageResponse) error
	MultiPublish(context.Context, KafkaProducer_MultiPublishStream) error
}

type KafkaProducerService interface {
	SinglePublish(ctx context.Context, in *MessageRequest, opts ...client.CallOption) (*MessageResponse, error)
	MultiPublish(ctx context.Context, opts ...client.CallOption) (KafkaProducer_MultiPublishService, error)
}

type KafkaProducer_MultiPublishService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*MessageRequest) error
	Recv() (*MessageResponse, error)
}

type KafkaProducer_MultiPublishStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*MessageResponse) error
	Recv() (*MessageRequest, error)
}

type MessageRequest struct {
	Version              int32    `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	MessageId            string   `protobuf:"bytes,2,opt,name=MessageId,proto3" json:"MessageId,omitempty"`
	ClientId             string   `protobuf:"bytes,3,opt,name=ClientId,proto3" json:"ClientId,omitempty"`
	Key                  string   `protobuf:"bytes,4,opt,name=Key,proto3" json:"Key,omitempty"`
	MessageBody          []byte   `protobuf:"bytes,5,opt,name=MessageBody,proto3" json:"MessageBody,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type MessageResponse struct {
	Code                 int32    `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	MessageId            string   `protobuf:"bytes,3,opt,name=MessageId,proto3" json:"MessageId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ProducerService struct {
}