job

Documentation

Index

• type SaramaConsumerJobServer
  • func NewSaramaConsumerJobServer(topics []string, kc sarama.ConsumerGroupHandler, kcg sarama.ConsumerGroup) *SaramaConsumerJobServer
  • func (s *SaramaConsumerJobServer) Start(ctx context.Context) error
  • func (s *SaramaConsumerJobServer) Stop(ctx context.Context) error

Types

type SaramaConsumerJobServer

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

func NewSaramaConsumerJobServer

func NewSaramaConsumerJobServer(topics []string,
	kc sarama.ConsumerGroupHandler, kcg sarama.ConsumerGroup) *SaramaConsumerJobServer

func (*SaramaConsumerJobServer) Start

func (s *SaramaConsumerJobServer) Start(ctx context.Context) error

func (*SaramaConsumerJobServer) Stop

func (s *SaramaConsumerJobServer) Stop(ctx context.Context) error