consumer

Documentation

Index

• func NewGokaConsumerGroup(opt GokaConsumerGroupOpt) (subscriber pubsub.Subscriber, err error)
• type GokaConsumerGroup
  • func (c *GokaConsumerGroup) Close() (err error)
  • func (c *GokaConsumerGroup) Subscribe()
• type GokaConsumerGroupOpt

Functions

func NewGokaConsumerGroup

func NewGokaConsumerGroup(opt GokaConsumerGroupOpt) (subscriber pubsub.Subscriber, err error)

Types

type GokaConsumerGroup

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

func (*GokaConsumerGroup) Close

func (c *GokaConsumerGroup) Close() (err error)

func (*GokaConsumerGroup) Subscribe

func (c *GokaConsumerGroup) Subscribe()

type GokaConsumerGroupOpt

type GokaConsumerGroupOpt struct {
	Brokers            []string
	Group              string
	Topic              string
	Handler            pubsub.GokaEventHandler
	TopicManagerConfig *goka.TopicManagerConfig
	InputCodec         pubsub.GokaCodec
	TableCodec         pubsub.GokaCodec
}