util

Documentation

Index

• Variables
• func AllHostnamesOfManifestGroup(mgroup manifest.Group) []string
• func ApplyToContext(ctx context.Context, config map[interface{}]interface{}) context.Context
• func ComputeCommittedResources(factor float64, rv atypes.ResourceValue) atypes.ResourceValue
• func ExposeExternalPort(expose manifest.ServiceExpose) int32
• func GetEndpointQuantityOfResourceGroup(resources atypes.ResourceGroup, kind atypes.Endpoint_Kind) uint
• func GetEndpointQuantityOfResourceUnits(r atypes.ResourceUnits, kind atypes.Endpoint_Kind) uint
• func IngressHost(lid mtypes.LeaseID, svcName string) string
• func IsInsideKubernetes() (bool, error)
• func LeaseIDToNamespace(lid mtypes.LeaseID) string
• func MakeIPSharingKey(lID mtypes.LeaseID, endpointName string) string
• func ShouldBeIngress(expose manifest.ServiceExpose) bool
• type ServiceClient
• type ServiceDiscoveryAgent
  • func NewServiceDiscoveryAgent(logger log.Logger, kubeConfig *rest.Config, ...) (ServiceDiscoveryAgent, error)

Variables

var (
	ErrShuttingDown = errors.New("shutting down")
)

Functions

func AllHostnamesOfManifestGroup

func AllHostnamesOfManifestGroup(mgroup manifest.Group) []string

func ApplyToContext

func ApplyToContext(ctx context.Context, config map[interface{}]interface{}) context.Context

func ComputeCommittedResources

func ComputeCommittedResources(factor float64, rv atypes.ResourceValue) atypes.ResourceValue

func ExposeExternalPort

func ExposeExternalPort(expose manifest.ServiceExpose) int32

func GetEndpointQuantityOfResourceGroup

func GetEndpointQuantityOfResourceGroup(resources atypes.ResourceGroup, kind atypes.Endpoint_Kind) uint

func GetEndpointQuantityOfResourceUnits

func GetEndpointQuantityOfResourceUnits(r atypes.ResourceUnits, kind atypes.Endpoint_Kind) uint

func IngressHost

func IngressHost(lid mtypes.LeaseID, svcName string) string

func IsInsideKubernetes

func IsInsideKubernetes() (bool, error)

func LeaseIDToNamespace

func LeaseIDToNamespace(lid mtypes.LeaseID) string

LeaseIDToNamespace generates a unique sha256 sum for identifying a provider's object name.

func MakeIPSharingKey

func MakeIPSharingKey(lID mtypes.LeaseID, endpointName string) string

func ShouldBeIngress

func ShouldBeIngress(expose manifest.ServiceExpose) bool

Types

type ServiceClient

type ServiceClient interface {
	CreateRequest(ctx context.Context, method, path string, body io.Reader) (*http.Request, error)
	DoRequest(req *http.Request) (*http.Response, error)
}

type ServiceDiscoveryAgent

type ServiceDiscoveryAgent interface {
	Stop()
	GetClient(ctx context.Context, isHTTPS, secure bool) (ServiceClient, error)
	DiscoverNow()
}

func NewServiceDiscoveryAgent

func NewServiceDiscoveryAgent(logger log.Logger, kubeConfig *rest.Config, portName, serviceName, namespace string, endpoint *net.SRV) (ServiceDiscoveryAgent, error)