store

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

type BadgerStoreOptions struct {
	DB             *badger.DB
	EstimateCounts bool
}

type EventStore interface {
	/*
		Adds event to specified stream at specfied version offset. Returns the persisted events and
		an error in case of concurrent stream modification.
	*/
	// Add(stream uuid.UUID, version uint32, events []EventData) ([]Event, error)
	Add(*api.AddRequest) (*api.EventResponse, error)

	/*
		Returns events for specified stream, offset at given version and limits the resulting set by the given limit.
		If limit is zero, then all events from given version onwards will be returned.
	*/
	Get(*api.GetRequest) (*api.EventResponse, error)

	/*
		Returns amount of events that have been recorded since the given offset. The maximum amount of returned events is specified by the given limit.
		If the limit is 0, then it will return a maximum of 100 events.
	*/
	GetAll(*api.GetAllRequest) (*api.EventResponse, error)

	/*
		Size of the database in bytes on disk
	*/
	Size(*api.SizeRequest) (*api.SizeResponse, error)

	/*
		Writes a snapshot of the database to a writer
	*/
	Backup(dst io.Writer) error

	/*
		Returns the total number of events stored in the database
	*/
	EventCount(*api.EventCountRequest) (*api.EventCountResponse, error)

	/*
		Returns the total number of streams in the database
	*/
	StreamCount(*api.StreamCountRequest) (*api.StreamCountResponse, error)

	/*
		Returns an estimate of the total number of events stored in the database
	*/
	EventCountEstimate(*api.EventCountEstimateRequest) (*api.EventCountResponse, error)

	/*
		Returns an estimate of the total number of streams in the database
	*/
	StreamCountEstimate(*api.StreamCountEstimateRequest) (*api.StreamCountResponse, error)

	ListStreams(*api.ListStreamsRequest) (*api.ListStreamsReponse, error)

	Close() error
}

type PersistedEvent struct {
	Id            []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Stream        []byte `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
	Version       uint32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Type          string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Data          []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Metadata      []byte `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	CausationId   []byte `protobuf:"bytes,7,opt,name=causation_id,json=causationId,proto3" json:"causation_id,omitempty"`
	CorrelationId []byte `protobuf:"bytes,8,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	AddedAt       int64  `protobuf:"varint,9,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`
	// contains filtered or unexported fields
}

type PersistedStream struct {
	Id      []byte   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Events  [][]byte `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	AddedAt int64    `protobuf:"varint,3,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`
	// contains filtered or unexported fields
}