registryd

package
v0.0.0-...-4450389 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 4, 2019 License: MIT Imports: 30 Imported by: 0

Documentation

Overview

Package `registryd`: GRPC service `nogfso.Registry` to access the FSO registry.

Index

Constants

View Source 
const (
	NsFsoMain                       = "fsomain"
	NsFsoRegistry                   = "fsoreg"
	NsFsoRegistryEphemeralWorkflows = "fsoregephwfl"
)
View Source 
const AAFsoAdminRegistry = fsoauthz.AAFsoAdminRegistry
View Source 
const AAFsoAdminRepo = fsoauthz.AAFsoAdminRepo
View Source 
const AAFsoAdminRoot = fsoauthz.AAFsoAdminRoot
View Source 
const AAFsoArchiveRepo = fsoauthz.AAFsoArchiveRepo
View Source 
const AAFsoDeleteRoot = fsoauthz.AAFsoDeleteRoot
View Source 
const AAFsoEnableDiscoveryPath = fsoauthz.AAFsoEnableDiscoveryPath
View Source 
const AAFsoExecArchiveRepo = fsoauthz.AAFsoExecArchiveRepo
View Source 
const AAFsoExecDu = fsoauthz.AAFsoExecDu
View Source 
const AAFsoExecFreezeRepo = fsoauthz.AAFsoExecFreezeRepo
View Source 
const AAFsoExecPingRegistry = fsoauthz.AAFsoExecPingRegistry
View Source 
const AAFsoExecSplitRoot = fsoauthz.AAFsoExecSplitRoot
View Source 
const AAFsoExecUnarchiveRepo = fsoauthz.AAFsoExecUnarchiveRepo
View Source 
const AAFsoExecUnfreezeRepo = fsoauthz.AAFsoExecUnfreezeRepo
View Source 
const AAFsoFreezeRepo = fsoauthz.AAFsoFreezeRepo
View Source 
const AAFsoInitRegistry = fsoauthz.AAFsoInitRegistry
View Source 
const AAFsoInitRepo = fsoauthz.AAFsoInitRepo
View Source 
const AAFsoInitRoot = fsoauthz.AAFsoInitRoot
View Source 
const AAFsoReadRegistry = fsoauthz.AAFsoReadRegistry
View Source 
const AAFsoReadRepo = fsoauthz.AAFsoReadRepo
View Source 
const AAFsoReadRoot = fsoauthz.AAFsoReadRoot
View Source 
const AAFsoUnarchiveRepo = fsoauthz.AAFsoUnarchiveRepo
View Source 
const AAFsoUnfreezeRepo = fsoauthz.AAFsoUnfreezeRepo

Variables

View Source 
var ErrDefaultDeny = status.Error(
	codes.PermissionDenied, "default deny",
)
View Source 
var ErrDenyUnknownWorkflowType = status.Error(
	codes.PermissionDenied, "deny access to unknown workflow type",
)
View Source 
var ErrForeignRegistryWorkflow = status.Error(
	codes.PermissionDenied, "registry does not own workflow",
)
View Source 
var ErrInconsistentRegistryState = status.Error(
	codes.Internal, "inconsistent registry state",
)
View Source 
var ErrMalformedAfter = status.Error(
	codes.InvalidArgument, "malformed after",
)
View Source 
var ErrMalformedJobControl = status.Error(
	codes.InvalidArgument, "malformed job control",
)
View Source 
var ErrMalformedPath = status.Error(
	codes.InvalidArgument, "malformed path",
)
View Source 
var ErrMalformedVid = status.Error(
	codes.InvalidArgument, "malformed VID",
)
View Source 
var ErrMalformedWorkflowId = status.Error(
	codes.InvalidArgument, "malformed workflow ID",
)
View Source 
var ErrMissingConfig = status.Error(
	codes.InvalidArgument, "missing config",
)
View Source 
var ErrParsePb = status.Error(
	codes.Internal, "failed to parse protobuf",
)
View Source 
var ErrPartialResult = status.Error(
	codes.Unknown, "partial result",
)
View Source 
var ErrPathNotCandidate = status.Error(
	codes.FailedPrecondition, "path is not a candidate",
)
View Source 
var ErrPathOutsideRoot = status.Error(
	codes.FailedPrecondition, "path outside of root",
)
View Source 
var ErrShutdown = status.Error(
	codes.Unavailable, "shutdown",
)
View Source 
var ErrSplitRootDecisionUnimplemented = status.Error(
	codes.Unimplemented, "unimplemented split-root decision",
)
View Source 
var ErrSplitRootDisabled = status.Error(
	codes.FailedPrecondition, "split root disabled",
)
View Source 
var ErrUnknownRoot = status.Errorf(
	codes.NotFound, "%s", fsoregistry.ErrUnknownRoot,
)
View Source 
var ErrUnknownWorkflow = status.Error(
	codes.NotFound, "unknown workflow",
)
View Source 
var ErrUnknownWorkflowState = status.Error(
	codes.Internal, "unknown workflow state",
)
View Source 
var ErrVersionConflict = status.Error(
	codes.FailedPrecondition, "version conflict",
)

