discovery

type Conn interface {
	curator.CuratorFramework
}

type InstanceProvider interface {
	/**
	 * Return the current available set of instances <b>IMPORTANT: </b> users
	 * should not hold on to the instance returned. They should always get a fresh list.
	 */
	GetAllInstances() ([]*ServiceInstance, error)
}

type InstanceSerializer interface {
	Serialize(i *ServiceInstance) ([]byte, error)
	Deserialize(b []byte) (*ServiceInstance, error)
}

type JsonInstanceSerializer struct {
}

type ProviderStrategy interface {
	// Given a source of instances, return one of them for a single use.
	GetInstance(instanceProvider InstanceProvider) (*ServiceInstance, error)
}

type RandomProvider struct {
	*rand.Rand
}

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

type ServiceDiscovery struct {

	// Cache of watched services
	Services map[string][]*ServiceInstance
	// contains filtered or unexported fields
}

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

type ServiceInstance struct {
	Name                string      `json:"name"`
	Id                  string      `json:"id"`
	Address             string      `json:"address"`
	Port                *int        `json:"port"`
	SslPort             *int        `json:"sslPort"`
	Payload             *string     `json:"payload"`
	RegistrationTimeUTC int64       `json:"registrationTimeUTC"`
	ServiceType         ServiceType `json:"serviceType"`
	UriSpec             *string     `json:"uriSpec"`
}

type ServiceProvider interface {
	InstanceProvider
	/**
	 * Return an instance for a single use. <b>IMPORTANT: </b> users
	 * should not hold on to the instance returned. They should always get a fresh instance.
	 */
	GetInstance() (*ServiceInstance, error)
}

type ServiceType string

type TreeCache struct {
	*ServiceDiscovery
	// contains filtered or unexported fields
}