workflowproc

Documentation

Index

• Constants
• Variables
• func Scan0s(data []byte, atEOF bool) (advance int, token []byte, err error)
• type AclPropagator
• type ArchiveRepoPrivileges
• type Config
• type Logger
• type Privileges
• type Processor
  • func New(lg Logger, cfg *Config) *Processor
  • func (p *Processor) Run(ctx context.Context) error
• type RepoProcessor
• type UnarchiveRepoPrivileges

Constants

const ConfigArchiveRepoGCDelay = ConfigArchiveRepoGCDelayDays * 24 * time.Hour

const ConfigArchiveRepoGCDelayDays = 7

const ConfigErrorMessageTruncateLength = 120

`ConfigErrorMessageTruncateLength` limits the length of error messages when storing them on a repo. Longer messages are truncated. The limit must be smaller than the maximum length that nogfsoregd accepts.

const ConfigMaxArchiveRepoRetries = 5

const ConfigMaxFreezeRepoRetries = 5

const ConfigMaxStreams = 20

const ConfigMaxUnarchiveRepoRetries = 5

const ConfigMaxUnfreezeRepoRetries = 5

const ConfigUnarchiveRepoGCDelay = ConfigUnarchiveRepoGCDelayDays * 24 * time.Hour

const ConfigUnarchiveRepoGCDelayDays = 7

Variables

var ErrAclsDisabled = errors.New("ACLs disabled")

var ErrUnknownEvent = errors.New("unknown event")

Functions

func Scan0s

func Scan0s(data []byte, atEOF bool) (advance int, token []byte, err error)

Types

type AclPropagator

type AclPropagator interface {
	PropagateAcls(ctx context.Context, src, dst string) error
}

type ArchiveRepoPrivileges

type ArchiveRepoPrivileges interface {
	privileges.UdoChattrPrivileges
}

type Config

type Config struct {
	Registries         []string
	Prefixes           []string
	Conn               *grpc.ClientConn
	SysRPCCreds        credentials.PerRPCCredentials
	RepoProcessor      RepoProcessor
	Privileges         Privileges
	AclPropagator      AclPropagator
	ArchiveRepoSpool   string
	UnarchiveRepoSpool string
}

type Logger

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

type Privileges

type Privileges interface {
	privileges.UdoChattrPrivileges
}

type Processor

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

func New

func New(lg Logger, cfg *Config) *Processor

func (*Processor) Run

func (p *Processor) Run(ctx context.Context) error

type RepoProcessor

type RepoProcessor interface {
	WaitEnableRepo4(ctx context.Context, id uuid.I) error
	FreezeRepo(
		ctx context.Context, repoId uuid.I, author nogfsostad.GitUser,
	) error
	UnfreezeRepo(
		ctx context.Context, repoId uuid.I, author nogfsostad.GitUser,
	) error
	TarttIsFrozenArchive(
		ctx context.Context, repoId uuid.I,
	) (*shadows.TarttIsFrozenArchiveInfo, error)
	ArchiveRepo(
		ctx context.Context,
		repoId uuid.I,
		workfingDir string,
		author nogfsostad.GitUser,
	) error
	UnarchiveRepo(
		ctx context.Context,
		repoId uuid.I,
		workfingDir string,
		author nogfsostad.GitUser,
	) error
}

type UnarchiveRepoPrivileges

type UnarchiveRepoPrivileges interface {
	privileges.UdoChattrPrivileges
}