cluster

Documentation

Index

• type Config
• type Connection
  • func NewConnection(config *Config) (Connection, error)
  • func NewKubernetesClient(namespace string, service string) (Connection, error)
• type Endpoint

Types

type Config

type Config struct {
	Discovery string `yaml:"discovery"`
	Namespace string `yaml:"namespace"`
	Service   string `yaml:"service"`
}

Config contains the cluster configuration.

type Connection

type Connection interface {
	Endpoints(portname string) []Endpoint
	Broadcast(req *http.Request, portname string, path string)
}

Connection is the cluster connection interface.

func NewConnection

func NewConnection(config *Config) (Connection, error)

NewConnection create a new cluster connection.

func NewKubernetesClient

func NewKubernetesClient(namespace string, service string) (Connection, error)

NewKubernetesClient create a new kubernetes clientset.

type Endpoint

type Endpoint struct {
	Name string
	Host string
	Port int
}

Endpoint contains kubernetes endpoint information.