service

Documentation

Index

• type Service
  • func New(chIn chan models.MsgTask, chOut chan models.MsgSMTP, wrk int) (*Service, error)
  • func (s *Service) Start(ctx context.Context) error

Types

type Service

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

Service implements main analytics logic

func New

func New(chIn chan models.MsgTask, chOut chan models.MsgSMTP, wrk int) (*Service, error)

New creates a new auth service

func (*Service) Start

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

Start reads MsgTask from chanIn, composes MsgSMTP and sends them to chanOut. The number of simultaneously working go-routines is defined by Service.workers