store

type Cluster interface {
	Heartbeat(ttl time.Duration) error
	EndSession() error
}

type ContainerRule struct {
	Selector     Selector `json:"selector,omitempty"`
	InstancePort int      `json:"instancePort,omitempty"`
}

type Host struct {
	IP net.IP `json:"address"`
}

type HostChange struct {
	Name         string
	HostDeparted bool
}

type IngressInstance struct {
	Weight int `json:"weight"`
}

type Instance struct {
	Host          Host              `json:"host"`
	ContainerRule string            `json:"containerRule"`
	Address       *netutil.IPPort   `json:"address,omitempty"`
	Labels        map[string]string `json:"labels"`
}

type Labeled interface {
	Label(string) string
}

type QueryServiceOptions struct {
	WithInstances        bool
	WithContainerRules   bool
	WithIngressInstances bool
}

type Selector map[string]string

type Service struct {
	Address      *netutil.IPPort `json:"address,omitempty"`
	InstancePort int             `json:"instancePort,omitempty"`
	Protocol     string          `json:"protocol,omitempty"`
}

type ServiceChange struct {
	Name           string
	ServiceDeleted bool
}

type ServiceInfo struct {
	Service
	Instances        map[string]Instance
	ContainerRules   map[string]ContainerRule
	IngressInstances map[netutil.IPPort]IngressInstance
}

type ServiceUpdate struct {
	Services map[string]*ServiceInfo
	Reset    bool
}

type Store interface {
	Cluster

	Ping() error

	RegisterHost(identity string, details *Host) error
	DeregisterHost(identity string) error
	GetHosts() ([]*Host, error)
	WatchHosts(ctx context.Context, resCh chan<- HostChange, errorSink daemon.ErrorSink)

	CheckRegisteredService(serviceName string) error
	AddService(name string, service Service) error
	RemoveService(serviceName string) error
	RemoveAllServices() error

	GetService(serviceName string, opts QueryServiceOptions) (*ServiceInfo, error)
	GetAllServices(opts QueryServiceOptions) (map[string]*ServiceInfo, error)

	SetContainerRule(serviceName string, ruleName string, spec ContainerRule) error
	RemoveContainerRule(serviceName string, ruleName string) error

	AddInstance(serviceName, instanceName string, details Instance) error
	RemoveInstance(serviceName, instanceName string) error

	AddIngressInstance(serviceName string, addr netutil.IPPort, details IngressInstance) error
	RemoveIngressInstance(serviceName string, addr netutil.IPPort) error

	WatchServices(ctx context.Context, resCh chan<- ServiceChange, errorSink daemon.ErrorSink, opts QueryServiceOptions)
}