service

Documentation

Index

• type Service
  • func NewService(conf *config.Config) *Service
  • func NewStreamService(logger *zap.Logger, conf *config.Config) (*Service, error)
  • func (svc *Service) BuildIndex(streamUUID StreamUUID) (interface{}, error)
  • func (svc *Service) CreateRecordsIterator(streamPtr *Stream, req *StreamIteratorRequest) (StreamIteratorUUID, *APIError)
  • func (svc *Service) CreateStream(properties *StreamProperties) (*Stream, error)
  • func (svc *Service) DeleteStream(streamUUID StreamUUID) error
  • func (svc *Service) Finalize()
  • func (svc *Service) GetLogger() *zap.Logger
  • func (svc *Service) GetStream(uuid StreamUUID) *Stream
  • func (svc *Service) GetStreamsCount() int
  • func (svc *Service) GetStreamsFiltered(jqFilter ...*gojq.Query) *[]*Stream
  • func (svc *Service) GetStreamsUUIDs() StreamUUIDList
  • func (svc *Service) GetStreamsUUIDsFiltered(jqFilter ...*gojq.Query) StreamUUIDList
  • func (svc *Service) Init() error
  • func (svc *Service) LoadStreams() (StreamInfoList, error)
  • func (svc *Service) Stop()
• type StreamMap

Types

type Service

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

func NewService

func NewService(conf *config.Config) *Service

func NewStreamService

func NewStreamService(logger *zap.Logger, conf *config.Config) (*Service, error)

func (*Service) BuildIndex

func (svc *Service) BuildIndex(streamUUID StreamUUID) (interface{}, error)

func (*Service) CreateRecordsIterator

func (svc *Service) CreateRecordsIterator(streamPtr *Stream, req *StreamIteratorRequest) (StreamIteratorUUID, *APIError)

func (*Service) CreateStream

func (svc *Service) CreateStream(properties *StreamProperties) (*Stream, error)

func (*Service) DeleteStream

func (svc *Service) DeleteStream(streamUUID StreamUUID) error

func (*Service) Finalize

func (svc *Service) Finalize()

func (*Service) GetLogger

func (svc *Service) GetLogger() *zap.Logger

func (*Service) GetStream

func (svc *Service) GetStream(uuid StreamUUID) *Stream

func (*Service) GetStreamsCount

func (svc *Service) GetStreamsCount() int

func (*Service) GetStreamsFiltered

func (svc *Service) GetStreamsFiltered(jqFilter ...*gojq.Query) *[]*Stream

func (*Service) GetStreamsUUIDs

func (svc *Service) GetStreamsUUIDs() StreamUUIDList

func (*Service) GetStreamsUUIDsFiltered

func (svc *Service) GetStreamsUUIDsFiltered(jqFilter ...*gojq.Query) StreamUUIDList

func (*Service) Init

func (svc *Service) Init() error

func (*Service) LoadStreams

func (svc *Service) LoadStreams() (StreamInfoList, error)

func (*Service) Stop

func (svc *Service) Stop()

type StreamMap

type StreamMap = map[StreamUUID]*Stream