agent

Documentation

Index

• type Agent
  • func NewAgent(c *Config) (*Agent, error)
  • func NewAgentByConfig() (*Agent, error)
  • func (a *Agent) Process(ctx context.Context, e *services.Event) (*services.Event, error)
  • func (a *Agent) Start() error
  • func (a *Agent) Stop()
• type Config

Types

type Agent

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

Agent represents Agent service

func NewAgent

func NewAgent(c *Config) (*Agent, error)

NewAgent creates Agent with given configuration.

func NewAgentByConfig

func NewAgentByConfig() (*Agent, error)

NewAgentByConfig creates Agent reading configuration from viper config.

func (*Agent) Process

func (a *Agent) Process(ctx context.Context, e *services.Event) (*services.Event, error)

Process processes event by sending requests to all registered clusters.

func (*Agent) Start

func (a *Agent) Start() error

Start Agent service

func (*Agent) Stop

func (a *Agent) Stop()

Stop Agent routine

type Config

type Config struct {
	// ID of Agent account.
	ID string `yaml:"id"`
	// Password of Agent account.
	Password string `yaml:"password"`
	// DomainID is ID of keystone domain used for authentication.
	DomainID string `yaml:"domain_id"`
	// ProjectID is ID of keystone project used for authentication.
	ProjectID string `yaml:"project_id"`
	// DomainName is Name of keystone domain used for authentication.
	DomainName string `yaml:"domain_name"`
	// ProjectName is Name of keystone project used for authentication.
	ProjectName string `yaml:"project_name"`
	// AuthURL defines authentication URL.
	AuthURL string `yaml:"auth_url"`
	// Endpoint of API Server.
	Endpoint string `yaml:"endpoint"`
	// Server schema path
	SchemaRoot string `yaml:"schema_root"`
	// Logging level
	LogLevel string `yaml:"log_level"`
	// Backend specifies backend to be used (values: "file").
	Backend string `yaml:"backend"`
	// Watcher specifies resource event watching strategy to be used (values: "polling").
	Watcher string `yaml:"watcher"`
	// InSecure https connection to endpoint
	InSecure bool `yaml:"insecure"`
	// Enabled
	Enabled bool `yaml:"enabled"`
	// Service user name for keystone
	ServiceUserID string `yaml:"service_user_id"`
	// Service user password for keystone
	ServiceUserPassword string `yaml:"service_user_password"`
}

Config holds configuration for creating cluster manager or cloud manager