Documentation ¶
Index ¶
- type BroadCastingMessageSubscribeHandler
- type ClusteringMessageSubscribeHandler
- type Consumer
- func (c *Consumer) InitConsumer(properties map[string]string) error
- func (c *Consumer) IsClosed() bool
- func (c *Consumer) IsStarted() bool
- func (c *Consumer) RegisterEventListener(listener *connector.EventListener)
- func (c *Consumer) Shutdown() error
- func (c *Consumer) Start() error
- func (c *Consumer) Subscribe(topicName string) error
- func (c *Consumer) Unsubscribe(topicName string) error
- func (c *Consumer) UpdateOffset(ctx context.Context, events []*ce.Event) error
- type Factory
- type Producer
- func (p *Producer) CheckTopicExist(topicName string) (bool, error)
- func (p *Producer) InitProducer(properties map[string]string) error
- func (p *Producer) IsClosed() bool
- func (p *Producer) IsStarted() bool
- func (p *Producer) Publish(ctx context.Context, event *ce.Event, callback *connector.SendCallback) error
- func (p *Producer) Reply(ctx context.Context, event *ce.Event, callback *connector.SendCallback) error
- func (p *Producer) Request(ctx context.Context, event *ce.Event, callback *connector.RequestReplyCallback, ...) error
- func (p *Producer) SendOneway(ctx context.Context, event *ce.Event) error
- func (p *Producer) SetExtFields() error
- func (p *Producer) Shutdown() error
- func (p *Producer) Start() error
- type Resource
- type SendCallback
- type SubscribeHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BroadCastingMessageSubscribeHandler ¶
type BroadCastingMessageSubscribeHandler struct {
// contains filtered or unexported fields
}
BroadCastingMessageSubscribeHandler message consume handler of BroadCasting mode
type ClusteringMessageSubscribeHandler ¶
type ClusteringMessageSubscribeHandler struct {
// contains filtered or unexported fields
}
ClusteringMessageSubscribeHandler message consume handler of Clustering mode
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func NewConsumer() *Consumer
NewConsumer get new consumer, needs to be Initiated before using
func (*Consumer) InitConsumer ¶
InitConsumer init consumer by properties
func (*Consumer) RegisterEventListener ¶
func (c *Consumer) RegisterEventListener(listener *connector.EventListener)
RegisterEventListener listener's Consume function will be called when message is being consumed
func (*Consumer) Unsubscribe ¶
Unsubscribe unsubscribe topic
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer() *Producer
NewProducer get new producer, needs to be Initiated before using
func (*Producer) CheckTopicExist ¶
CheckTopicExist RocketMQ go-sdk doesn't support topic check
func (*Producer) InitProducer ¶
InitProducer init producer by properties
func (*Producer) Publish ¶
func (p *Producer) Publish(ctx context.Context, event *ce.Event, callback *connector.SendCallback) error
Publish async publish message to broker
func (*Producer) Reply ¶
func (p *Producer) Reply(ctx context.Context, event *ce.Event, callback *connector.SendCallback) error
Reply async send message to reply
func (*Producer) Request ¶
func (p *Producer) Request(ctx context.Context, event *ce.Event, callback *connector.RequestReplyCallback, timeout time.Duration) error
Request async request message
func (*Producer) SendOneway ¶
SendOneway async send message without callback
func (*Producer) SetExtFields ¶
SetExtFields do nothing, RocketMQ go-sdk doesn't support dynamic client option modify
type SendCallback ¶
type SendCallback func(ctx context.Context, result *primitive.SendResult, err error)
type SubscribeHandler ¶
type SubscribeHandler interface {
// contains filtered or unexported methods
}
SubscribeHandler interface of message consume handler