Versions in this module Expand all Collapse all v0 v0.1.0 Feb 11, 2021 Changes in this version + type Service struct + 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