stream

Documentation

Index

• type Service
  • func NewService(modelID string, streamCfg *config.Stream, afsv afs.Service, dp dictProvider, ...) (*Service, error)
  • func (s *Service) Log(data []byte, output interface{}, timeTaken time.Duration)

Types

type Service

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

func NewService

func NewService(modelID string, streamCfg *config.Stream, afsv afs.Service, dp dictProvider, op outputsProvider, m *gmetric.Service) (*Service, error)

func (*Service) Log

func (s *Service) Log(data []byte, output interface{}, timeTaken time.Duration)