schemalog

type Column struct {
	Name         string  `json:"name"`
	DataType     string  `json:"type"`
	DefaultValue *string `json:"default,omitempty"`
	Nullable     bool    `json:"nullable"`
	Unique       bool    `json:"unique"`
	// Metadata is NOT typed here because we don't fully control the content that is sent from the publisher.
	Metadata   *string `json:"metadata"`
	PgstreamID string  `json:"pgstream_id"`
}

type LogEntry struct {
	ID         xid.ID                   `json:"id"`
	Version    int64                    `json:"version"`
	SchemaName string                   `json:"schema_name"`
	CreatedAt  SchemaCreatedAtTimestamp `json:"created_at"`
	Schema     Schema                   `json:"schema"`
	// Acked indicates if the schema has been processed and acknowledged by
	// pgstream after being updated in the source database
	Acked bool `json:"acked"`
}

type Schema struct {
	Tables []Table `json:"tables"`
	// Dropped will be true if the schema has been deleted
	Dropped bool `json:"dropped,omitempty"`
}

type SchemaCreatedAtTimestamp struct {
	time.Time
}

type SchemaDiff struct {
	TablesToRemove      []Table
	ColumnsToAdd        []Column
	PrimaryKeyChange    []string
	UniqueNotNullChange []string
}

type Store interface {
	Insert(ctx context.Context, schemaName string) (*LogEntry, error)
	Fetch(ctx context.Context, schemaName string, ackedOnly bool) (*LogEntry, error)
	Ack(ctx context.Context, le *LogEntry) error
	Close() error
}

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

type Table struct {
	Oid               string   `json:"oid"`
	Name              string   `json:"name"`
	Columns           []Column `json:"columns"`
	PrimaryKeyColumns []string `json:"primary_key_columns"`
	// PgstreamID is a unique identifier of the table generated by pgstream
	PgstreamID string `json:"pgstream_id"`
}