Functions

This section is empty.

Types

type IdChecker 

type IdChecker interface {
	IsUnusedId(uuid.I) (decision string, err error)
}

type Logger 

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

type Server 

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

Canceling the server `ctx` stops streaming connections. Use it together with `grpc.Server.GracefulStop()`:

``` cancel() // non-blocking gsrv.GracefulStop() // blocking ```

func New 

func New(
	ctx context.Context,
	lg Logger,
	authn auth.Authenticator,
	authz auth.AnyAuthorizer,
	names *shorteruuid.Names,
	idChecker IdChecker,
	main *fsomain.Main,
	mainId uuid.I,
	registryJ *events.Journal,
	registry *fsoregistry.Registry,
	repos *fsorepos.Repos,
	ephWorkflowsJ *events.Journal,
	workflowIndexes *wfindexes.Indexes,
	duRootWorkflows *durootwf.Workflows,
	pingRegistryWorkflows *pingregistrywf.Workflows,
	splitRootWorkflows *splitrootwf.Workflows,
	freezeRepoWorkflows *freezerepowf.Workflows,
	unfreezeRepoWorkflows *unfreezerepowf.Workflows,
	archiveRepoWorkflows *archiverepowf.Workflows,
	unarchiveRepoWorkflows *unarchiverepowf.Workflows,
) *Server

func (*Server) AbortArchiveRepo 

func (srv *Server) AbortArchiveRepo(
	ctx context.Context, i *pb.AbortArchiveRepoI,
) (*pb.AbortArchiveRepoO, error)

func (*Server) AbortArchiveRepoFiles 

func (srv *Server) AbortArchiveRepoFiles(
	ctx context.Context, i *pb.AbortArchiveRepoFilesI,
) (*pb.AbortArchiveRepoFilesO, error)

func (*Server) AbortFreezeRepo 

func (srv *Server) AbortFreezeRepo(
	ctx context.Context, i *pb.AbortFreezeRepoI,
) (*pb.AbortFreezeRepoO, error)

func (*Server) AbortFreezeRepoFiles 

func (srv *Server) AbortFreezeRepoFiles(
	ctx context.Context, i *pb.AbortFreezeRepoFilesI,
) (*pb.AbortFreezeRepoFilesO, error)

func (*Server) AbortSplitRoot 

func (srv *Server) AbortSplitRoot(
	ctx context.Context, i *pb.AbortSplitRootI,
) (*pb.AbortSplitRootO, error)

func (*Server) AbortSplitRootAnalysis 

func (srv *Server) AbortSplitRootAnalysis(
	ctx context.Context, i *pb.AbortSplitRootAnalysisI,
) (*pb.AbortSplitRootAnalysisO, error)

func (*Server) AbortSplitRootDu 

func (srv *Server) AbortSplitRootDu(
	ctx context.Context, i *pb.AbortSplitRootDuI,
) (*pb.AbortSplitRootDuO, error)

func (*Server) AbortUnarchiveRepo 

func (srv *Server) AbortUnarchiveRepo(
	ctx context.Context, i *pb.AbortUnarchiveRepoI,
) (*pb.AbortUnarchiveRepoO, error)

func (*Server) AbortUnarchiveRepoFiles 

func (srv *Server) AbortUnarchiveRepoFiles(
	ctx context.Context, i *pb.AbortUnarchiveRepoFilesI,
) (*pb.AbortUnarchiveRepoFilesO, error)

func (*Server) AbortUnarchiveRepoTartt 

