k8s_service_agg

Documentation

Index

• type Config
• type ServiceAggregate
  • func NewServiceAggregate(config Config) (*ServiceAggregate, error)
  • func (sa *ServiceAggregate) Services(context.Context) ([]service_agg.Service, error)

Types

type Config

type Config struct {
	Namespace             string
	PrefixesAnnotation    string
	ServicePortAnnotation string
	TimeoutAnnotation     string
	InCluster             bool
}

Config for k8s service agg

type ServiceAggregate

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

ServiceAggregate provides k8s services

func NewServiceAggregate

func NewServiceAggregate(config Config) (*ServiceAggregate, error)

NewServiceAggregate returns a new k8s ServiceAggregate

func (*ServiceAggregate) Services

func (sa *ServiceAggregate) Services(context.Context) ([]service_agg.Service, error)

Services implements service_agg.ServiceAggregate.Services