msgclient

Documentation

Index

• type MessagingClient
  • func NewMessagingClient(bootstrapBrokers ...string) *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
  • func (pc *PubChannel) Close() error
  • func (pc *PubChannel) Md5() []byte
  • func (pc *PubChannel) Publish(m []byte) error
• type Publisher
  • func (p *Publisher) Publish(m *messaging_pb.Message) error
• type SubChannel
  • func (sc *SubChannel) Cancel()
  • func (sc *SubChannel) Channel() chan []byte
  • func (sc *SubChannel) Md5() []byte
• type Subscriber
  • func (s *Subscriber) Shutdown()
  • func (s *Subscriber) Subscribe(processFn func(m *messaging_pb.Message))

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 Publisher

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

func (*Publisher) Publish

func (p *Publisher) Publish(m *messaging_pb.Message) 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