agent

Documentation

Index

• type AgentConfig
  • func CloneWithSerialization(orig *AgentConfig) (*AgentConfig, error)
• type AgentSyncer
  • func NewAgentSyncer(numaLogger *logger.NumaLogger) *AgentSyncer
  • func (syncer *AgentSyncer) Run(ctx context.Context)
• type ConfigManager
  • func GetConfigManagerInstance() *ConfigManager
  • func (cm *ConfigManager) GetConfig() (AgentConfig, int, error)
  • func (cm *ConfigManager) GetRevisionIndex() int
  • func (cm *ConfigManager) LoadConfig(onErrorReloading func(error), ...) error
• type KVGenerator
• type Source

Types

type AgentConfig

type AgentConfig struct {
	ClusterName     string `mapstructure:"clusterName"`
	TimeIntervalSec uint   `mapstructure:"timeIntervalSec"`
	Source          Source `mapstructure:"source"`
	LogLevel        int    `mapstructure:"logLevel"`
}

func CloneWithSerialization

func CloneWithSerialization(orig *AgentConfig) (*AgentConfig, error)

CloneWithSerialization uses encoding and decoding with json as a mechanism for performing a DeepCopy of the AgentConfig

type AgentSyncer

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

func NewAgentSyncer

func NewAgentSyncer(numaLogger *logger.NumaLogger) *AgentSyncer

func (*AgentSyncer) Run

func (syncer *AgentSyncer) Run(ctx context.Context)

Run function runs in a loop, syncing the manifest if it's changed, checking every x seconds It responds to all of the following events: 1. Config change; 2. Source Manifest change; 3. If file generator is used, then a change from that file

type ConfigManager

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

func GetConfigManagerInstance

func GetConfigManagerInstance() *ConfigManager

GetConfigManagerInstance returns a singleton config manager throughout the Agent application

func (*ConfigManager) GetConfig

func (cm *ConfigManager) GetConfig() (AgentConfig, int, error)

func (*ConfigManager) GetRevisionIndex

func (cm *ConfigManager) GetRevisionIndex() int

func (*ConfigManager) LoadConfig

func (cm *ConfigManager) LoadConfig(onErrorReloading func(error), configPath, configFileName, configFileType string) error

type KVGenerator

type KVGenerator struct {
	Embedded *apiv1.SingleClusterGenerator `mapstructure:"embedded,omitempty"`

	Reference *apiv1.MultiClusterFileGenerator `mapstructure:"reference,omitempty"`
}

type Source

type Source struct {
	// optional, apply to GitDefinition
	KeyValueGenerator *KVGenerator `mapstructure:"keyValueGenerator,omitempty"`

	GitDefinition apiv1.CredentialedGitSource `mapstructure:"gitDefinition"`
}