func (srv *Server) AbortUnarchiveRepoTartt(
	ctx context.Context, i *pb.AbortUnarchiveRepoTarttI,
) (*pb.AbortUnarchiveRepoTarttO, error)

func (*Server) AbortUnfreezeRepo 

func (srv *Server) AbortUnfreezeRepo(
	ctx context.Context, i *pb.AbortUnfreezeRepoI,
) (*pb.AbortUnfreezeRepoO, error)

func (*Server) AbortUnfreezeRepoFiles 

func (srv *Server) AbortUnfreezeRepoFiles(
	ctx context.Context, i *pb.AbortUnfreezeRepoFilesI,
) (*pb.AbortUnfreezeRepoFilesO, error)

func (*Server) AppendDuRoot 

func (srv *Server) AppendDuRoot(
	ctx context.Context, i *pb.AppendDuRootI,
) (*pb.AppendDuRootO, error)

func (*Server) AppendSplitRootDecisions 

func (srv *Server) AppendSplitRootDecisions(
	ctx context.Context, i *pb.AppendSplitRootDecisionsI,
) (*pb.AppendSplitRootDecisionsO, error)

func (*Server) AppendSplitRootDu 

func (srv *Server) AppendSplitRootDu(
	ctx context.Context, i *pb.AppendSplitRootDuI,
) (*pb.AppendSplitRootDuO, error)

func (*Server) AppendSplitRootSuggestions 

func (srv *Server) AppendSplitRootSuggestions(
	ctx context.Context, i *pb.AppendSplitRootSuggestionsI,
) (*pb.AppendSplitRootSuggestionsO, error)

func (*Server) BeginArchiveRepo 

func (srv *Server) BeginArchiveRepo(
	ctx context.Context, i *pb.BeginArchiveRepoI,
) (*pb.BeginArchiveRepoO, error)

func (*Server) BeginArchiveRepoFiles 

func (srv *Server) BeginArchiveRepoFiles(
	ctx context.Context, i *pb.BeginArchiveRepoFilesI,
) (*pb.BeginArchiveRepoFilesO, error)

func (*Server) BeginArchiveRepoSwap 

func (srv *Server) BeginArchiveRepoSwap(
	ctx context.Context, i *pb.BeginArchiveRepoSwapI,
) (*pb.BeginArchiveRepoSwapO, error)

func (*Server) BeginDuRoot 

func (srv *Server) BeginDuRoot(
	ctx context.Context, i *pb.BeginDuRootI,
) (*pb.BeginDuRootO, error)

func (*Server) BeginFreezeRepo 

func (srv *Server) BeginFreezeRepo(
	ctx context.Context, i *pb.BeginFreezeRepoI,
) (*pb.BeginFreezeRepoO, error)

func (*Server) BeginFreezeRepoFiles 

func (srv *Server) BeginFreezeRepoFiles(
	ctx context.Context, i *pb.BeginFreezeRepoFilesI,
) (*pb.BeginFreezeRepoFilesO, error)

func (*Server) BeginMoveRepo 

func (srv *Server) BeginMoveRepo(
	ctx context.Context, i *pb.BeginMoveRepoI,
) (*pb.BeginMoveRepoO, error)

func (*Server) BeginPingRegistry 

func (srv *Server) BeginPingRegistry(
	ctx context.Context, i *pb.BeginPingRegistryI,
) (*pb.BeginPingRegistryO, error)

func (*Server) BeginSplitRoot 

func (srv *Server) BeginSplitRoot(
	ctx context.Context, i *pb.BeginSplitRootI,
) (*pb.BeginSplitRootO, error)

func (*Server) BeginUnarchiveRepo 

func (srv *Server) BeginUnarchiveRepo(
	ctx context.Context, i *pb.BeginUnarchiveRepoI,
) (*pb.BeginUnarchiveRepoO, error)

func (*Server) BeginUnarchiveRepoFiles 

func (srv *Server) BeginUnarchiveRepoFiles(
	ctx context.Context, i *pb.BeginUnarchiveRepoFilesI,
) (*pb.BeginUnarchiveRepoFilesO, error)

func (*Server) BeginUnarchiveRepoTartt 

func (srv *Server) BeginUnarchiveRepoTartt(
	ctx context.Context, i *pb.BeginUnarchiveRepoTarttI,
) (*pb.BeginUnarchiveRepoTarttO, error)

