couchbase

package

v1.0.0 Latest Latest Go to latest Published: Jan 20, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package couchbase provides an event sourcing implementation in couchbase for the CQRS and Event Sourcing framework

Current version: experimental

View Source

const NotFound string = "Not found"

NotFound error string returned from couchbase when a key cannot be found

This section is empty.

func IsNotFoundError(err error) bool

IsNotFoundError checks if we get a key not found error from couchbase

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

EventStreamRepository : a Couchbase Server event stream repository

func NewEventStreamRepository(connectionString string, poolName string, bucketName string, prefix string) (*EventStreamRepository, error)

NewEventStreamRepository creates new Couchbase Server based event stream repository

func (r *EventStreamRepository) AllIntegrationEventsEverPublished() ([]cqrs.VersionedEvent, error)

AllIntegrationEventsEverPublished retreives all events every persisted

func (r *EventStreamRepository) Get(id string, fromVersion int) ([]cqrs.VersionedEvent, error)

Get retrieves events assoicated with an event sourced object by ID

func (r *EventStreamRepository) GetIntegrationEventsByCorrelationID(correlationID string) ([]cqrs.VersionedEvent, error)

GetIntegrationEventsByCorrelationID returns all integration events by correlation ID

func (r *EventStreamRepository) GetSnapshot(id string) (cqrs.EventSourced, error)

func (r *EventStreamRepository) Save(sourceID string, events []cqrs.VersionedEvent) error

Save persists an event sourced object into the repository

func (r *EventStreamRepository) SaveIntegrationEvent(event cqrs.VersionedEvent) error

SaveIntegrationEvent persists a published integration event

func (r *EventStreamRepository) SaveSnapshot(eventsourced cqrs.EventSourced) error