serversets

type Endpoint struct {
	*ServerSet
	PingRate   time.Duration // default/initial is 1 second
	CloseEvent chan struct{}
	// contains filtered or unexported fields
}

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

type FinagleRecord struct {
	ServiceEndpoint     endpoint            `json:"serviceEndpoint"`
	AdditionalEndpoints map[string]endpoint `json:"additionalEndpoints"`
	Shard               int64               `json:"shard"`
	Status              string              `json:"status"`
}

type ServerSet struct {
	ZKTimeout time.Duration
	ZKFmt     ZKFmt
	// contains filtered or unexported fields
}

type Watch struct {
	LastEvent  time.Time
	EventCount int
	// contains filtered or unexported fields
}

type ZKFmt interface {
	// Path returns the zokeeper full path to service members.
	Path() string
	// Prefix returns the znode name prefix for service members.
	Prefix() string
	// CreateRecord creates a new endpoint record from host and port.
	Create(host string, port int) ZKRecord
	// Unmarshal decodes encoded endpoint data a ZKrecord.
	Unmarshal([]byte) (ZKRecord, error)
}

type ZKRecord interface {
	// Marshal encodes data to be stored in zookeeper.
	Marshal() ([]byte, error)
	// Endpoint returns the endpoint as host:port string
	Endpoint() string
	// IsAlive returns true if znode has liveness information stored.
	IsAlive() bool
}