func (*Server) BeginUnfreezeRepo 

func (srv *Server) BeginUnfreezeRepo(
	ctx context.Context, i *pb.BeginUnfreezeRepoI,
) (*pb.BeginUnfreezeRepoO, error)

func (*Server) BeginUnfreezeRepoFiles 

func (srv *Server) BeginUnfreezeRepoFiles(
	ctx context.Context, i *pb.BeginUnfreezeRepoFilesI,
) (*pb.BeginUnfreezeRepoFilesO, error)

func (*Server) CommitArchiveRepo 

func (srv *Server) CommitArchiveRepo(
	ctx context.Context, i *pb.CommitArchiveRepoI,
) (*pb.CommitArchiveRepoO, error)

func (*Server) CommitArchiveRepoFiles 

func (srv *Server) CommitArchiveRepoFiles(
	ctx context.Context, i *pb.CommitArchiveRepoFilesI,
) (*pb.CommitArchiveRepoFilesO, error)

func (*Server) CommitArchiveRepoGc 

func (srv *Server) CommitArchiveRepoGc(
	ctx context.Context, i *pb.CommitArchiveRepoGcI,
) (*pb.CommitArchiveRepoGcO, error)

func (*Server) CommitArchiveRepoTartt 

func (srv *Server) CommitArchiveRepoTartt(
	ctx context.Context, i *pb.CommitArchiveRepoTarttI,
) (*pb.CommitArchiveRepoTarttO, error)

func (*Server) CommitDuRoot 

func (srv *Server) CommitDuRoot(
	ctx context.Context, i *pb.CommitDuRootI,
) (*pb.CommitDuRootO, error)

func (*Server) CommitFreezeRepo 

func (srv *Server) CommitFreezeRepo(
	ctx context.Context, i *pb.CommitFreezeRepoI,
) (*pb.CommitFreezeRepoO, error)

func (*Server) CommitFreezeRepoFiles 

func (srv *Server) CommitFreezeRepoFiles(
	ctx context.Context, i *pb.CommitFreezeRepoFilesI,
) (*pb.CommitFreezeRepoFilesO, error)

func (*Server) CommitPingRegistry 

func (srv *Server) CommitPingRegistry(
	ctx context.Context, i *pb.CommitPingRegistryI,
) (*pb.CommitPingRegistryO, error)

func (*Server) CommitSplitRoot 

func (srv *Server) CommitSplitRoot(
	ctx context.Context, i *pb.CommitSplitRootI,
) (*pb.CommitSplitRootO, error)

func (*Server) CommitSplitRootAnalysis 

func (srv *Server) CommitSplitRootAnalysis(
	ctx context.Context, i *pb.CommitSplitRootAnalysisI,
) (*pb.CommitSplitRootAnalysisO, error)

func (*Server) CommitSplitRootDu 

func (srv *Server) CommitSplitRootDu(
	ctx context.Context, i *pb.CommitSplitRootDuI,
) (*pb.CommitSplitRootDuO, error)

func (*Server) CommitUnarchiveRepo 

func (srv *Server) CommitUnarchiveRepo(
	ctx context.Context, i *pb.CommitUnarchiveRepoI,
) (*pb.CommitUnarchiveRepoO, error)

func (*Server) CommitUnarchiveRepoFiles 

func (srv *Server) CommitUnarchiveRepoFiles(
	ctx context.Context, i *pb.CommitUnarchiveRepoFilesI,
) (*pb.CommitUnarchiveRepoFilesO, error)

func (*Server) CommitUnarchiveRepoGc 

func (srv *Server) CommitUnarchiveRepoGc(
	ctx context.Context, i *pb.CommitUnarchiveRepoGcI,
) (*pb.CommitUnarchiveRepoGcO, error)

func (*Server) CommitUnarchiveRepoTartt 

func (srv *Server) CommitUnarchiveRepoTartt(
	ctx context.Context, i *pb.CommitUnarchiveRepoTarttI,
) (*pb.CommitUnarchiveRepoTarttO, error)

func (*Server) CommitUnfreezeRepo 

func (srv *Server) CommitUnfreezeRepo(
	ctx context.Context, i *pb.CommitUnfreezeRepoI,
) (*pb.CommitUnfreezeRepoO, error)

