registryinit

Documentation

Overview

`registryinit.Processor` watches an `fsomain` event journal and tells `fsoregistry` to initialize registry entities.

Index

• Constants
• type Logger
• type Processor
  • func NewProcessor(names *shorteruuid.Names, lg Logger, mainJ *events.Journal, main *fsomain.Main, ...) *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 Processor

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

func NewProcessor

func NewProcessor(
	names *shorteruuid.Names,
	lg Logger,
	mainJ *events.Journal,
	main *fsomain.Main,
	mainId uuid.I,
	registry *fsoregistry.Registry,
) *Processor

func (*Processor) Process

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