publication

Documentation

Index

• Constants
• Variables
• type Config
  • func NewConfig(opts ...Option) Config
  • func (c *Config) Validate() error
• type Operation
  • func (op Operation) Validate() error
• type Operations
  • func (ops Operations) String() string
  • func (ops Operations) Validate() error
• type Option
  • func WithCreateIfNotExists(createIfNotExists bool) Option
  • func WithName(name string) Option
  • func WithOperations(operations Operations) Option
  • func WithTables(tables Tables) Option
• type Publication
  • func New(cfg Config, conn pg.Connection) *Publication
  • func (p *Publication) AddTable(ctx context.Context, table Table) error
  • func (p *Publication) AlterTableReplicaIdentity(ctx context.Context, t Table) error
  • func (p *Publication) Create(ctx context.Context) (*Config, error)
  • func (p *Publication) GetReplicaIdentities(ctx context.Context) ([]Table, error)
  • func (p *Publication) Info(ctx context.Context) (*Config, error)
  • func (p *Publication) RemoveTable(ctx context.Context, table Table) error
  • func (p *Publication) SetReplicaIdentities(ctx context.Context) error
• type Table
  • func NewTable(name string, opts ...TableOption) Table
  • func (t Table) Validate() error
• type TableOption
  • func WithIndexName(indexName string) TableOption
  • func WithReplicaIdentity(replicaIdentity string) TableOption
  • func WithSchema(schema string) TableOption
• type Tables
  • func (ts Tables) Diff(tss Tables) Tables
  • func (ts Tables) Validate() error

Constants

const (
	ReplicaIdentityDefault = "DEFAULT"
	ReplicaIdentityFull    = "FULL"
	ReplicaIdentityIndex   = "INDEX"
	ReplicaIdentityNothing = "NOTHING"
)

Variables

var (
	ErrTablesNotExist      = errors.New("table does not exist")
	ReplicaIdentityOptions = []string{ReplicaIdentityDefault, ReplicaIdentityFull, ReplicaIdentityIndex, ReplicaIdentityNothing}
	ReplicaIdentityMap     = map[string]string{
		"d": ReplicaIdentityDefault,
		"f": ReplicaIdentityFull,
		"i": ReplicaIdentityIndex,
		"n": ReplicaIdentityNothing,
	}
)

var ErrPublicationNotExists = errors.New("publication does not exist")

var OperationOptions = Operations{"INSERT", "UPDATE", "DELETE", "TRUNCATE"}

Types

type Config

type Config struct {
	Name              string
	Operations        Operations
	Tables            Tables
	CreateIfNotExists bool
}

func NewConfig

func NewConfig(opts ...Option) Config

func (*Config) Validate

func (c *Config) Validate() error

type Operation

type Operation string

var (
	OperationInsert   Operation = "INSERT"
	OperationUpdate   Operation = "UPDATE"
	OperationDelete   Operation = "DELETE"
	OperationTruncate Operation = "TRUNCATE"
)

func (Operation) Validate

func (op Operation) Validate() error

type Operations

type Operations []Operation

func (Operations) String

func (ops Operations) String() string

func (Operations) Validate

func (ops Operations) Validate() error

type Option

type Option func(*Config)

func WithCreateIfNotExists

func WithCreateIfNotExists(createIfNotExists bool) Option

func WithName

func WithName(name string) Option

func WithOperations

func WithOperations(operations Operations) Option

func WithTables

func WithTables(tables Tables) Option

type Publication

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

func New

func New(cfg Config, conn pg.Connection) *Publication

func (*Publication) AddTable

func (p *Publication) AddTable(ctx context.Context, table Table) error

func (*Publication) AlterTableReplicaIdentity

func (p *Publication) AlterTableReplicaIdentity(ctx context.Context, t Table) error

func (*Publication) Create

func (p *Publication) Create(ctx context.Context) (*Config, error)

func (*Publication) GetReplicaIdentities

func (p *Publication) GetReplicaIdentities(ctx context.Context) ([]Table, error)

func (*Publication) Info

func (p *Publication) Info(ctx context.Context) (*Config, error)

func (*Publication) RemoveTable

func (p *Publication) RemoveTable(ctx context.Context, table Table) error

func (*Publication) SetReplicaIdentities

func (p *Publication) SetReplicaIdentities(ctx context.Context) error

type Table

type Table struct {
	Name            string
	ReplicaIdentity string
	Schema          string
	IndexName       string
}

func NewTable

func NewTable(name string, opts ...TableOption) Table

func (Table) Validate

func (t Table) Validate() error

type TableOption

type TableOption func(*Table)

func WithIndexName

func WithIndexName(indexName string) TableOption

func WithReplicaIdentity

func WithReplicaIdentity(replicaIdentity string) TableOption

func WithSchema

func WithSchema(schema string) TableOption

type Tables

type Tables []Table

func (Tables) Diff

func (ts Tables) Diff(tss Tables) Tables

func (Tables) Validate

func (ts Tables) Validate() error