es

package

v0.0.0-...-4a59535 Latest Latest Go to latest Published: Sep 19, 2024 License: MIT Imports: 7 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func AsProjection(handler interface{}) interface{}

func NewInMemorySubscriptionCheckpointRepository() contracts.SubscriptionCheckpointRepository

func NewProjectionPublisher(projections []projection.IProjection) projection.IProjectionPublisher

type Config struct {
	SnapshotFrequency int64 `json:"snapshotFrequency" validate:"required,gte=0"`
}

Config of es package.

Path	Synopsis
contracts
projection
store
errors
mocks
models
append_result
stream_name
stream_position/read_position
stream_position/truncatePosition
stream_version