mongo

Documentation

Index

• type Provider
  • func NewProvider(db *mongo.Database) *Provider
  • func (p *Provider) Close() error
  • func (p *Provider) DelState(ctx context.Context, ref *stategate.StateRef) *errorz.Error
  • func (p *Provider) GetState(ctx context.Context, ref *stategate.StateRef) (*stategate.State, *errorz.Error)
  • func (p Provider) SaveEvent(ctx context.Context, e *stategate.Event) *errorz.Error
  • func (p *Provider) SearchEvents(ctx context.Context, opts *stategate.SearchEventOpts) (*stategate.Events, *errorz.Error)
  • func (p *Provider) SearchState(ctx context.Context, opts *stategate.SearchStateOpts) (*stategate.StateValues, *errorz.Error)
  • func (p Provider) SetState(ctx context.Context, state *stategate.State) *errorz.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) DelState

func (p *Provider) DelState(ctx context.Context, ref *stategate.StateRef) *errorz.Error

func (*Provider) GetState

func (p *Provider) GetState(ctx context.Context, ref *stategate.StateRef) (*stategate.State, *errorz.Error)

func (Provider) SaveEvent

func (p Provider) SaveEvent(ctx context.Context, e *stategate.Event) *errorz.Error

func (*Provider) SearchEvents

func (p *Provider) SearchEvents(ctx context.Context, opts *stategate.SearchEventOpts) (*stategate.Events, *errorz.Error)

func (*Provider) SearchState

func (p *Provider) SearchState(ctx context.Context, opts *stategate.SearchStateOpts) (*stategate.StateValues, *errorz.Error)

func (Provider) SetState

func (p Provider) SetState(ctx context.Context, state *stategate.State) *errorz.Error