mqclient

type AckMessage struct {
	SubscribeGroup string       `json:"subscribe_group"`
	Queue          string       `json:"queue"`
	MessageId      idgen.IdType `json:"message_id"`

	ReplyId         string `json:"reply_id"`
	ReplyIdentifier string `json:"reply_identifier"`
	Payload         []byte `json:"payload"`
}

type BindRequest struct {
	Topic      string `json:"topic"`
	Queue      string `json:"queue"`
	BindingKey string `json:"binding_key"`
}

type Client struct {
	// contains filtered or unexported fields
}

type Codec interface {
	ReqMarshal(req interface{}) ([]byte, error)
	ReqUnmarshal(data []byte) (interface{}, error)
	ResMarshal(req interface{}) ([]byte, error)
	ResUnmarshal(data []byte) (interface{}, error)
}

type DeliveryType int

type Message struct {
	Topic          string       `json:"topic"`
	Queue          string       `json:"queue"`
	BindingKey     string       `json:"binding_key"`
	SubscribeGroup string       `json:"subscribe_group"`
	MessageId      idgen.IdType `json:"message_id"`
	Payload        []byte       `json:"payload"`

	ReplyId         string `json:"reply_id"`
	ReplyIdentifier string `json:"reply_identifier"`
	// contains filtered or unexported fields
}

type MessageDesc struct {
	MessageIdList []MessageId `json:"message_id_list"`
	Topic         string      `json:"topic"`
	BindingKey    string      `json:"binding_key"`
	PublishGroup  string      `json:"publish_group"`
}

type MessageId struct {
	MsgId idgen.IdType `json:"msg_id"`
	OutId idgen.IdType `json:"out_id"`
}

type MessageReleasing struct {
	Topic          string       `json:"topic"`
	Queue          string       `json:"queue"`
	BindingKey     string       `json:"binding_key"`
	SubscribeGroup string       `json:"subscribe_group"`
	MessageId      idgen.IdType `json:"message_id"`

	ReplyId         string `json:"reply_id"`
	ReplyIdentifier string `json:"reply_identifier"`
	// contains filtered or unexported fields
}

type NewMessageRequest struct {
	Topic        string `json:"topic"`
	PublishGroup string `json:"publish_group"`
	BindingKey   string `json:"binding_key"`
	RpcMeta      *struct {
		ReplyIdentifier string `json:"reply_identifier"`
	} `json:"rpc_meta"`

	Payload []byte `json:"payload"`
}

type NewMessageRes struct {
	MessageIdList []MessageId `json:"message_id_list"`
	Topic         string      `json:"topic"`
	BindingKey    string      `json:"binding_key"`
}

type NewPublishGroupRequest struct {
	Topic        string `json:"topic"`
	PublishGroup string `json:"publish_group"`
}

type NewQueueRequest struct {
	Queue             string `json:"queue"`
	DeliveryLevelType string `json:"delivery_level_type"`
}

type NewSubscribeGroupRequest struct {
	Queue          string `json:"queue"`
	SubscribeGroup string `json:"subscribe_group"`
}

type NewTopicRequest struct {
	Topic             string `json:"topic"`
	DeliveryLevelType string `json:"delivery_level_type"`
}

type PublishGroup interface {
	// Publish for publishing message in at most once & at least once modes
	Publish(payload []byte, bindingKey string) (*MessageDesc, error)
	// CommitPublish for committing message at delivery level type of exactly-once
	CommitPublish(desc *MessageDesc) error
}

type PublishGroupRes struct {
	PublishGroup string `json:"publish_group"`
}

type QueueOption struct {
	DeliveryLevelType DeliveryType
}

type ReleaseMessage struct {
	SubscribeGroup string       `json:"subscribe_group"`
	Queue          string       `json:"queue"`
	MessageId      idgen.IdType `json:"message_id"`

	ReplyId         string `json:"reply_id"`
	ReplyIdentifier string `json:"reply_identifier"`
	Payload         []byte `json:"payload"`
}

type Reply struct {
	ReplyId         idgen.IdType `json:"reply_id"`
	ReplyIdentifier string       `json:"reply_identifier"`
	Payload         []byte       `json:"payload"`
}

type RpcHandler interface {
	Handle(req interface{}) (interface{}, error)
}

type RpcStub interface {
	Call(req interface{}) (interface{}, error)
}

type ServerSideIncoming struct {
	Status    string `json:"status"`
	Info      string `json:"info"`
	RequestId string `json:"request_id"`

	PublishGroupResponse   *PublishGroupRes   `json:"publish_group_res,omitempty"`
	SubscribeGroupResponse *SubscribeGroupRes `json:"subscribe_group_res,omitempty"`

	NewMessageResponse *NewMessageRes `json:"new_message,omitempty"`

	IncomingOperation *string           `json:"operation,omitempty"`
	Message           *Message          `json:"message,omitempty"`
	MessageReleasing  *MessageReleasing `json:"message_releasing,omitempty"`
	Reply             *Reply            `json:"reply,omitempty"`
}

type Session struct {
	// contains filtered or unexported fields
}

type SimpleRpcHandler struct {
	H func(req interface{}) (interface{}, error)
}

type Subscribe interface {
	OnMessage(message *Message, sg SubscribeGroup) error
	OnReleasing(messageMeta *MessageReleasing, sg SubscribeGroup) error
}

type SubscribeGroup interface {
	Commit(message *Message) error
	Release(messageMeta *MessageReleasing) error
}

type SubscribeGroupRes struct {
	SubscribeGroup string `json:"subscribe_group"`
}

type ToServerSidePacket struct {
	Operation string `json:"operation"`
	RequestId string `json:"request_id"`

	NewTopic                 *NewTopicRequest          `json:"new_topic,omitempty"`
	NewQueue                 *NewQueueRequest          `json:"new_queue,omitempty"`
	NewBinding               *BindRequest              `json:"new_binding,omitempty"`
	NewPublishGroupRequest   *NewPublishGroupRequest   `json:"new_publish_group,omitempty"`
	NewSubscribeGroupRequest *NewSubscribeGroupRequest `json:"new_subscribe_group,omitempty"`
	NewMessageRequest        *NewMessageRequest        `json:"new_message,omitempty"`
	NewAckMessage            *AckMessage               `json:"ack_message,omitempty"`
	NewMessageCommitRequest  *MessageDesc              `json:"new_message_commit,omitempty"`
	NewReleaseMessage        *ReleaseMessage           `json:"release_message,omitempty"`
}

type TopicOption struct {
	DeliveryLevelType DeliveryType
}