reposd

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: 16 Imported by: 0

Documentation

Overview

Package `reposd`: GRPC service `nogfso.Repos` to access the FSO repos.

Index

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 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.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) GetRepo 

func (srv *Server) GetRepo(
	ctx context.Context, req *pb.GetRepoI,
) (*pb.GetRepoO, 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

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.