agentk

Documentation

Index

• type Agent
  • func New(config Config) *Agent
  • func (a *Agent) Run(ctx context.Context) error
• type Config
• type DefaultGitOpsEngineFactory
  • func (f *DefaultGitOpsEngineFactory) New(engineOpts []engine.Option, cacheOpts []cache.UpdateSettingsFunc) engine.GitOpsEngine
• type GitOpsEngineFactory

Types

type Agent

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

func New

func New(config Config) *Agent

func (*Agent) Run

func (a *Agent) Run(ctx context.Context) error

type Config

type Config struct {
	Log                                *zap.Logger
	LogLevel                           zap.AtomicLevel
	KasClient                          agentrpc.KasClient
	EngineFactory                      GitOpsEngineFactory
	K8sClientGetter                    resource.RESTClientGetter
	RefreshConfigurationRetryPeriod    time.Duration
	GetObjectsToSynchronizeRetryPeriod time.Duration
}

type DefaultGitOpsEngineFactory

type DefaultGitOpsEngineFactory struct {
	KubeClientConfig *rest.Config
}

func (*DefaultGitOpsEngineFactory) New

func (f *DefaultGitOpsEngineFactory) New(engineOpts []engine.Option, cacheOpts []cache.UpdateSettingsFunc) engine.GitOpsEngine

type GitOpsEngineFactory

type GitOpsEngineFactory interface {
	New(engineOpts []engine.Option, cacheOpts []cache.UpdateSettingsFunc) engine.GitOpsEngine
}