pg

package module
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2020 License: MIT Imports: 14 Imported by: 0

README

GO Event Store PostgreSQL Provider

Test Workflow

More details: GO EventStore

Documentation

Index

Constants

View Source 
const (
	EventStreamsTable = "event_streams"
	ProjectionsTable  = "projections"
)

Variables

This section is empty.

Functions

func GenerateTableName 

func GenerateTableName(streamName string) string

Types

type Client 

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

func NewClient 

func NewClient(db *pgxpool.Pool) *Client

func (*Client) Conn 

func (c *Client) Conn() interface{}

func (*Client) Delete 

func (c *Client) Delete(ctx context.Context, collection string) error

func (*Client) Exists 

func (c *Client) Exists(ctx context.Context, collection string) (bool, error)

func (*Client) Insert 

func (c *Client) Insert(ctx context.Context, collection string, values map[string]interface{}) error

func (*Client) Remove 

func (c *Client) Remove(ctx context.Context, collection string, identifiers map[string]interface{}) error

func (*Client) Reset 

func (c *Client) Reset(ctx context.Context, collection string) error

func (*Client) Update 

func (c *Client) Update(ctx context.Context, collection string, values map[string]interface{}, identifiers map[string]interface{}) error

type DomainEventIterator 

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

func NewDomainEventIterator 

func NewDomainEventIterator(ctx context.Context, db *pgxpool.Pool, query string, parameters []interface{}, count int) *DomainEventIterator

func (*DomainEventIterator) Close 

func (it *DomainEventIterator) Close()

func (*DomainEventIterator) Current 

func (it *DomainEventIterator) Current() (*eventstore.DomainEvent, error)

func (*DomainEventIterator) Error 

func (it *DomainEventIterator) Error() error

func (*DomainEventIterator) IsEmpty 

func (it *DomainEventIterator) IsEmpty() (bool, error)

func (*DomainEventIterator) Next 

func (it *DomainEventIterator) Next() bool

func (*DomainEventIterator) Rewind 

func (it *DomainEventIterator) Rewind()

func (*DomainEventIterator) ToList 

func (it *DomainEventIterator) ToList() ([]eventstore.DomainEvent, error)

type PersistenceStrategy 

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

func NewPersistenceStrategy 

func NewPersistenceStrategy(db *pgxpool.Pool) *PersistenceStrategy

func (PersistenceStrategy) AddStreamToStreamsTable 

func (ps PersistenceStrategy) AddStreamToStreamsTable(ctx context.Context, streamName string) error

func (PersistenceStrategy) AppendTo 

func (ps PersistenceStrategy) AppendTo(ctx context.Context, streamName string, events []eventstore.DomainEvent) error

func (PersistenceStrategy) CreateEventStreamsTable 

func (ps PersistenceStrategy) CreateEventStreamsTable(ctx context.Context) error

func (PersistenceStrategy) CreateProjectionsTable 

func (ps PersistenceStrategy) CreateProjectionsTable(ctx context.Context) error

func (PersistenceStrategy) CreateSchema 

func (ps PersistenceStrategy) CreateSchema(ctx context.Context, streamName string) error

func (PersistenceStrategy) DeleteStream 

func (ps PersistenceStrategy) DeleteStream(ctx context.Context, streamName string) error

func (PersistenceStrategy) DropSchema 

func (ps PersistenceStrategy) DropSchema(ctx context.Context, streamName string) error

func (PersistenceStrategy) FetchAllStreamNames 

func (ps PersistenceStrategy) FetchAllStreamNames(ctx context.Context) ([]string, error)

func (PersistenceStrategy) HasStream 

func (ps PersistenceStrategy) HasStream(ctx context.Context, streamName string) (bool, error)

func (PersistenceStrategy) Load 

func (ps PersistenceStrategy) Load(ctx context.Context, streamName string, fromNumber, count int, matcher eventstore.MetadataMatcher) (eventstore.DomainEventIterator, error)

func (PersistenceStrategy) MergeAndLoad 

func (ps PersistenceStrategy) MergeAndLoad(ctx context.Context, count int, streams ...eventstore.LoadStreamParameter) (eventstore.DomainEventIterator, error)

func (PersistenceStrategy) RemoveStreamFromStreamsTable 

func (ps PersistenceStrategy) RemoveStreamFromStreamsTable(ctx context.Context, streamName string) error

type ProjectionManager 

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

func NewProjectionManager 

func NewProjectionManager(db *pgxpool.Pool) *ProjectionManager

func (ProjectionManager) CreateProjection 

func (pm ProjectionManager) CreateProjection(ctx context.Context, projectionName string, state interface{}, status eventstore.Status) error

func (ProjectionManager) DeleteProjection 

func (pm ProjectionManager) DeleteProjection(ctx context.Context, projectionName string) error

func (ProjectionManager) FetchProjectionStatus 

func (pm ProjectionManager) FetchProjectionStatus(ctx context.Context, projectionName string) (eventstore.Status, error)

func (ProjectionManager) LoadProjection 

func (pm ProjectionManager) LoadProjection(ctx context.Context, projectionName string) (map[string]int, interface{}, error)

func (ProjectionManager) PersistProjection 

func (pm ProjectionManager) PersistProjection(ctx context.Context, projectionName string, state interface{}, streamPositions map[string]int) error

func (ProjectionManager) ProjectionExists 

func (pm ProjectionManager) ProjectionExists(ctx context.Context, projectionName string) (bool, error)

func (ProjectionManager) ResetProjection 

func (pm ProjectionManager) ResetProjection(ctx context.Context, projectionName string, state interface{}) error

func (ProjectionManager) UpdateProjectionStatus 

func (pm ProjectionManager) UpdateProjectionStatus(ctx context.Context, projectionName string, status eventstore.Status) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.