replication

type Action = string

type Change struct {
	Action       Action        `json:"kind"`
	Schema       string        `json:"schema"`
	Table        string        `json:"table"`
	ColumnNames  []string      `json:"columnnames"`
	ColumnTypes  []string      `json:"columntypes"`
	ColumnValues []interface{} `json:"columnvalues"`
	OldKeys      *OldKeys      `json:"oldkeys,omitempty"`
}

type Config struct {
	LogLevel                    zapcore.Level   `cpln:"default:info;mapper:ZapLogLevelMapper"`
	Host                        string          `json:"-"`
	Port                        string          `json:"-"`
	User                        string          `json:"-"`
	Database                    string          `json:"-"`
	Password                    string          `json:"-"`
	Slot                        string          `json:"slot"`
	WalAcknowledgementFrequency time.Duration   `cpln:"default:30s" json:"-"`
	Destinations                DestinationList `json:"destinations"`
}

type DestinationKind string

type DestinationList []*DestinationSpec

type DestinationSpec struct {
	Map        `json:",inline"`
	Kind       DestinationKind `json:"kind"`
	Parameters map[string]any  `json:"parameters"`
}

type Map struct {
	Name     string            `json:"name"`
	Table    string            `json:"table"`
	FieldMap map[string]string `json:"fieldMap"`
	Fields   []string          `json:"fields"`
	Actions  []Action          `json:"actions"`
}

type Mapping struct {
	Maps []Map `json:"maps"`
}

type Message struct {
	Id        string         `json:"id"`
	Created   string         `json:"created"`
	Delivered string         `json:"delivered"`
	Payload   map[string]any `json:"payload" gorm:"type:jsonb"`
}

type OldKeys struct {
	KeyNames  []string      `json:"keynames"`
	KeyTypes  []string      `json:"keytypes"`
	KeyValues []interface{} `json:"keyvalues"`
}

type WalData struct {
	Changes []*Change `json:"change"`
}