apihub

type BackendInfo struct {
	Address          string `json:"address"`
	Disabled         bool   `json:"disabled"`
	HeartBeatAddress string `json:"heart_beat_address"`
	HeartBeatTimeout int    `json:"heart_beat_timeout"`
}

type Client interface {
	// Ping pings the ApiHub server.
	//
	// Errors:
	// * Error - indicates the ApiHub API server is in a bad state.
	Ping() error

	// AddService adds a new service.
	//
	// Errors:
	// * When the host is already taken.
	AddService(ServiceSpec) (Service, error)

	// RemoveService removes an existing service.
	//
	// Errors:
	// * When the host is not found.
	RemoveService(host string) error

	// Services lists all services.
	//
	// Errors:
	// * None.
	Services() ([]Service, error)

	// FindService returns the service with the specified host.
	//
	// Errors:
	// * Service not found.
	FindService(host string) (Service, error)

	// UpdateService updates the service with the specified host.
	//
	// Errors:
	// * Service not found.
	UpdateService(string, ServiceSpec) (Service, error)
}

type ErrorResponse struct {
	Error       string `json:"error,omitempty"`
	Description string `json:"error_description,omitempty"`
}

type Service interface {
	// Host returns the subdomain/host used to access a service.
	Host() string

	// Start adds a service in the service pool to host upcoming requests.
	Start() error

	// Stop stops proxying the requests.
	Stop() error

	// Info returns information about a service.
	Info() (ServiceSpec, error)

	// Backends returns all backends in the service.
	Backends() ([]BackendInfo, error)

	// Timeout waits for the duration before returning an error to the client.
	SetTimeout(time.Duration) error
}

type ServicePublisher interface {
	Publish(logger lager.Logger, prefix string, spec ServiceSpec) error
	Unpublish(logger lager.Logger, prefix string, host string) error
}

type ServiceSpec struct {
	// Host specifies the subdomain/host used to access the service.
	Host     string        `json:"host"`
	Disabled bool          `json:"disabled"`
	Timeout  time.Duration `json:"timeout"` // in milliseconds
	Backends []BackendInfo `json:"backends,omitempty"`
}

type ServiceSubscriber interface {
	Subscribe(logger lager.Logger, prefix string, servicesCh chan ServiceSpec, stop <-chan struct{}) error
}

type Storage interface {
	AddService(ServiceSpec) error
	UpdateService(ServiceSpec) error
	FindServiceByHost(string) (ServiceSpec, error)
	Services() ([]ServiceSpec, error)
	RemoveService(string) error
}