service

Documentation

Index

• Constants
• func RequiredBridges(services map[string]*ServiceBindings, siteId string) (*qdr.BridgeConfig, error)
• type EgressBindingKey
• type EgressBindings
  • func (target *EgressBindings) GetLocalTargetPorts(desired *ServiceBindings) map[int]int
• type ExternalBridge
• type NullTargetResolver
  • func (o *NullTargetResolver) Close()
  • func (o *NullTargetResolver) HasTarget() bool
  • func (o *NullTargetResolver) List() []string
• type ServiceBindingContext
• type ServiceBindings
  • func NewServiceBindings(required types.ServiceInterface, ports []int, ...) *ServiceBindings
  • func (bindings *ServiceBindings) AsServiceInterface() types.ServiceInterface
  • func (s *ServiceBindings) FindLocalTarget() *EgressBindings
  • func (s *ServiceBindings) GetIngressPorts() []int
  • func (sb *ServiceBindings) HeadlessName() string
  • func (sb *ServiceBindings) IsHeadless() bool
  • func (s *ServiceBindings) PortMap() map[int]int
  • func (s *ServiceBindings) Protocol() string
  • func (bindings *ServiceBindings) RealiseExternalBridge() error
  • func (bindings *ServiceBindings) RealiseIngress() error
  • func (s *ServiceBindings) RequiresExternalBridge() bool
  • func (s *ServiceBindings) SetIngressPorts(ports []int)
  • func (sb *ServiceBindings) Stop()
  • func (bindings *ServiceBindings) Update(required types.ServiceInterface, bindingContext ServiceBindingContext)
• type ServiceIngress
• type TargetResolver
  • func NewNullTargetResolver(targets []string) TargetResolver

Constants

const (
	ProtocolTCP   string = "tcp"
	ProtocolHTTP  string = "http"
	ProtocolHTTP2 string = "http2"
)

Functions

func RequiredBridges

func RequiredBridges(services map[string]*ServiceBindings, siteId string) (*qdr.BridgeConfig, error)

Types

type EgressBindingKey

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

type EgressBindings

type EgressBindings struct {
	Selector string
	// contains filtered or unexported fields
}

func (*EgressBindings) GetLocalTargetPorts

func (target *EgressBindings) GetLocalTargetPorts(desired *ServiceBindings) map[int]int

type ExternalBridge

type ExternalBridge interface {
	Realise() error
	Matches(def *types.ServiceInterface) bool
}

type NullTargetResolver

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

func (*NullTargetResolver) Close

func (o *NullTargetResolver) Close()

func (*NullTargetResolver) HasTarget

func (o *NullTargetResolver) HasTarget() bool

func (*NullTargetResolver) List

func (o *NullTargetResolver) List() []string

type ServiceBindingContext

type ServiceBindingContext interface {
	NewTargetResolver(address string, selector string, skipTargetStatus bool, namespace string) (TargetResolver, error)
	NewServiceIngress(def *types.ServiceInterface) ServiceIngress
	NewExternalBridge(def *types.ServiceInterface) ExternalBridge
}

type ServiceBindings

type ServiceBindings struct {
	Address string

	Labels      map[string]string
	Annotations map[string]string

	TlsCredentials           string
	TlsCertAuthority         string
	PublishNotReadyAddresses bool
	// contains filtered or unexported fields
}

func NewServiceBindings

func NewServiceBindings(required types.ServiceInterface, ports []int, bindingContext ServiceBindingContext) *ServiceBindings

func (*ServiceBindings) AsServiceInterface

func (bindings *ServiceBindings) AsServiceInterface() types.ServiceInterface

func (*ServiceBindings) FindLocalTarget

func (s *ServiceBindings) FindLocalTarget() *EgressBindings

func (*ServiceBindings) GetIngressPorts

func (s *ServiceBindings) GetIngressPorts() []int

func (*ServiceBindings) HeadlessName

func (sb *ServiceBindings) HeadlessName() string

func (*ServiceBindings) IsHeadless

func (sb *ServiceBindings) IsHeadless() bool

func (*ServiceBindings) PortMap

func (s *ServiceBindings) PortMap() map[int]int

func (*ServiceBindings) Protocol

func (s *ServiceBindings) Protocol() string

func (*ServiceBindings) RealiseExternalBridge

func (bindings *ServiceBindings) RealiseExternalBridge() error

func (*ServiceBindings) RealiseIngress

func (bindings *ServiceBindings) RealiseIngress() error

func (*ServiceBindings) RequiresExternalBridge

func (s *ServiceBindings) RequiresExternalBridge() bool

func (*ServiceBindings) SetIngressPorts

func (s *ServiceBindings) SetIngressPorts(ports []int)

func (*ServiceBindings) Stop

func (sb *ServiceBindings) Stop()

func (*ServiceBindings) Update

func (bindings *ServiceBindings) Update(required types.ServiceInterface, bindingContext ServiceBindingContext)

type ServiceIngress

type ServiceIngress interface {
	Realise(binding *ServiceBindings) error
	Mode() types.ServiceIngressMode
	Matches(def *types.ServiceInterface) bool
}

type TargetResolver

type TargetResolver interface {
	Close()
	List() []string
	HasTarget() bool
}

func NewNullTargetResolver

func NewNullTargetResolver(targets []string) TargetResolver