Documentation ¶
Overview ¶
Package `reposd`: GRPC service `nogfso.Repos` to access the FSO repos.
Index ¶
- Constants
- Variables
- type Logger
- type Server
- func (srv *Server) BeginMoveShadow(ctx context.Context, i *pb.BeginMoveShadowI) (*pb.BeginMoveShadowO, error)
- func (srv *Server) ClearRepoError(ctx context.Context, i *pb.ClearRepoErrorI) (*pb.ClearRepoErrorO, error)
- func (srv *Server) CommitMoveRepo(ctx context.Context, i *pb.CommitMoveRepoI) (*pb.CommitMoveRepoO, error)
- func (srv *Server) CommitMoveShadow(ctx context.Context, i *pb.CommitMoveShadowI) (*pb.CommitMoveShadowO, error)
- func (srv *Server) ConfirmGit(ctx context.Context, i *pb.ConfirmGitI) (*pb.ConfirmGitO, error)
- func (srv *Server) ConfirmShadow(ctx context.Context, i *pb.ConfirmShadowI) (*pb.ConfirmShadowO, error)
- func (srv *Server) DeleteArchiveRecipients(ctx context.Context, i *pb.DeleteArchiveRecipientsI) (*pb.DeleteArchiveRecipientsO, error)
- func (srv *Server) DeleteShadowBackupRecipients(ctx context.Context, i *pb.DeleteShadowBackupRecipientsI) (*pb.DeleteShadowBackupRecipientsO, error)
- func (srv *Server) Events(req *pb.RepoEventsI, stream pb.Repos_EventsServer) error
- func (srv *Server) GetRepo(ctx context.Context, req *pb.GetRepoI) (*pb.GetRepoO, error)
- func (srv *Server) InitShadowBackup(ctx context.Context, i *pb.InitShadowBackupI) (*pb.InitShadowBackupO, error)
- func (srv *Server) InitTartt(ctx context.Context, i *pb.InitTarttI) (*pb.InitTarttO, error)
- func (srv *Server) MoveShadowBackup(ctx context.Context, i *pb.MoveShadowBackupI) (*pb.MoveShadowBackupO, error)
- func (srv *Server) PostMoveRepoAppAccepted(ctx context.Context, i *pb.PostMoveRepoAppAcceptedI) (*pb.PostMoveRepoAppAcceptedO, error)
- func (srv *Server) PostMoveRepoStaReleased(ctx context.Context, i *pb.PostMoveRepoStaReleasedI) (*pb.PostMoveRepoStaReleasedO, error)
- func (srv *Server) PostMoveShadowStaDisabled(ctx context.Context, i *pb.PostMoveShadowStaDisabledI) (*pb.PostMoveShadowStaDisabledO, error)
- func (srv *Server) ReposAbortArchiveRepo(ctx context.Context, i *pb.ReposAbortArchiveRepoI) (*pb.ReposAbortArchiveRepoO, error)
- func (srv *Server) ReposAbortFreezeRepo(ctx context.Context, i *pb.ReposAbortFreezeRepoI) (*pb.ReposAbortFreezeRepoO, error)
- func (srv *Server) ReposAbortUnarchiveRepo(ctx context.Context, i *pb.ReposAbortUnarchiveRepoI) (*pb.ReposAbortUnarchiveRepoO, error)
- func (srv *Server) ReposAbortUnfreezeRepo(ctx context.Context, i *pb.ReposAbortUnfreezeRepoI) (*pb.ReposAbortUnfreezeRepoO, error)
- func (srv *Server) ReposBeginArchiveRepo(ctx context.Context, i *pb.ReposBeginArchiveRepoI) (*pb.ReposBeginArchiveRepoO, error)
- func (srv *Server) ReposBeginFreezeRepo(ctx context.Context, i *pb.ReposBeginFreezeRepoI) (*pb.ReposBeginFreezeRepoO, error)
- func (srv *Server) ReposBeginUnarchiveRepo(ctx context.Context, i *pb.ReposBeginUnarchiveRepoI) (*pb.ReposBeginUnarchiveRepoO, error)
- func (srv *Server) ReposBeginUnfreezeRepo(ctx context.Context, i *pb.ReposBeginUnfreezeRepoI) (*pb.ReposBeginUnfreezeRepoO, error)
- func (srv *Server) ReposCommitArchiveRepo(ctx context.Context, i *pb.ReposCommitArchiveRepoI) (*pb.ReposCommitArchiveRepoO, error)
- func (srv *Server) ReposCommitFreezeRepo(ctx context.Context, i *pb.ReposCommitFreezeRepoI) (*pb.ReposCommitFreezeRepoO, error)
- func (srv *Server) ReposCommitUnarchiveRepo(ctx context.Context, i *pb.ReposCommitUnarchiveRepoI) (*pb.ReposCommitUnarchiveRepoO, error)
- func (srv *Server) ReposCommitUnfreezeRepo(ctx context.Context, i *pb.ReposCommitUnfreezeRepoI) (*pb.ReposCommitUnfreezeRepoO, error)
- func (srv *Server) SetRepoError(ctx context.Context, i *pb.SetRepoErrorI) (*pb.SetRepoErrorO, error)
- func (srv *Server) UpdateArchiveRecipients(ctx context.Context, i *pb.UpdateArchiveRecipientsI) (*pb.UpdateArchiveRecipientsO, error)
- func (srv *Server) UpdateShadowBackupRecipients(ctx context.Context, i *pb.UpdateShadowBackupRecipientsI) (*pb.UpdateShadowBackupRecipientsO, error)
- func (srv *Server) WorkflowEvents(req *pb.RepoWorkflowEventsI, stream pb.Repos_WorkflowEventsServer) error
Constants ¶
View Source
const AAFsoAdminRepo = fsoauthz.AAFsoAdminRepo
View Source
const AAFsoConfirmRepo = fsoauthz.AAFsoConfirmRepo
View Source
const AAFsoExecArchiveRepo = fsoauthz.AAFsoExecArchiveRepo
View Source
const AAFsoExecFreezeRepo = fsoauthz.AAFsoExecFreezeRepo
View Source
const AAFsoExecUnarchiveRepo = fsoauthz.AAFsoExecUnarchiveRepo
View Source
const AAFsoExecUnfreezeRepo = fsoauthz.AAFsoExecUnfreezeRepo
View Source
const AAFsoInitRepo = fsoauthz.AAFsoInitRepo
View Source
const AAFsoInitRepoShadowBackup = fsoauthz.AAFsoInitRepoShadowBackup
View Source
const AAFsoInitRepoTartt = fsoauthz.AAFsoInitRepoTartt
View Source
const AAFsoReadRepo = fsoauthz.AAFsoReadRepo
View Source
const LimitErrorMessageMaxLength = 200
Accept a larger limit than nogfsostad sends.
View Source
const (
NsFsoRepo = "fsorepo"
)
Variables ¶
View Source
var ErrOperationMismatch = status.Error( codes.FailedPrecondition, "operation mismatch", )
Functions ¶
This section is empty.
Types ¶
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.Authorizer, names *shorteruuid.Names, reposJ *events.Journal, repos *fsorepos.Repos, workflowsJ *events.Journal, moveRepoWorkflows *moverepowf.Workflows, moveShadowWorkflows *moveshadowwf.Workflows, ) *Server
func (*Server) BeginMoveShadow ¶
func (srv *Server) BeginMoveShadow( ctx context.Context, i *pb.BeginMoveShadowI, ) (*pb.BeginMoveShadowO, error)
func (*Server) ClearRepoError ¶
func (srv *Server) ClearRepoError( ctx context.Context, i *pb.ClearRepoErrorI, ) (*pb.ClearRepoErrorO, error)
func (*Server) CommitMoveRepo ¶
func (srv *Server) CommitMoveRepo( ctx context.Context, i *pb.CommitMoveRepoI, ) (*pb.CommitMoveRepoO, error)
func (*Server) CommitMoveShadow ¶
func (srv *Server) CommitMoveShadow( ctx context.Context, i *pb.CommitMoveShadowI, ) (*pb.CommitMoveShadowO, error)
func (*Server) ConfirmGit ¶
func (srv *Server) ConfirmGit( ctx context.Context, i *pb.ConfirmGitI, ) (*pb.ConfirmGitO, error)
func (*Server) ConfirmShadow ¶
func (srv *Server) ConfirmShadow( ctx context.Context, i *pb.ConfirmShadowI, ) (*pb.ConfirmShadowO, error)
func (*Server) DeleteArchiveRecipients ¶
func (srv *Server) DeleteArchiveRecipients( ctx context.Context, i *pb.DeleteArchiveRecipientsI, ) (*pb.DeleteArchiveRecipientsO, error)
func (*Server) DeleteShadowBackupRecipients ¶
func (srv *Server) DeleteShadowBackupRecipients( ctx context.Context, i *pb.DeleteShadowBackupRecipientsI, ) (*pb.DeleteShadowBackupRecipientsO, error)
func (*Server) Events ¶
func (srv *Server) Events( req *pb.RepoEventsI, stream pb.Repos_EventsServer, ) error
func (*Server) InitShadowBackup ¶
func (srv *Server) InitShadowBackup( ctx context.Context, i *pb.InitShadowBackupI, ) (*pb.InitShadowBackupO, error)
func (*Server) InitTartt ¶
func (srv *Server) InitTartt( ctx context.Context, i *pb.InitTarttI, ) (*pb.InitTarttO, error)
func (*Server) MoveShadowBackup ¶
func (srv *Server) MoveShadowBackup( ctx context.Context, i *pb.MoveShadowBackupI, ) (*pb.MoveShadowBackupO, error)
func (*Server) PostMoveRepoAppAccepted ¶
func (srv *Server) PostMoveRepoAppAccepted( ctx context.Context, i *pb.PostMoveRepoAppAcceptedI, ) (*pb.PostMoveRepoAppAcceptedO, error)
func (*Server) PostMoveRepoStaReleased ¶
func (srv *Server) PostMoveRepoStaReleased( ctx context.Context, i *pb.PostMoveRepoStaReleasedI, ) (*pb.PostMoveRepoStaReleasedO, error)
func (*Server) PostMoveShadowStaDisabled ¶
func (srv *Server) PostMoveShadowStaDisabled( ctx context.Context, i *pb.PostMoveShadowStaDisabledI, ) (*pb.PostMoveShadowStaDisabledO, error)
func (*Server) ReposAbortArchiveRepo ¶
func (srv *Server) ReposAbortArchiveRepo( ctx context.Context, i *pb.ReposAbortArchiveRepoI, ) (*pb.ReposAbortArchiveRepoO, error)
func (*Server) ReposAbortFreezeRepo ¶
func (srv *Server) ReposAbortFreezeRepo( ctx context.Context, i *pb.ReposAbortFreezeRepoI, ) (*pb.ReposAbortFreezeRepoO, error)
func (*Server) ReposAbortUnarchiveRepo ¶
func (srv *Server) ReposAbortUnarchiveRepo( ctx context.Context, i *pb.ReposAbortUnarchiveRepoI, ) (*pb.ReposAbortUnarchiveRepoO, error)
func (*Server) ReposAbortUnfreezeRepo ¶
func (srv *Server) ReposAbortUnfreezeRepo( ctx context.Context, i *pb.ReposAbortUnfreezeRepoI, ) (*pb.ReposAbortUnfreezeRepoO, error)
func (*Server) ReposBeginArchiveRepo ¶
func (srv *Server) ReposBeginArchiveRepo( ctx context.Context, i *pb.ReposBeginArchiveRepoI, ) (*pb.ReposBeginArchiveRepoO, error)
func (*Server) ReposBeginFreezeRepo ¶
func (srv *Server) ReposBeginFreezeRepo( ctx context.Context, i *pb.ReposBeginFreezeRepoI, ) (*pb.ReposBeginFreezeRepoO, error)
func (*Server) ReposBeginUnarchiveRepo ¶
func (srv *Server) ReposBeginUnarchiveRepo( ctx context.Context, i *pb.ReposBeginUnarchiveRepoI, ) (*pb.ReposBeginUnarchiveRepoO, error)
func (*Server) ReposBeginUnfreezeRepo ¶
func (srv *Server) ReposBeginUnfreezeRepo( ctx context.Context, i *pb.ReposBeginUnfreezeRepoI, ) (*pb.ReposBeginUnfreezeRepoO, error)
func (*Server) ReposCommitArchiveRepo ¶
func (srv *Server) ReposCommitArchiveRepo( ctx context.Context, i *pb.ReposCommitArchiveRepoI, ) (*pb.ReposCommitArchiveRepoO, error)
func (*Server) ReposCommitFreezeRepo ¶
func (srv *Server) ReposCommitFreezeRepo( ctx context.Context, i *pb.ReposCommitFreezeRepoI, ) (*pb.ReposCommitFreezeRepoO, error)
func (*Server) ReposCommitUnarchiveRepo ¶
func (srv *Server) ReposCommitUnarchiveRepo( ctx context.Context, i *pb.ReposCommitUnarchiveRepoI, ) (*pb.ReposCommitUnarchiveRepoO, error)
func (*Server) ReposCommitUnfreezeRepo ¶
func (srv *Server) ReposCommitUnfreezeRepo( ctx context.Context, i *pb.ReposCommitUnfreezeRepoI, ) (*pb.ReposCommitUnfreezeRepoO, error)
func (*Server) SetRepoError ¶
func (srv *Server) SetRepoError( ctx context.Context, i *pb.SetRepoErrorI, ) (*pb.SetRepoErrorO, error)
func (*Server) UpdateArchiveRecipients ¶
func (srv *Server) UpdateArchiveRecipients( ctx context.Context, i *pb.UpdateArchiveRecipientsI, ) (*pb.UpdateArchiveRecipientsO, error)
func (*Server) UpdateShadowBackupRecipients ¶
func (srv *Server) UpdateShadowBackupRecipients( ctx context.Context, i *pb.UpdateShadowBackupRecipientsI, ) (*pb.UpdateShadowBackupRecipientsO, error)
func (*Server) WorkflowEvents ¶
func (srv *Server) WorkflowEvents( req *pb.RepoWorkflowEventsI, stream pb.Repos_WorkflowEventsServer, ) error
Click to show internal directories.
Click to hide internal directories.