agent

Sep 28, 2017

Changes in this version

type Agent

+ IsMember func() bool

type Config

+ MetricsAddr string

Mar 3, 2016

Changes in this version

+ const MemberAlive

+ const MemberFailed

+ const MemberLeaving

+ const MemberLeft

+ const RPCPort

+ func NewClient(addr string) (*client, error)

+ type Agent interface

+ Close func() error

+ Join func(peers []string) error

+ LocalStatus func() *pb.NodeStatus

+ Start func() error

+ func New(config *Config) (Agent, error)

+ type Client interface

+ LocalStatus func(context.Context) (*pb.NodeStatus, error)

+ Status func(context.Context) (*pb.SystemStatus, error)

+ type Config struct

+ Cache cache.Cache

+ Name string

+ Peers []string

+ RPCAddrs []string

+ SerfRPCAddr string

+ Tags map[string]string

+ type MemberStatus string

+ type RPCServer interface

+ LocalStatus func(context.Context, *pb.LocalStatusRequest) (*pb.LocalStatusResponse, error)

+ Status func(context.Context, *pb.StatusRequest) (*pb.StatusResponse, error)

+ Stop func()

+ type Role string

+ const RoleMaster

+ const RoleNode