func (*Server) CommitUnfreezeRepoFiles 

func (srv *Server) CommitUnfreezeRepoFiles(
	ctx context.Context, i *pb.CommitUnfreezeRepoFilesI,
) (*pb.CommitUnfreezeRepoFilesO, error)

func (*Server) CreateSplitRootConfig 

func (srv *Server) CreateSplitRootConfig(
	ctx context.Context, i *pb.CreateSplitRootConfigI,
) (*pb.CreateSplitRootConfigO, error)

func (*Server) CreateSplitRootPathFlag 

func (srv *Server) CreateSplitRootPathFlag(
	ctx context.Context, i *pb.CreateSplitRootPathFlagI,
) (*pb.CreateSplitRootPathFlagO, error)

func (*Server) DeleteRootArchiveRecipients 

func (srv *Server) DeleteRootArchiveRecipients(
	ctx context.Context, i *pb.DeleteRootArchiveRecipientsI,
) (*pb.DeleteRootArchiveRecipientsO, error)

func (*Server) DeleteRootShadowBackupRecipients 

func (srv *Server) DeleteRootShadowBackupRecipients(
	ctx context.Context, i *pb.DeleteRootShadowBackupRecipientsI,
) (*pb.DeleteRootShadowBackupRecipientsO, error)

func (*Server) DeleteSplitRootConfig 

func (srv *Server) DeleteSplitRootConfig(
	ctx context.Context, i *pb.DeleteSplitRootConfigI,
) (*pb.DeleteSplitRootConfigO, error)

func (*Server) DeleteSplitRootPathFlag 

func (srv *Server) DeleteSplitRootPathFlag(
	ctx context.Context, i *pb.DeleteSplitRootPathFlagI,
) (*pb.DeleteSplitRootPathFlagO, error)

func (*Server) DisableGitlabRoot 

func (srv *Server) DisableGitlabRoot(
	ctx context.Context, i *pb.DisableGitlabRootI,
) (*pb.DisableGitlabRootO, error)

func (*Server) EnableDiscoveryPaths 

func (srv *Server) EnableDiscoveryPaths(
	ctx context.Context, i *pb.EnableDiscoveryPathsI,
) (*pb.EnableDiscoveryPathsO, error)

func (*Server) EnableEphemeralWorkflows 

func (srv *Server) EnableEphemeralWorkflows(
	ctx context.Context, i *pb.EnableEphemeralWorkflowsI,
) (*pb.EnableEphemeralWorkflowsO, error)

func (*Server) EnableGitlabRepo 

func (srv *Server) EnableGitlabRepo(
	ctx context.Context, i *pb.EnableGitlabRepoI,
) (*pb.EnableGitlabRepoO, error)

func (*Server) EnableGitlabRoot 

func (srv *Server) EnableGitlabRoot(
	ctx context.Context, i *pb.EnableGitlabRootI,
) (*pb.EnableGitlabRootO, error)

func (*Server) EnablePropagateRootAcls 

func (srv *Server) EnablePropagateRootAcls(
	ctx context.Context, i *pb.EnablePropagateRootAclsI,
) (*pb.EnablePropagateRootAclsO, error)

func (*Server) EndArchiveRepoFiles 

func (srv *Server) EndArchiveRepoFiles(
	ctx context.Context, i *pb.EndArchiveRepoFilesI,
) (*pb.EndArchiveRepoFilesO, error)

func (*Server) EndUnarchiveRepoFiles 

func (srv *Server) EndUnarchiveRepoFiles(
	ctx context.Context, i *pb.EndUnarchiveRepoFilesI,
) (*pb.EndUnarchiveRepoFilesO, error)

func (*Server) Events 

func (srv *Server) Events(
	req *pb.RegistryEventsI, stream pb.Registry_EventsServer,
) error

func (*Server) GetArchiveRepo 

func (srv *Server) GetArchiveRepo(
	ctx context.Context, i *pb.GetArchiveRepoI,
) (*pb.GetArchiveRepoO, error)

func (*Server) GetDuRoot 

func (srv *Server) GetDuRoot(
	i *pb.GetDuRootI, stream pb.DiskUsage_GetDuRootServer,
) error

func (*Server) GetFreezeRepo 

func (srv *Server) GetFreezeRepo(
	ctx context.Context, i *pb.GetFreezeRepoI,
) (*pb.GetFreezeRepoO, error)

