cluster

type Addresses struct {
	Lan string `json:"lan"`
	Wan string `json:"wan"`
}

type Check struct {
	Node        string `json:"Node"`
	CheckID     string `json:"CheckID"`
	Name        string `json:"Name"`
	Status      string `json:"Status"`
	Notes       string `json:"Notes"`
	Output      string `json:"Output"`
	ServiceID   string `json:"ServiceID"`
	ServiceName string `json:"ServiceName"`
	CreateIndex int    `json:"CreateIndex"`
	ModifyIndex int    `json:"ModifyIndex"`
}

type Client interface {
	Write(pts []*pb.Point) error
	Read(ksid, tsid string, start, end int64) ([]*pb.Point, gobol.Error)
	Meta(metas []*pb.Meta) error
	Address() string
	Port() int
}

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

type Conf struct {
	NodeID string `json:"NodeID"`
}

type Config struct {
	Consul ConsulConfig
	//gRPC port
	Port int
	//Ticker interval to check cluster changes
	CheckInterval string
	//Time, in seconds, to wait before applying cluster changes to consistency hashing
	ApplyWait int64

	GrpcWriteTimeout    string
	GrpcReadTimeout     string
	GrpcMetaTimeout     string
	GrpcMaxServerConn   int64
	GrpcBurstServerConn int
	MaxListenerConn     int

	LogPath string
}

type Consul interface {
	Nodes() ([]Health, gobol.Error)
	Self() (string, gobol.Error)
	Uptime(node string) (int64, error)
}

type ConsulConfig struct {
	//Consul agent adrress without the scheme
	Address string
	//Consul agent port
	Port int
	//Location of consul agent cert file
	Cert string
	//Location of consul agent key file
	Key string
	//Location of consul agent CA file
	CA string
	//Name of the service to be probed on consul
	Service string
	//Tag of the service
	Tag string
	// Token of the service
	Token string
	// Protocol of the service
	Protocol string
}

type GrpcServer interface {
	Write(stream pb.Timeseries_WriteServer) error
	Read(q *pb.Query, stream pb.Timeseries_ReadServer) error
	WriteMeta(stream pb.Timeseries_WriteMetaServer) error
	Stop()
}

type Health struct {
	Node    Node    `json:"Node"`
	Service Service `json:"Service"`
	Checks  []Check `json:"Checks"`
}

type KV struct {
	Value string `json:"Value"`
}

type Local struct {
	Config Conf `json:"Config"`
}

type Node struct {
	ID              string            `json:"ID"`
	Node            string            `json:"Node"`
	Address         string            `json:"Address"`
	TaggedAddresses TagAddr           `json:"TaggedAddresses"`
	Meta            map[string]string `json:"Meta"`
	CreateIndex     int               `json:"CreateIndex"`
	ModifyIndex     int               `json:"ModifyIndex"`
}

type Service struct {
	ID                string   `json:"ID"`
	Service           string   `json:"Service"`
	Tags              []string `json:"Tags"`
	Address           string   `json:"Address"`
	Port              int      `json:"Port"`
	EnableTagOverride bool     `json:"EnableTagOverride"`
	CreateIndex       int      `json:"CreateIndex"`
	ModifyIndex       int      `json:"ModifyIndex"`
}

type TagAddr struct {
	Lan string `json:"lan"`
	Wan string `json:"wan"`
}