service

Documentation

Index

• type Service
  • func NewService(storage storage.Provider, channel channel.Provider, lgger *logger.Logger) (*Service, error)
  • func (s Service) Close() error
  • func (s Service) GetObject(ctx context.Context, ref *stategate.ObjectRef) (*stategate.Object, error)
  • func (s Service) SearchEvents(ctx context.Context, opts *stategate.SearchOpts) (*stategate.Events, error)
  • func (s Service) SetObject(ctx context.Context, object *stategate.Object) (*empty.Empty, error)
  • func (s Service) StreamEvents(opts *stategate.StreamOpts, ...) error

Types

type Service

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

func NewService

func NewService(storage storage.Provider, channel channel.Provider, lgger *logger.Logger) (*Service, error)

func (Service) Close

func (s Service) Close() error

func (Service) GetObject

func (s Service) GetObject(ctx context.Context, ref *stategate.ObjectRef) (*stategate.Object, error)

func (Service) SearchEvents

func (s Service) SearchEvents(ctx context.Context, opts *stategate.SearchOpts) (*stategate.Events, error)

func (Service) SetObject

func (s Service) SetObject(ctx context.Context, object *stategate.Object) (*empty.Empty, error)

func (Service) StreamEvents

func (s Service) StreamEvents(opts *stategate.StreamOpts, server stategate.StateGateService_StreamEventsServer) error