replicate

Documentation

Overview

`replicate.Processor` watches event journals and replicates selected events to other journals.

Index

• Constants
• type Logger
• type Op
• type Processor
  • func NewProcessor(lg Logger, names *shorteruuid.Names, mainJ *events.Journal, ...) *Processor
  • func (p *Processor) Process(ctx context.Context) error

Constants

const (
	NsFsoRegistry = "fsoreg"
)

Types

type Logger

type Logger interface {
	Infow(msg string, kv ...interface{})
	Warnw(msg string, kv ...interface{})
	Errorw(msg string, kv ...interface{})
}

type Op

type Op int

const (
	OpUnspecified Op = iota
	OpInit
	OpUpdate
)

type Processor

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

func NewProcessor

func NewProcessor(
	lg Logger,
	names *shorteruuid.Names,
	mainJ *events.Journal,
	registryJ *events.Journal,
	reposJ *events.Journal,
	workflowsJ *events.Journal,
	registry *fsoregistry.Registry,
	repos *fsorepos.Repos,
	moveRepoWorkflows *moverepowf.Workflows,
	moveShadowWorkflows *moveshadowwf.Workflows,
	mainId uuid.I,
) *Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context) error