service

Documentation

Index

• type Service
  • func (svc *Service) Close(ctx context.Context) error
  • func (svc *Service) Init(ctx context.Context, cfg *config.Config) (err error)
  • func (svc *Service) Start(ctx context.Context, cancel context.CancelFunc) (err error)

Types

type Service

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

func (*Service) Close

func (svc *Service) Close(ctx context.Context) error

func (*Service) Init

func (svc *Service) Init(ctx context.Context, cfg *config.Config) (err error)

Init: Create ConsumerGroup with config, and register the handler

func (*Service) Start

func (svc *Service) Start(ctx context.Context, cancel context.CancelFunc) (err error)

Start: Create ConsumerGroup with config, and register the handler