k8sclient

Documentation

Index

• type EndpointAddress
• type EndpointSubset
• type Endpoints
• type EventType
• type K8sClient
  • func New() (K8sClient, error)
• type Metadata
• type WatchEndpointsCallback

Types

type EndpointAddress

type EndpointAddress struct {
	IP string `json:"ip"`
}

type EndpointSubset

type EndpointSubset struct {
	Addresses []EndpointAddress `json:"addresses"`
}

type Endpoints

type Endpoints struct {
	Metadata Metadata         `json:"metadata"`
	Subsets  []EndpointSubset `json:"subsets"`
}

type EventType

type EventType string

const (
	EventAdded    EventType = "ADDED"
	EventModified EventType = "MODIFIED"
	EventDeleted  EventType = "DELETED"
)

type K8sClient

type K8sClient interface {
	Namespace() (namespace string)
	GetEndpoints(ctx context.Context, namespace, endpointsName string) (endpoints *Endpoints, err error)
	WatchEndpoints(ctx context.Context, namespace, endpointsName, resourceVersion string, callback WatchEndpointsCallback) (err error)
}

func New

func New() (K8sClient, error)

type Metadata

type Metadata struct {
	ResourceVersion string `json:"resourceVersion"`
}

type WatchEndpointsCallback

type WatchEndpointsCallback func(eventType EventType, endpoints *Endpoints) (ok bool)