Documentation
¶
Index ¶
- type MessagingClient
- func (mc *MessagingClient) DeleteChannel(chanName string) error
- func (mc *MessagingClient) DeleteTopic(namespace, topic string) error
- func (mc *MessagingClient) NewPubChannel(chanName string) (*PubChannel, error)
- func (mc *MessagingClient) NewPublisher(publisherId, namespace, topic string) (*Publisher, error)
- func (mc *MessagingClient) NewSubChannel(subscriberId, chanName string) (*SubChannel, error)
- func (mc *MessagingClient) NewSubscriber(subscriberId, namespace, topic string, partitionId int, startTime time.Time) (*Subscriber, error)
- type PubChannel
- type Publisher
- type SubChannel
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessagingClient ¶
type MessagingClient struct {
// contains filtered or unexported fields
}
func NewMessagingClient ¶
func NewMessagingClient(bootstrapBrokers ...string) *MessagingClient
func (*MessagingClient) DeleteChannel ¶
func (mc *MessagingClient) DeleteChannel(chanName string) error
func (*MessagingClient) DeleteTopic ¶
func (mc *MessagingClient) DeleteTopic(namespace, topic string) error
func (*MessagingClient) NewPubChannel ¶
func (mc *MessagingClient) NewPubChannel(chanName string) (*PubChannel, error)
func (*MessagingClient) NewPublisher ¶
func (mc *MessagingClient) NewPublisher(publisherId, namespace, topic string) (*Publisher, error)
func (*MessagingClient) NewSubChannel ¶
func (mc *MessagingClient) NewSubChannel(subscriberId, chanName string) (*SubChannel, error)
func (*MessagingClient) NewSubscriber ¶
func (mc *MessagingClient) NewSubscriber(subscriberId, namespace, topic string, partitionId int, startTime time.Time) (*Subscriber, error)
type PubChannel ¶
type PubChannel struct {
// contains filtered or unexported fields
}
func (*PubChannel) Close ¶
func (pc *PubChannel) Close() error
func (*PubChannel) Md5 ¶
func (pc *PubChannel) Md5() []byte
func (*PubChannel) Publish ¶
func (pc *PubChannel) Publish(m []byte) error
type SubChannel ¶
type SubChannel struct {
// contains filtered or unexported fields
}
func (*SubChannel) Cancel ¶
func (sc *SubChannel) Cancel()
func (*SubChannel) Channel ¶
func (sc *SubChannel) Channel() chan []byte
func (*SubChannel) Md5 ¶
func (sc *SubChannel) Md5() []byte
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func (*Subscriber) Shutdown ¶
func (s *Subscriber) Shutdown()
func (*Subscriber) Subscribe ¶
func (s *Subscriber) Subscribe(processFn func(m *messaging_pb.Message))
Subscribe starts goroutines to process the messages
Source Files
Click to show internal directories.
Click to hide internal directories.