persistencesql

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

type Driver string

type Journal struct {
	// the unique id of the journal row
	Ordering int64
	// Persistent ID that journals a persistent message.
	PersistenceID string
	// This persistent message's sequence number
	SequenceNumber int
	// The `timestamp` is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC.
	Timestamp int64
	// This persistent message's payload (the event).
	Payload []byte
	// A type hint for the event. This will be the proto message name of the event
	EventManifest Manifest
	// Unique identifier of the writing persistent actor.
	WriterID string
	// Flag to indicate the event has been deleted when logical deletion is set.
	Deleted bool
}

type Manifest protoreflect.FullName

type OptFunc = func(provider *SQLProvider)

type PoolOpt = func(*DBConfig)

type SQLDialect interface {
	CreateSchemasIfNotExist(ctx context.Context) error

	Connect(ctx context.Context) error
	Close() error

	PersistJournal(ctx context.Context, journal *Journal) error
	PersistSnapshot(ctx context.Context, snapshot *Snapshot) error

	GetLatestSnapshot(ctx context.Context, persistenceID string) (*Snapshot, error)
	GetJournals(ctx context.Context, persistenceID string, fromSequenceNumber int, toSequenceNumber int) (
		[]*Journal, error,
	)

	DeleteSnapshots(ctx context.Context, persistenceID string, toSequenceNumber int) error
	DeleteJournals(ctx context.Context, persistenceID string, toSequenceNumber int, logical bool) error
}

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

type SQLProviderState struct {
	*SQLProvider
	// contains filtered or unexported fields
}

type Snapshot struct {
	// Persistent ID that journals a persistent message.
	PersistenceID string
	// This persistent message's sequence number
	SequenceNumber int
	// The `timestamp` is the time the event was stored, in milliseconds since midnight, January 1, 1970 UTC.
	Timestamp int64
	// This snapshot message's payload.
	Snapshot []byte
	// A type hint for the snapshot. This will be the proto message name of the snapshot
	SnapshotManifest Manifest
	// Unique identifier of the writing persistent actor.
	WriterID string
}