func (*Server) GetRegistryPings 

func (srv *Server) GetRegistryPings(
	ctx context.Context, i *pb.GetRegistryPingsI,
) (*pb.GetRegistryPingsO, error)

func (*Server) GetRepoAclPolicy 

func (srv *Server) GetRepoAclPolicy(
	ctx context.Context, i *pb.GetRepoAclPolicyI,
) (*pb.GetRepoAclPolicyO, error)

func (*Server) GetRepos 

func (srv *Server) GetRepos(
	ctx context.Context, req *pb.GetReposI,
) (*pb.GetReposO, error)

func (*Server) GetRoot 

func (srv *Server) GetRoot(
	ctx context.Context, i *pb.GetRootI,
) (*pb.GetRootO, error)

func (*Server) GetRoots 

func (srv *Server) GetRoots(
	ctx context.Context, req *pb.GetRootsI,
) (*pb.GetRootsO, error)

func (*Server) GetSplitRoot 

func (srv *Server) GetSplitRoot(
	ctx context.Context, i *pb.GetSplitRootI,
) (*pb.GetSplitRootO, error)

func (*Server) GetSplitRootConfig 

func (srv *Server) GetSplitRootConfig(
	ctx context.Context, i *pb.GetSplitRootConfigI,
) (*pb.GetSplitRootConfigO, error)

func (*Server) GetUnarchiveRepo 

func (srv *Server) GetUnarchiveRepo(
	ctx context.Context, i *pb.GetUnarchiveRepoI,
) (*pb.GetUnarchiveRepoO, error)

func (*Server) GetUnfreezeRepo 

func (srv *Server) GetUnfreezeRepo(
	ctx context.Context, i *pb.GetUnfreezeRepoI,
) (*pb.GetUnfreezeRepoO, error)

func (*Server) Info 

func (srv *Server) Info(
	ctx context.Context, req *pb.InfoI,
) (*pb.InfoO, error)

func (*Server) InitRegistry 

func (srv *Server) InitRegistry(
	ctx context.Context, i *pb.InitRegistryI,
) (*pb.InitRegistryO, error)

func (*Server) InitRepo 

func (srv *Server) InitRepo(
	ctx context.Context, i *pb.InitRepoI,
) (*pb.InitRepoO, error)

func (*Server) InitRoot 

func (srv *Server) InitRoot(
	ctx context.Context, i *pb.InitRootI,
) (*pb.InitRootO, error)

func (*Server) ListSplitRootPathFlags 

func (srv *Server) ListSplitRootPathFlags(
	ctx context.Context, i *pb.ListSplitRootPathFlagsI,
) (*pb.ListSplitRootPathFlagsO, error)

func (*Server) PatchRepoNaming 

func (srv *Server) PatchRepoNaming(
	ctx context.Context, i *pb.PatchRepoNamingI,
) (*pb.PatchRepoNamingO, error)

func (*Server) PostServerPingSummary 

func (srv *Server) PostServerPingSummary(
	ctx context.Context, i *pb.PostServerPingSummaryI,
) (*pb.PostServerPingSummaryO, error)

func (*Server) RegistryAbortArchiveRepo 

func (srv *Server) RegistryAbortArchiveRepo(
	ctx context.Context, i *pb.RegistryAbortArchiveRepoI,
) (*pb.RegistryAbortArchiveRepoO, error)

func (*Server) RegistryAbortFreezeRepo 

func (srv *Server) RegistryAbortFreezeRepo(
	ctx context.Context, i *pb.RegistryAbortFreezeRepoI,
) (*pb.RegistryAbortFreezeRepoO, error)

func (*Server) RegistryAbortUnarchiveRepo 

func (srv *Server) RegistryAbortUnarchiveRepo(
	ctx context.Context, i *pb.RegistryAbortUnarchiveRepoI,
) (*pb.RegistryAbortUnarchiveRepoO, error)

func (*Server) RegistryAbortUnfreezeRepo 

func (srv *Server) RegistryAbortUnfreezeRepo(
	ctx context.Context, i *pb.RegistryAbortUnfreezeRepoI,
) (*pb.RegistryAbortUnfreezeRepoO, error)

func (*Server) RegistryBeginArchiveRepo 

