discoverd

type Client struct {
	Logger log15.Logger
	// contains filtered or unexported fields
}

type Config struct {
	Endpoints []string
}

type Event struct {
	Service     string       `json:"service"`
	Kind        EventKind    `json:"kind"`
	Instance    *Instance    `json:"instance,omitempty"`
	ServiceMeta *ServiceMeta `json:"service_meta,omitempty"`
}

type EventKind uint

type Heartbeater interface {
	SetMeta(map[string]string) error
	Close() error
	Addr() string
	SetClient(*Client)
}

type Instance struct {
	// ID is unique within the service, and is currently defined as
	// Hex(MD5(Proto + "-" + Addr)) but this may change in the future.
	ID string `json:"id"`

	// Addr is the IP/port address that can be used to communicate with the
	// service. It must be valid to dial this address.
	Addr string `json:"addr"`

	// Proto is the protocol used to connect to the service, examples include:
	// tcp, udp, http, https. It must be lowercase alphanumeric.
	Proto string `json:"proto"`

	// Meta is arbitrary metadata specified when registering the instance.
	Meta map[string]string `json:"meta,omitempty"`

	// Index is the logical epoch of the initial registration of the instance.
	// It is guaranteed to be unique, greater than zero, not change as long as
	// the instance does not expire, and sort with other indexes in the order of
	// instance creation.
	Index uint64 `json:"index,omitempty"`
	// contains filtered or unexported fields
}

type LeaderType string

type Service interface {
	Leader() (*Instance, error)
	Instances() ([]*Instance, error)
	Addrs() ([]string, error)
	Leaders(chan *Instance) (stream.Stream, error)
	Watch(events chan *Event) (stream.Stream, error)
	GetMeta() (*ServiceMeta, error)
	SetMeta(*ServiceMeta) error
	SetLeader(string) error
}

type ServiceConfig struct {
	LeaderType LeaderType `json:"leader_type"`
}

type ServiceMeta struct {
	Data json.RawMessage `json:"data"`

	// LeaderID is the optional ID of an instance to set as a leader when
	// applying the new service metadata. It is only used for writes and is not
	// returned during reads.
	LeaderID string `json:"leader_id,omitempty"`

	// When calling SetMeta, Index is checked against the current index and the
	// set only succeeds if the index is the same. A zero index means the meta
	// does not currently exist.
	Index uint64 `json:"index"`
}

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

type WatchState string