health

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

type AgentLoc struct {
	ID             string `json:"serverId"`
	NatsHost       string `json:"natsHost"`
	NatsClientPort int    `json:"natsClientPort"`

	Grpc ExtInt `json:"grpc"`

	// LeaseExpires is zero for any
	// non-leader. For the leader,
	// LeaseExpires tells you when
	// the leaders lease expires.
	LeaseExpires time.Time `json:"leaseExpires"`

	// lower rank is leader until lease
	// expires. Ties are broken by ID.
	// Rank should be assignable on the
	// gnatsd command line with -rank to
	// let the operator prioritize
	// leadership for certain hosts.
	Rank int `json:"rank"`

	// Pid or process id is the only
	// way to tell apart two processes
	// sometimes, if they share the
	// same nats server.
	//
	// Pid is one difference between
	// a nats.ServerLoc and a health.AgentLoc.
	//
	Pid int `json:"pid"`
}

type ExtInt struct {
	External HostPort `json:"externalHostPort"`
	Internal HostPort `json:"internalHostPort"`
}

type HostPort struct {
	Host string `json:"host"`
	Port int    `json:"port"`
}

type Icc struct {
	*net.TCPConn
}

type Membership struct {
	Cfg MembershipCfg
	// contains filtered or unexported fields
}

type MembershipCfg struct {

	// max we allow for clocks to be out of sync.
	// default to 1 second if not set.
	MaxClockSkew time.Duration

	// how often we heartbeat. defaults to 100msec
	// if not set.
	BeatDur time.Duration

	// NatsURL example "nats://127.0.0.1:4222"
	NatsURL string

	// defaults to "_nats.cluster.members."
	SysMemberPrefix string

	// LeaseTime is the minimum time the
	// leader is elected for. Defaults to 10 sec.
	LeaseTime time.Duration

	// provide a default until the server gives us rank
	MyRank int

	// optional, if provided we will use this connection on
	// the client side.
	CliConn net.Conn

	// where we log stuff.
	Log server.Logger
	// contains filtered or unexported fields
}