nogfsoregd

Documentation

Overview

Package `nogfsoregd` implements modules that are combined in `cmd/nogfsoregd`.

`NewMainServer()`, `maind.Server`: GRPC service `nogfso.Main` to access the FSO main root entity,

`NewRegistryServer()`, `registryd.Server`: GRPC service `nogfso.Registry` to access the FSO registry,

`NewReposServer()`, `reposd.Server`: GRPC service `nogfso.Repos` to access the FSO repos.

`NewStatdsServer()`, `statdsd.Server`: GRPC service `nogfso.Statds`; `nogfsostad` host servers connect in permanent sessions and wait to execute commands. Also GRPC service `nogfso.Stat`; calls are forwarded to host server sessions.

`ProcessRegistryInit()`, `registryinit.Processor`: Watches main journal and initializes fsoregistry entities.

`ProcessRepoInit()`, `repoinit.Processor`: Watches registry journals and initializes repo entities.

Index

• func NewBroadcastServer(ctx context.Context, lg Logger, authn auth.Authenticator, ...) *broadcastd.Server
• func NewMainServer(ctx context.Context, authn auth.Authenticator, authz auth.Authorizer, ...) *maind.Server
• func NewReposServer(ctx context.Context, lg Logger, authn auth.Authenticator, ...) *reposd.Server
• func NewStatdsServer(lg Logger, advertiseAddr string, tls credentials.TransportCredentials, ...) *statdsd.Server
• func ProcessRegistryInit(ctx context.Context, lg Logger, n *shorteruuid.Names, mainJ *events.Journal, ...) error
• func ProcessRepoInit(ctx context.Context, lg Logger, n *shorteruuid.Names, mainJ *events.Journal, ...) error
• type Logger

Functions

func NewBroadcastServer

func NewBroadcastServer(
	ctx context.Context,
	lg Logger,
	authn auth.Authenticator,
	authz auth.Authorizer,
	names *shorteruuid.Names,
	broadcastJ *events.Journal,
) *broadcastd.Server

func NewMainServer

func NewMainServer(
	ctx context.Context,
	authn auth.Authenticator,
	authz auth.Authorizer,
	main *fsomain.Main,
	mainId uuid.I,
	mainName string,
) *maind.Server

func NewReposServer

func NewReposServer(
	ctx context.Context,
	lg Logger,
	authn auth.Authenticator,
	authz auth.Authorizer,
	names *shorteruuid.Names,
	reposJ *events.Journal,
	repos *fsorepos.Repos,
	workflowsJ *events.Journal,
	moveRepoWorkflows *moverepowf.Workflows,
	moveShadowWorkflows *moveshadowwf.Workflows,
) *reposd.Server

func NewStatdsServer

func NewStatdsServer(
	lg Logger,
	advertiseAddr string,
	tls credentials.TransportCredentials,
	authn auth.Authenticator,
	authz auth.Authorizer,
	repos *fsorepos.Repos,
) *statdsd.Server

func ProcessRegistryInit

func ProcessRegistryInit(
	ctx context.Context,
	lg Logger,
	n *shorteruuid.Names,
	mainJ *events.Journal,
	main *fsomain.Main,
	mainId uuid.I,
	reg *fsoregistry.Registry,
) error

func ProcessRepoInit

func ProcessRepoInit(
	ctx context.Context,
	lg Logger,
	n *shorteruuid.Names,
	mainJ *events.Journal,
	main *fsomain.Main,
	mainId uuid.I,
	regJ *events.Journal,
	reg *fsoregistry.Registry,
	repos *fsorepos.Repos,
) error

Types

type Logger

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