agent

May 3, 2017

Changes in this version

+ const REJOIN_BACKOFF

+ const SSE_BLANK_LINE

+ const SSE_DATA_PREFIX

+ const SSE_EVENT_PREFIX

type Agent

+ HttpServer *HttpServer

+ Janitor *janitor.JanitorServer

+ Resolver *nameserver.Resolver

+ SerfServer *SerfServer

+ func (agent *Agent) StartAndJoin(ctx context.Context) error

+ type HttpServer struct

+ func NewHttpServer(listener string, a *Agent) *HttpServer

+ func (aas *HttpServer) Start(ctx context.Context, started chan bool) error

+ type SerfServer struct

+ EventCh chan serf.Event

+ SerfJoinAddr string

+ SerfListenAddr string

+ SerfNode *serf.Serf

+ func NewSerfServer(listenerAddr, joinAddr string) *SerfServer

+ func (ss *SerfServer) Publish(eventType string, payload []byte)

+ func (ss *SerfServer) Start(ctx context.Context, started chan bool) error

Mar 20, 2017

Changes in this version

type AgentApi

+ func (api *AgentApi) Init(request *restful.Request, response *restful.Response)

Mar 6, 2017

Changes in this version

+ const JoinRetryInterval

type Agent

+ Config config.AgentConfig

+ JoinAddrs []string

+ NodeInfo types.Node

+ func (agent *Agent) JoinAndStart(ctx context.Context) error

+ func (agent *Agent) JoinToCluster(ctx context.Context) error

Jan 17, 2017

Changes in this version

+ type Agent struct

+ CancelFunc context.CancelFunc

+ func New() (*Agent, error)

+ func (agent *Agent) RegisterToManager() error

+ func (agent *Agent) Start(ctx context.Context) error

+ func (agent *Agent) Stop(cancel context.CancelFunc)

+ type AgentApi struct

+ func (api *AgentApi) InitJanitor(request *restful.Request, response *restful.Response)

+ func (api *AgentApi) InitResolver(request *restful.Request, response *restful.Response)

+ func (api *AgentApi) JanitorEventHandler(request *restful.Request, response *restful.Response)

+ func (api *AgentApi) Register(container *restful.Container)

+ func (api *AgentApi) ResolverEventHandler(request *restful.Request, response *restful.Response)