repoinit

Documentation

Overview

`repoinit.Processor` watches a `fsoregistry` event journal and tells `fsorepos.Repos` to initialize repo instances.

XXX The processing logic might perhaps be merged with package `replicate`. But it is not straightforward, because repoinit needs to maintain state about the roots.

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
• type RootInfo

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,
	registryJ *events.Journal,
	registry *fsoregistry.Registry,
	repos *fsorepos.Repos,
) *Processor

func (*Processor) Process

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

type RootInfo

type RootInfo struct {
	GlobalRoot             string
	Host                   string
	HostRoot               string
	GitlabNamespace        string
	InitPolicy             *pb.FsoRepoInitPolicy
	ArchiveRecipients      gpg.Fingerprints
	ShadowBackupRecipients gpg.Fingerprints
}