service

Documentation

Index

• type Config
  • func (c Config) Close(ctx context.Context) error
• type Service
  • func New(ctx context.Context, cfg Config) (*Service, error)
  • func (s *Service) AwaitReady()
  • func (s *Service) Entities() map[string]map[string]bool
  • func (s *Service) Metrics() map[string]entity.Metrics
  • func (s *Service) NotifyChan() entity.NotifyChan
  • func (s *Service) Registry() *registry.StreamRegistry
  • func (s *Service) Run(ctx context.Context) error
  • func (s *Service) Shutdown(ctx context.Context) error
  • func (s *Service) Stream(streamId string) (*engine.Stream, error)
  • func (s *Service) String() string

Types

type Config

type Config struct {
	AdminStreamSpec []byte
	NotifyChanSize  int
	Registry        registry.Config
	Engine          engine.Config
	Entity          assembly.Config
}

func (Config) Close

func (c Config) Close(ctx context.Context) error

type Service

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

Service is responsible for creating and injecting concrete implementations of the various parts required by GEIST to function.

func New

func New(ctx context.Context, cfg Config) (*Service, error)

func (*Service) AwaitReady

func (s *Service) AwaitReady()

func (*Service) Entities

func (s *Service) Entities() map[string]map[string]bool

func (*Service) Metrics

func (s *Service) Metrics() map[string]entity.Metrics

func (*Service) NotifyChan

func (s *Service) NotifyChan() entity.NotifyChan

func (*Service) Registry

func (s *Service) Registry() *registry.StreamRegistry

func (*Service) Run

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

func (*Service) Shutdown

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

func (*Service) Stream

func (s *Service) Stream(streamId string) (*engine.Stream, error)

func (*Service) String

func (s *Service) String() string