mutantdb

type Conn interface {
	Begin(context.Context) (pgx.Tx, error)
	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
	QueryRow(context.Context, string, ...any) pgx.Row
	Query(context.Context, string, ...any) (pgx.Rows, error)
}

type Cursor[T any] struct {
	// contains filtered or unexported fields
}

type ErrConflict struct {
	CurrentMutationID, ExpectedMutationID string
}

type Listener[T any] struct {
	// contains filtered or unexported fields
}

type Meta map[string]string

type Mutation[T any] interface {
	Name() string
	Data() any
	Meta() Meta
	Apply(T) (T, error)
}

type Mutator[T any] interface {
	Name() string
	Apply(T, any) (T, error)
}

type Projection[T any] struct {
	ID          string    `json:"entity_id"`
	Data        T         `json:"entity_data"`
	MutationID  string    `json:"mutation_id"`
	DateCreated time.Time `json:"date_created"`
	DateUpdated time.Time `json:"date_updated"`
}

type Store[T any] struct {
	// contains filtered or unexported fields
}

type Type[T any] struct {
	// contains filtered or unexported fields
}