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 *eventgate.ObjectRef) (*eventgate.Object, error)
  • func (s Service) SearchEvents(ctx context.Context, opts *eventgate.SearchOpts) (*eventgate.Events, error)
  • func (s Service) SetObject(ctx context.Context, object *eventgate.Object) (*empty.Empty, error)
  • func (s Service) StreamEvents(opts *eventgate.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 *eventgate.ObjectRef) (*eventgate.Object, error)

func (Service) SearchEvents

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

func (Service) SetObject

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

func (Service) StreamEvents

func (s Service) StreamEvents(opts *eventgate.StreamOpts, server eventgate.EventGateService_StreamEventsServer) error