service

Documentation

Index

• type SvcContext
  • func NewCtx(k8s store.K8s, ingress *store.Ingress, path *store.IngressPath, ...) (*SvcContext, error)
  • func (s *SvcContext) GetBackendName() (string, error)
  • func (s *SvcContext) GetService() *store.Service
  • func (s *SvcContext) GetStatus() store.Status
  • func (s *SvcContext) HandleBackend(client api.HAProxyClient, store store.K8s) (reload bool, backendName string, err error)
  • func (s *SvcContext) HandleEndpoints(client api.HAProxyClient, store store.K8s, certs *haproxy.Certificates) (reload bool)

Types

type SvcContext

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

func NewCtx

func NewCtx(k8s store.K8s, ingress *store.Ingress, path *store.IngressPath, tcpService bool) (*SvcContext, error)

func (*SvcContext) GetBackendName

func (s *SvcContext) GetBackendName() (string, error)

GetBackendName checks if servicePort provided in IngressPath exists and construct corresponding backend name Backend name is in format "ServiceNS-ServiceName-PortName"

func (*SvcContext) GetService

func (s *SvcContext) GetService() *store.Service

func (*SvcContext) GetStatus

func (s *SvcContext) GetStatus() store.Status

func (*SvcContext) HandleBackend

func (s *SvcContext) HandleBackend(client api.HAProxyClient, store store.K8s) (reload bool, backendName string, err error)

HandleBackend processes a Service Context and creates/updates corresponding backend configuration in HAProxy

func (*SvcContext) HandleEndpoints

func (s *SvcContext) HandleEndpoints(client api.HAProxyClient, store store.K8s, certs *haproxy.Certificates) (reload bool)

HandleEndpoints lookups the IngressPath related endpoints and handles corresponding backend servers configuration in HAProxy