structs

type BlockingQuery struct {
	// If set, wait until query exceeds given index
	MinQueryIndex uint64

	// Provided with MinQueryIndex to wait for change
	MaxQueryTime time.Duration
}

type CheckServiceNode struct {
	Node    Node
	Service NodeService
	Checks  HealthChecks
}

type CheckServiceNodes []CheckServiceNode

type ChecksInStateRequest struct {
	Datacenter string
	State      string
	BlockingQuery
}

type DCSpecificRequest struct {
	Datacenter string
	BlockingQuery
}

type DeregisterRequest struct {
	Datacenter string
	Node       string
	ServiceID  string
	CheckID    string
}

type DirEntries []*DirEntry

type DirEntry struct {
	CreateIndex uint64
	ModifyIndex uint64
	Key         string
	Flags       uint64
	Value       []byte
}

type HealthCheck struct {
	Node        string
	CheckID     string // Unique per-node ID
	Name        string // Check name
	Status      string // The current check status
	Notes       string // Additional notes with the status
	ServiceID   string // optional associated service
	ServiceName string // optional service name
}

type HealthChecks []*HealthCheck

type IndexedCheckServiceNodes struct {
	Index uint64
	Nodes CheckServiceNodes
}

type IndexedDirEntries struct {
	Index   uint64
	Entries DirEntries
}

type IndexedHealthChecks struct {
	Index        uint64
	HealthChecks HealthChecks
}

type IndexedNodeServices struct {
	Index        uint64
	NodeServices *NodeServices
}

type IndexedNodes struct {
	Index uint64
	Nodes Nodes
}

type IndexedServiceNodes struct {
	Index        uint64
	ServiceNodes ServiceNodes
}

type IndexedServices struct {
	Index    uint64
	Services Services
}

type KVSOp string

type KVSRequest struct {
	Datacenter string
	Op         KVSOp    // Which operation are we performing
	DirEnt     DirEntry // Which directory entry
}

type KeyRequest struct {
	Datacenter string
	Key        string
	BlockingQuery
}

type MessageType uint8

type Node struct {
	Node    string
	Address string
}

type NodeService struct {
	ID      string
	Service string
	Tags    []string
	Port    int
}

type NodeServices struct {
	Node     Node
	Services map[string]*NodeService
}

type NodeSpecificRequest struct {
	Datacenter string
	Node       string
	BlockingQuery
}

type Nodes []Node

type RegisterRequest struct {
	Datacenter string
	Node       string
	Address    string
	Service    *NodeService
	Check      *HealthCheck
}

type ServiceNode struct {
	Node        string
	Address     string
	ServiceID   string
	ServiceName string
	ServiceTags []string
	ServicePort int
}

type ServiceNodes []ServiceNode

type ServiceSpecificRequest struct {
	Datacenter  string
	ServiceName string
	ServiceTag  string
	TagFilter   bool // Controls tag filtering
	BlockingQuery
}

type Services map[string][]string