pgoutbox

Documentation

Index

• Variables
• type App
  • func NewApp(conn pgclient.PGConnector, batcher Batcher, parser Parser, delayable bool) (*App, error)
  • func NewApps(envConfig OutboxConfig, parser Parser, sender Batcher, ...) ([]*App, error)
  • func (a *App) Run(ctx context.Context) error
• type Batcher
• type Outbox
  • func NewOutbox(connector pgConnector, publisher Batcher, parser Parser, delayable bool) (*Outbox, error)
  • func (o *Outbox) Run(ctx context.Context) error
• type OutboxConfig
• type Parser

Variables

var ErrSend = errors.New("error sending batch of outbox messages")

Types

type App

type App struct {
	Name string
	*Outbox
}

func NewApp

func NewApp(conn pgclient.PGConnector, batcher Batcher, parser Parser, delayable bool) (*App, error)

func NewApps

func NewApps(envConfig OutboxConfig, parser Parser, sender Batcher, pgConfigs pgclient.ConfigSet) ([]*App, error)

func (*App) Run

func (a *App) Run(ctx context.Context) error

type Batcher

type Batcher interface {
	PublishBatch(ctx context.Context, messages []*messaging_pb.Message) ([]string, error)
}

type Outbox

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

func NewOutbox

func NewOutbox(connector pgConnector, publisher Batcher, parser Parser, delayable bool) (*Outbox, error)

func (*Outbox) Run

func (o *Outbox) Run(ctx context.Context) error

type OutboxConfig

type OutboxConfig struct {
	PostgresOutboxURI       []string `env:"POSTGRES_OUTBOX" default:""`
	PostgresOutboxDelayable bool     `env:"POSTGRES_OUTBOX_DELAYABLE" default:"false"`
}

type Parser

type Parser interface {
	ParseMessage(id string, data []byte) (*messaging_pb.Message, error)
}