mirror

package

Go to main page

Versions in this module

v0

v0.8.5

Apr 22, 2024

v0.8.4

Mar 28, 2024

v0.8.3

Mar 13, 2024

Changes in this version

type Source

+ func GetSource(_ context.Context, cfg *datastore.MirrorConfig) (Source, error)

v0.8.2

Feb 21, 2024

v0.8.1

Jan 19, 2024

Changes in this version

type Config

+ Namespace string

type DirektivApplyer

+ NamespaceID uuid.UUID

type Parser

+ Consumers map[string][]byte

+ Endpoints map[string][]byte

type Process

+ Namespace string

type Store

+ GetProcessesByNamespace func(ctx context.Context, namespace string) ([]*Process, error)

v0.8.0

Sep 29, 2023

Changes in this version

+ const ProcessStatusComplete

+ const ProcessStatusExecuting

+ const ProcessStatusFailed

+ const ProcessStatusPending

+ const ProcessTypeDryRun

+ const ProcessTypeInit

+ const ProcessTypeSync

+ var ErrNotFound = errors.New("ErrNotFound")

+ type Applyer interface

+ type Callbacks interface

+ ConfigureWorkflowFunc func(ctx context.Context, nsID uuid.UUID, file *filestore.File) error

+ EventFilterStore func() events.CloudEventsFilterStore

+ FileAnnotationsStore func() core.FileAnnotationsStore

+ FileStore func() filestore.FileStore

+ ProcessLogger func() ProcessLogger

+ SetNamespaceServices func(nsID uuid.UUID, services []*api.Service) error

+ Store func() Store

+ SysLogCrit func(msg string)

+ VarStore func() core.RuntimeVariablesStore

+ type Config struct

+ CreatedAt time.Time

+ GitCommitHash string

+ GitRef string

+ Insecure bool

+ NamespaceID uuid.UUID

+ PrivateKey string

+ PrivateKeyPassphrase string

+ PublicKey string

+ RootName string

+ URL string

+ UpdatedAt time.Time

+ func (cfg *Config) GetSource(_ context.Context) (Source, error)

+ type DirectorySource struct

+ func NewDirectorySource(dir string) *DirectorySource

+ func (src *DirectorySource) FS() fs.FS

+ func (src *DirectorySource) Free() error

+ func (src *DirectorySource) Notes() map[string]string

+ type DirektivApplyer struct

+ type DryrunApplyer struct

+ type FormatLogger interface

+ Debugf func(msg string, a ...interface{})

+ Errorf func(msg string, a ...interface{})

+ Infof func(msg string, a ...interface{})

+ Warnf func(msg string, a ...interface{})

+ type GitSourceConfig struct

+ GitRef string

+ InsecureSkipTLS bool

+ TempDir string

+ URL string

+ type GitSourceSSHAuthConf struct

+ PrivateKey string

+ PrivateKeyPassphrase string

+ PublicKey string

+ type GitSourceTokenAuthConf struct

+ Token string

+ type Manager struct

+ func NewManager(callbacks Callbacks) *Manager

+ func (d *Manager) Cancel(_ context.Context, id uuid.UUID) error

+ func (d *Manager) Execute(ctx context.Context, p *Process, get func(ctx context.Context) (Source, error), ...)

+ func (d *Manager) NewProcess(ctx context.Context, nsID, rootID uuid.UUID, processType string) (*Process, error)

+ type Parser struct

+ DeprecatedNamespaceVars map[string][]byte

+ DeprecatedWorkflowVars map[string]map[string][]byte

+ Filters map[string][]byte

+ Services map[string]*api.Service

+ Workflows map[string][]byte

+ func NewParser(log FormatLogger, src Source) (*Parser, error)

+ func (p *Parser) Close() error

+ func (p *Parser) ListFiles() ([]string, error)

+ type Process struct

+ CreatedAt time.Time

+ EndedAt time.Time

+ ID uuid.UUID

+ NamespaceID uuid.UUID

+ RootID uuid.UUID

+ Status string

+ Typ string

+ UpdatedAt time.Time

+ type ProcessLogger interface

+ Debug func(pid uuid.UUID, msg string, keysAndValues ...interface{})

+ Error func(pid uuid.UUID, msg string, keysAndValues ...interface{})

+ Info func(pid uuid.UUID, msg string, keysAndValues ...interface{})

+ Warn func(pid uuid.UUID, msg string, keysAndValues ...interface{})

+ type Source interface

+ FS func() fs.FS

+ Free func() error

+ Notes func() map[string]string

+ func NewGitSourceNoAuth(conf GitSourceConfig) (Source, error)

+ func NewGitSourceSSH(conf GitSourceConfig, auth GitSourceSSHAuthConf) (Source, error)

+ type Store interface

+ CreateConfig func(ctx context.Context, config *Config) (*Config, error)

+ CreateProcess func(ctx context.Context, process *Process) (*Process, error)

+ DeleteOldProcesses func(ctx context.Context, before time.Time) error

+ GetConfig func(ctx context.Context, namespaceID uuid.UUID) (*Config, error)

+ GetProcess func(ctx context.Context, id uuid.UUID) (*Process, error)

+ GetProcessesByNamespaceID func(ctx context.Context, namespaceID uuid.UUID) ([]*Process, error)

+ GetUnfinishedProcesses func(ctx context.Context) ([]*Process, error)

+ UpdateConfig func(ctx context.Context, config *Config) (*Config, error)

+ UpdateProcess func(ctx context.Context, process *Process) (*Process, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL