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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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 ¶
Types ¶
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package `maind`: GRPC service `nogfso.Main` to access the FSO main root entity.
|
Package `maind`: GRPC service `nogfso.Main` to access the FSO main root entity. |
|
Package `registryd`: GRPC service `nogfso.Registry` to access the FSO registry.
|
Package `registryd`: GRPC service `nogfso.Registry` to access the FSO registry. |
|
`registryinit.Processor` watches an `fsomain` event journal and tells `fsoregistry` to initialize registry entities.
|
`registryinit.Processor` watches an `fsomain` event journal and tells `fsoregistry` to initialize registry entities. |
|
`replicate.Processor` watches event journals and replicates selected events to other journals.
|
`replicate.Processor` watches event journals and replicates selected events to other journals. |
|
`repoinit.Processor` watches a `fsoregistry` event journal and tells `fsorepos.Repos` to initialize repo instances.
|
`repoinit.Processor` watches a `fsoregistry` event journal and tells `fsorepos.Repos` to initialize repo instances. |
|
Package `reposd`: GRPC service `nogfso.Repos` to access the FSO repos.
|
Package `reposd`: GRPC service `nogfso.Repos` to access the FSO repos. |