provider

Documentation

Index

• type MongoEventGenerator
• type MongoProjectionGenerator
• type MongoStorageProvider
  • func NewMongoStorageProvider(db *mongo.Database, collection string, generator MongoProjectionGenerator) *MongoStorageProvider
  • func (provider *MongoStorageProvider) GetLatestEventIDForEntityID(ctx context.Context, entityID string) (string, error)
  • func (provider *MongoStorageProvider) GetProjection(ctx context.Context, entityID string, projection eventing.Projection) (eventing.Projection, error)
  • func (provider *MongoStorageProvider) GetSortedEventsForEntityID(ctx context.Context, entityID string) ([]eventing.Event, error)
  • func (provider *MongoStorageProvider) SaveEvent(ctx context.Context, event eventing.Event) error
  • func (provider *MongoStorageProvider) SaveProjection(ctx context.Context, projection eventing.Projection) error
  • func (provider *MongoStorageProvider) WithEvent(name string, generator MongoEventGenerator) *MongoStorageProvider

Types

type MongoEventGenerator

type MongoEventGenerator func(cursor *mongo.Cursor) (eventing.Event, error)

type MongoProjectionGenerator

type MongoProjectionGenerator func(result *mongo.SingleResult) (eventing.Projection, error)

type MongoStorageProvider

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

func NewMongoStorageProvider

func NewMongoStorageProvider(db *mongo.Database, collection string, generator MongoProjectionGenerator) *MongoStorageProvider

func (*MongoStorageProvider) GetLatestEventIDForEntityID

func (provider *MongoStorageProvider) GetLatestEventIDForEntityID(ctx context.Context, entityID string) (string, error)

func (*MongoStorageProvider) GetProjection

func (provider *MongoStorageProvider) GetProjection(ctx context.Context, entityID string, projection eventing.Projection) (eventing.Projection, error)

func (*MongoStorageProvider) GetSortedEventsForEntityID

func (provider *MongoStorageProvider) GetSortedEventsForEntityID(ctx context.Context, entityID string) ([]eventing.Event, error)

func (*MongoStorageProvider) SaveEvent

func (provider *MongoStorageProvider) SaveEvent(ctx context.Context, event eventing.Event) error

func (*MongoStorageProvider) SaveProjection

func (provider *MongoStorageProvider) SaveProjection(ctx context.Context, projection eventing.Projection) error

func (*MongoStorageProvider) WithEvent

func (provider *MongoStorageProvider) WithEvent(name string, generator MongoEventGenerator) *MongoStorageProvider