mongo

Documentation

Index

• type Provider
  • func NewProvider(db *mongo.Database) *Provider
  • func (p *Provider) Close() error
  • func (p *Provider) GetObject(ctx context.Context, ref *eventgate.ObjectRef) (*eventgate.Object, error)
  • func (p Provider) SaveEvent(ctx context.Context, e *eventgate.Event) error
  • func (p *Provider) SearchEvents(ctx context.Context, opts *eventgate.SearchOpts) (*eventgate.Events, error)
  • func (p Provider) SetObject(ctx context.Context, object *eventgate.Object) error

Types

type Provider

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

func NewProvider

func NewProvider(db *mongo.Database) *Provider

func (*Provider) Close

func (p *Provider) Close() error

func (*Provider) GetObject

func (p *Provider) GetObject(ctx context.Context, ref *eventgate.ObjectRef) (*eventgate.Object, error)

func (Provider) SaveEvent

func (p Provider) SaveEvent(ctx context.Context, e *eventgate.Event) error

func (*Provider) SearchEvents

func (p *Provider) SearchEvents(ctx context.Context, opts *eventgate.SearchOpts) (*eventgate.Events, error)

func (Provider) SetObject

func (p Provider) SetObject(ctx context.Context, object *eventgate.Object) error