func (srv *Server) RegistryBeginArchiveRepo(
	ctx context.Context, i *pb.RegistryBeginArchiveRepoI,
) (*pb.RegistryBeginArchiveRepoO, error)

func (*Server) RegistryBeginFreezeRepo 

func (srv *Server) RegistryBeginFreezeRepo(
	ctx context.Context, i *pb.RegistryBeginFreezeRepoI,
) (*pb.RegistryBeginFreezeRepoO, error)

func (*Server) RegistryBeginUnarchiveRepo 

func (srv *Server) RegistryBeginUnarchiveRepo(
	ctx context.Context, i *pb.RegistryBeginUnarchiveRepoI,
) (*pb.RegistryBeginUnarchiveRepoO, error)

func (*Server) RegistryBeginUnfreezeRepo 

func (srv *Server) RegistryBeginUnfreezeRepo(
	ctx context.Context, i *pb.RegistryBeginUnfreezeRepoI,
) (*pb.RegistryBeginUnfreezeRepoO, error)

func (*Server) RegistryCommitArchiveRepo 

func (srv *Server) RegistryCommitArchiveRepo(
	ctx context.Context, i *pb.RegistryCommitArchiveRepoI,
) (*pb.RegistryCommitArchiveRepoO, error)

func (*Server) RegistryCommitFreezeRepo 

func (srv *Server) RegistryCommitFreezeRepo(
	ctx context.Context, i *pb.RegistryCommitFreezeRepoI,
) (*pb.RegistryCommitFreezeRepoO, error)

func (*Server) RegistryCommitUnarchiveRepo 

func (srv *Server) RegistryCommitUnarchiveRepo(
	ctx context.Context, i *pb.RegistryCommitUnarchiveRepoI,
) (*pb.RegistryCommitUnarchiveRepoO, error)

func (*Server) RegistryCommitUnfreezeRepo 

func (srv *Server) RegistryCommitUnfreezeRepo(
	ctx context.Context, i *pb.RegistryCommitUnfreezeRepoI,
) (*pb.RegistryCommitUnfreezeRepoO, error)

func (*Server) RegistryWorkflowEvents 

func (srv *Server) RegistryWorkflowEvents(
	req *pb.RegistryWorkflowEventsI,
	stream pb.EphemeralRegistry_RegistryWorkflowEventsServer,
) error

func (*Server) RegistryWorkflowIndexEvents 

func (srv *Server) RegistryWorkflowIndexEvents(
	req *pb.RegistryWorkflowIndexEventsI,
	stream pb.EphemeralRegistry_RegistryWorkflowIndexEventsServer,
) error

func (*Server) ReinitRepo 

func (srv *Server) ReinitRepo(
	ctx context.Context, i *pb.ReinitRepoI,
) (*pb.ReinitRepoO, error)

func (*Server) RemoveRoot 

func (srv *Server) RemoveRoot(
	ctx context.Context, i *pb.RemoveRootI,
) (*pb.RemoveRootO, error)

func (*Server) ServerPing 

func (srv *Server) ServerPing(
	ctx context.Context, i *pb.ServerPingI,
) (*pb.ServerPingO, error)

func (*Server) UpdateRepoInitPolicy 

func (srv *Server) UpdateRepoInitPolicy(
	ctx context.Context, i *pb.UpdateRepoInitPolicyI,
) (*pb.UpdateRepoInitPolicyO, error)

func (*Server) UpdateRepoNaming 

func (srv *Server) UpdateRepoNaming(
	ctx context.Context, i *pb.UpdateRepoNamingI,
) (*pb.UpdateRepoNamingO, error)

func (*Server) UpdateRootArchiveRecipients 

func (srv *Server) UpdateRootArchiveRecipients(
	ctx context.Context, i *pb.UpdateRootArchiveRecipientsI,
) (*pb.UpdateRootArchiveRecipientsO, error)

func (*Server) UpdateRootShadowBackupRecipients 

func (srv *Server) UpdateRootShadowBackupRecipients(
	ctx context.Context, i *pb.UpdateRootShadowBackupRecipientsI,
) (*pb.UpdateRootShadowBackupRecipientsO, error)

func (*Server) UpdateSplitRootConfig 

func (srv *Server) UpdateSplitRootConfig(
	ctx context.Context, i *pb.UpdateSplitRootConfigI,
) (*pb.UpdateSplitRootConfigO, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.