collector

Documentation

Index

• type AfterReplication
  • func NewAfterReplication(config *Config, beforeOut, afterOut string, conn *pgx.Conn) *AfterReplication
  • func (c *AfterReplication) Run(ctx context.Context) error
• type BeforeReplication
  • func NewBeforeReplication(config *Config, beforeOut string, conn *pgx.Conn) *BeforeReplication
  • func (c *BeforeReplication) Run(ctx context.Context) error
• type Compare
  • func NewCompare(config *Config, afterFile string, sourceConn, targetConn *pgx.Conn) *Compare
  • func (c *Compare) Run(ctx context.Context) error
• type Config
• type TablesConfig

Types

type AfterReplication

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

func NewAfterReplication

func NewAfterReplication(config *Config, beforeOut, afterOut string, conn *pgx.Conn) *AfterReplication

func (*AfterReplication) Run

func (c *AfterReplication) Run(ctx context.Context) error

type BeforeReplication

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

func NewBeforeReplication

func NewBeforeReplication(config *Config, beforeOut string, conn *pgx.Conn) *BeforeReplication

func (*BeforeReplication) Run

func (c *BeforeReplication) Run(ctx context.Context) error

type Compare

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

func NewCompare

func NewCompare(config *Config, afterFile string, sourceConn, targetConn *pgx.Conn) *Compare

func (*Compare) Run

func (c *Compare) Run(ctx context.Context) error

type Config

type Config struct {
	Tables map[string]TablesConfig `yaml:"tables"`
}

type TablesConfig

type TablesConfig struct {
	Collect string `yaml:"collect"`
	Compare string `yaml:"compare"`
}