firestore

Documentation

Overview

Package firestore implements go-eventually interfaces (such as event.Store) using Google Cloud Firestore as backend.

Index

• type EventStore
  • func NewEventStore(client *firestore.Client, msgSerde serde.Bytes[message.Message]) EventStore
  • func (es EventStore) Append(ctx context.Context, id event.StreamID, expected version.Check, ...) (version.Version, error)
  • func (es EventStore) Stream(ctx context.Context, stream event.StreamWrite, id event.StreamID, ...) error

Types

type EventStore

type EventStore struct {
	Client *firestore.Client
	Serde  serde.Bytes[message.Message]
}

EventStore is an event.Store implementation using Google Cloud Firestore as backend.

func NewEventStore

func NewEventStore(client *firestore.Client, msgSerde serde.Bytes[message.Message]) EventStore

NewEventStore creates a new EventStore instance.

func (EventStore) Append

func (es EventStore) Append(
	ctx context.Context,
	id event.StreamID,
	expected version.Check,
	events ...event.Envelope,
) (version.Version, error)

Append implements the event.Appender interface.

func (EventStore) Stream

func (es EventStore) Stream(
	ctx context.Context,
	stream event.StreamWrite,
	id event.StreamID,
	selector version.Selector,
) error

Stream implements the event.Streamer interface.