processor

Documentation

Index

• Variables
• func IsSchemaLogEvent(d *wal.Data) bool
• func WalDataToLogEntry(d *wal.Data) (*schemalog.LogEntry, error)
• type Processor

Variables

var (
	ErrVersionNotFound = errors.New("version column not found")
	ErrIDNotFound      = errors.New("id column not found")
	ErrTableNotFound   = errors.New("table not found")
	ErrColumnNotFound  = errors.New("column not found")
)

var (
	ErrPanic               = errors.New("panic while processing wal event")
	ErrIncompatibleWalData = errors.New("wal data event is not a schema log entry")
)

Functions

func IsSchemaLogEvent

func IsSchemaLogEvent(d *wal.Data) bool

IsSchemaLogEvent will return true if the wal event data originates from the pgstream schema and the pgstream schema_log table.

func WalDataToLogEntry

func WalDataToLogEntry(d *wal.Data) (*schemalog.LogEntry, error)

WalDataToLogEntry will convert the wal event data on input into the equivalent schemalog entry. It will return an error if the wal event data is not from the schema log table.

Types

type Processor

type Processor interface {
	ProcessWALEvent(ctx context.Context, walEvent *wal.Event) error
	Name() string
}

Processor is a general interface to receive and process a wal event