Documentation ¶
Index ¶
- Constants
- Variables
- func ConcatNames(strs ...string) string
- func DebugJsonPrint(i interface{})
- func GetBroker() mqapi.Broker
- func GetMetadataContainer() *metadataContainer
- func InitBroker() error
- func LoadMetadata() error
- func Run(listener string) error
- func ValidateNameForBrokerMechanisms(v string) bool
- func ValidateNameForBrokerMechanismsWithWildcard(v string) bool
- type AckDef
- type BindDef
- type GeneralReq
- type GeneralRes
- type MessageDef
- type MessageDescDef
- type NewMessageRes
- type PublishGroupDef
- type PublishGroupRes
- type QueueDef
- type ReleaseDef
- type StoredBinding
- type SubscribeGroupDef
- type SubscribeGroupRes
- type TopicDef
- type WrittenMessage
- type WrittenMessageReleasing
- type WrittenReply
Constants ¶
View Source
const ( MessageAttrTopic = "nekoq.topic" MessageAttrBindingKey = "nekoq.binding_key" MessageAttrReplyId = "nekoq.reply.reply_id" MessageAttrReplyIdentifier = "nekoq.reply.reply_identifier" )
View Source
const ( DeliveryTypeAtMostOnce = "at_most_once" DeliveryTypeAtLeastOnce = "at_least_once" DeliveryTypeExactlyOnce = "exactly_once" )
View Source
const ( ResponseOperationMessage = "message" ResponseOperationMessageReleasing = "message_releasing" ResponseOperationReply = "reply" )
Variables ¶
Functions ¶
func ConcatNames ¶
func DebugJsonPrint ¶
func DebugJsonPrint(i interface{})
func GetMetadataContainer ¶
func GetMetadataContainer() *metadataContainer
func InitBroker ¶
func InitBroker() error
func LoadMetadata ¶
func LoadMetadata() error
Types ¶
type GeneralReq ¶
type GeneralReq struct { Operation string `json:"operation"` RequestId string `json:"request_id"` NewTopic *TopicDef `json:"new_topic,omitempty"` NewQueue *QueueDef `json:"new_queue,omitempty"` NewBinding *BindDef `json:"new_binding,omitempty"` NewPublishGroup *PublishGroupDef `json:"new_publish_group,omitempty"` NewSubscribeGroup *SubscribeGroupDef `json:"new_subscribe_group,omitempty"` NewMessage *MessageDef `json:"new_message,omitempty"` NewMessageCommit *MessageDescDef `json:"new_message_commit,omitempty"` AckMessage *AckDef `json:"ack_message,omitempty"` ReleaseMessage *ReleaseDef `json:"release_message,omitempty"` }
type GeneralRes ¶
type GeneralRes 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"` Operation *string `json:"operation,omitempty"` WrittenMessage *WrittenMessage `json:"message,omitempty"` WrittenMessageReleasing *WrittenMessageReleasing `json:"message_releasing,omitempty"` WrittenReply *WrittenReply `json:"reply,omitempty"` }
type MessageDef ¶
type MessageDescDef ¶
type NewMessageRes ¶
type PublishGroupDef ¶
type PublishGroupRes ¶
type PublishGroupRes struct {
PublishGroup string `json:"publish_group"`
}
type ReleaseDef ¶
type StoredBinding ¶
type SubscribeGroupDef ¶
type SubscribeGroupRes ¶
type SubscribeGroupRes struct {
SubscribeGroup string `json:"subscribe_group"`
}
type WrittenMessage ¶
type WrittenMessage struct { Topic string `json:"topic"` Queue string `json:"queue"` BindingKey string `json:"binding_key"` SubscribeGroup string `json:"subscribe_group"` MessageId mqapi.MsgId `json:"message_id"` Payload []byte `json:"payload"` ReplyId string `json:"reply_id"` ReplyIdentifier string `json:"reply_identifier"` }
type WrittenMessageReleasing ¶
type WrittenMessageReleasing struct { Topic string `json:"topic"` Queue string `json:"queue"` BindingKey string `json:"binding_key"` SubscribeGroup string `json:"subscribe_group"` MessageId mqapi.MsgId `json:"message_id"` ReplyId string `json:"reply_id"` ReplyIdentifier string `json:"reply_identifier"` }
Click to show internal directories.
Click to hide internal directories.