replica

Documentation

Index

• Constants
• type Operator
• type Replicator
  • func New(operator Operator) *Replicator
  • func (r *Replicator) Replicate(event event.ChangeEvent) error

Constants

const (
	OpInsert       = "insert"
	OpDelete       = "delete"
	OpReplace      = "replace"
	OpUpdate       = "update"
	OpDrop         = "drop"
	OpRename       = "rename"
	OpDropDatabase = "dropDatabase"
	OpInvalidate   = "invalidate"
)

Types

type Operator

type Operator interface {
	Insert(event event.ChangeEvent) error
	Delete(event event.ChangeEvent) error
	Replace(event event.ChangeEvent) error
	Update(event event.ChangeEvent) error
	Drop(event event.ChangeEvent) error
	Rename(event event.ChangeEvent) error
	DropDatabase(event event.ChangeEvent) error
	Invalidate(event event.ChangeEvent) error
}

type Replicator

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

func New

func New(operator Operator) *Replicator

func (*Replicator) Replicate

func (r *Replicator) Replicate(event event.ChangeEvent) error