internals

Documentation

Index

• type Config
  • func (config *Config) LoadFromYaml(path string) error
• type PgSync
  • func (pgSync *PgSync) FullReindex()
  • func (pgSync *PgSync) GetPublisher(name string) (types.AbstractPublisher, error)
  • func (pgSync *PgSync) GetPublishers() map[string]types.AbstractPublisher
  • func (pgSync *PgSync) GetSubscriber(name string) (types.AbstractSubscriber, error)
  • func (pgSync *PgSync) GetSubscribers() map[string]types.AbstractSubscriber
  • func (pgSync *PgSync) Init(config *Config) error
  • func (pgSync *PgSync) Start()
  • func (pgSync *PgSync) Terminate()

Types

type Config

type Config struct {
	DefaultIn  string                    `yaml:"default_in"`
	In         map[string]map[string]any `yaml:"in"`
	DefaultOut []string                  `yaml:"default_out"`
	Out        map[string]map[string]any `yaml:"out"`
	Mappings   []map[string]any          `yaml:"mappings"`
}

func (*Config) LoadFromYaml

func (config *Config) LoadFromYaml(path string) error

type PgSync

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

func (*PgSync) FullReindex

func (pgSync *PgSync) FullReindex()

func (*PgSync) GetPublisher

func (pgSync *PgSync) GetPublisher(name string) (types.AbstractPublisher, error)

func (*PgSync) GetPublishers

func (pgSync *PgSync) GetPublishers() map[string]types.AbstractPublisher

func (*PgSync) GetSubscriber

func (pgSync *PgSync) GetSubscriber(name string) (types.AbstractSubscriber, error)

func (*PgSync) GetSubscribers

func (pgSync *PgSync) GetSubscribers() map[string]types.AbstractSubscriber

func (*PgSync) Init

func (pgSync *PgSync) Init(config *Config) error

func (*PgSync) Start

func (pgSync *PgSync) Start()

func (*PgSync) Terminate

func (pgSync *PgSync) Terminate()