aggregator

Documentation

Index

• Constants
• type Aggregator
  • func NewAggregator(listenAddr string, repoAddr string) *Aggregator
  • func (c *Aggregator) Run() error
• type AggregatorClient
  • func NewAggregatorClient(clusterCfg *config.Store) *AggregatorClient
  • func NewAggregatorClientWithTransport(clusterCfg *config.Store, transport *http.Transport) *AggregatorClient
  • func (c *AggregatorClient) PostIngresses(routes route.IngressRoute)
  • func (c *AggregatorClient) PostServices(routes route.ServiceRoute)

Constants

const (
	IngressPath     = "/ingress"
	ServicePath     = "/service"
	HealthPath      = "/healthz"
	ReadyPath       = "/readyz"
	BaseUrlTemplate = "%s://%s"
)

Types

type Aggregator

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

func NewAggregator

func NewAggregator(listenAddr string, repoAddr string) *Aggregator

func (*Aggregator) Run

func (c *Aggregator) Run() error

type AggregatorClient

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

func NewAggregatorClient

func NewAggregatorClient(clusterCfg *config.Store) *AggregatorClient

func NewAggregatorClientWithTransport

func NewAggregatorClientWithTransport(clusterCfg *config.Store, transport *http.Transport) *AggregatorClient

func (*AggregatorClient) PostIngresses

func (c *AggregatorClient) PostIngresses(routes route.IngressRoute)

func (*AggregatorClient) PostServices

func (c *AggregatorClient) PostServices(routes route.ServiceRoute)