agent

Documentation

Index

• type Agent
  • func NewAgent(client *clientv3.Client, scs storage.ServerConfigStorage, ...) *Agent
  • func (a *Agent) Run(ctx context.Context)
• type Nginx
  • func NewNginx(e shell.Executor) Nginx
• type StatusServer
  • func NewStatusServer(readyCh <-chan interface{}) StatusServer

Types

type Agent

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

Agent watches etcd to trigger config updates

func NewAgent

func NewAgent(
	client *clientv3.Client,
	scs storage.ServerConfigStorage,
	mcs storage.MainConfigStorage,
	readyCh chan interface{},
) *Agent

NewAgent creates a new Agent instance

func (*Agent) Run

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

Run starts the agent

type Nginx

type Nginx interface {
	Run() error
	Stop() error
	Reload() error
	TestConfig() error
}

Nginx controls a nginx process

func NewNginx

func NewNginx(e shell.Executor) Nginx

NewNginx creates a new nginx instance

type StatusServer

type StatusServer interface {
	Run() error
}

StatusServer is used to query the agent status from the outside

func NewStatusServer

func NewStatusServer(readyCh <-chan interface{}) StatusServer

NewStatusServer creates a new StatusServer