cell

Documentation

Index

• type CellMeasurementService
  • func NewCellMeasurementSerice(log *zap.SugaredLogger, ctx context.Context, out *redis.PubSub, err chan error) *CellMeasurementService
  • func (s *CellMeasurementService) Consume()
  • func (s *CellMeasurementService) Produce(msg string)

Types

type CellMeasurementService

type CellMeasurementService struct {
	TopicChannel *redis.PubSub
	ErrorChannel chan error
	// contains filtered or unexported fields
}

CellMeasurementService

func NewCellMeasurementSerice

func NewCellMeasurementSerice(log *zap.SugaredLogger, ctx context.Context, out *redis.PubSub, err chan error) *CellMeasurementService

NewCellMeasurementSerice

func (*CellMeasurementService) Consume

func (s *CellMeasurementService) Consume()

Consume

func (*CellMeasurementService) Produce

func (s *CellMeasurementService) Produce(msg string)

Produce