util

Documentation

Index

• Variables
• func GetEndpointQuantityOfResourceGroup(resources dtypes.ResourceGroup, kind atypes.Endpoint_Kind) uint
• func GetEndpointQuantityOfResourceUnits(r atypes.Resources, kind atypes.Endpoint_Kind) uint
• func LeaseIDToNamespace(lid mtypes.LeaseID) string
• func MakeIPSharingKey(lID mtypes.LeaseID, endpointName string) string
• type ServiceClient
• type ServiceDiscoveryAgent
  • func NewServiceDiscoveryAgent(ctx context.Context, logger log.Logger, ...) (ServiceDiscoveryAgent, error)

Variables

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

Functions

func GetEndpointQuantityOfResourceGroup

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

func GetEndpointQuantityOfResourceUnits

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

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

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(ctx context.Context, logger log.Logger, portName, serviceName, namespace string, endpoint *net.SRV) (ServiceDiscoveryAgent, error)