postgres

Documentation

Index

• Constants
• Variables
• type Notification
• type Option
• type Publisher
  • func NewPublisher(ctx context.Context, url string, sl string, op string, tables []string, ...) (publisher *Publisher, err error)
  • func (p *Publisher) CreateReplicationSlotServer(ctx context.Context) (err error)
  • func (p *Publisher) Migrate(ctx context.Context) (err error)
  • func (p *Publisher) Start()
  • func (p *Publisher) Subscribe(c chan<- *Notification)
  • func (p *Publisher) Unsubscribe(c chan *Notification)

Constants

const (
	INSERT = "INSERT"
	UPDATE = "UPDATE"
	DELETE = "DELETE"
)

Variables

var Event = struct {
	Entity  string
	Columns []string
}{}

Event -

Types

type Notification

type Notification struct {
	Entity  string                 `json:"entity"`
	Action  string                 `json:"action"`
	OldData map[string]interface{} `json:"old_data"`
	NewData map[string]interface{} `json:"new_data"`
}

Notification -

type Option

type Option func(publisher *Publisher)

Option -.

type Publisher

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

Publisher -

func NewPublisher

func NewPublisher(ctx context.Context, url string, sl string, op string, tables []string, logger logger.Interface) (publisher *Publisher, err error)

NewPublisher -

func (*Publisher) CreateReplicationSlotServer

func (p *Publisher) CreateReplicationSlotServer(ctx context.Context) (err error)

CreateReplicationSlotServer -

func (*Publisher) Migrate

func (p *Publisher) Migrate(ctx context.Context) (err error)

Migrate -

func (*Publisher) Start

func (p *Publisher) Start()

Start -

func (*Publisher) Subscribe

func (p *Publisher) Subscribe(c chan<- *Notification)

Subscribe -

func (*Publisher) Unsubscribe

func (p *Publisher) Unsubscribe(c chan *Notification)

Unsubscribe -