store

Documentation

Index

• Variables
• func FilterClustersByLabels(clusters []*api.Cluster, labels map[string]string) []*api.Cluster
• func FilterEndpointsByLabels(endpoints []*api.Endpoint, labels map[string]string) []*api.Endpoint
• func FilterListenersByLabels(listeners []*api.Listener, labels map[string]string) []*api.Listener
• func FilterRoutesByLabels(routes []*api.Route, labels map[string]string) []*api.Route
• func ToNamespacedName(node string) (string, string)
• func ToNodeName(name, namespace string) string
• type ListOption
  • func WithLabelFilter(labels map[string]string) ListOption
• type Store
  • func New(c client.Client, reader client.Reader) Store

Variables

var (
	ErrNotFound = errors.New("resource not found")
)

Functions

func FilterClustersByLabels

func FilterClustersByLabels(clusters []*api.Cluster, labels map[string]string) []*api.Cluster

func FilterEndpointsByLabels

func FilterEndpointsByLabels(endpoints []*api.Endpoint, labels map[string]string) []*api.Endpoint

func FilterListenersByLabels

func FilterListenersByLabels(listeners []*api.Listener, labels map[string]string) []*api.Listener

func FilterRoutesByLabels

func FilterRoutesByLabels(routes []*api.Route, labels map[string]string) []*api.Route

func ToNamespacedName

func ToNamespacedName(node string) (string, string)

func ToNodeName

func ToNodeName(name, namespace string) string

Types

type ListOption

type ListOption func(*listOption)

func WithLabelFilter

func WithLabelFilter(labels map[string]string) ListOption

type Store

type Store interface {
	GetCluster(ctx context.Context, name, namespace string) (*api.Cluster, error)
	ListClustersByNamespace(ctx context.Context, namespace string) (*api.ClusterList, error)
	GetListener(ctx context.Context, name, namespace string) (*api.Listener, error)
	ListListenersByNamespace(ctx context.Context, namespace string) (*api.ListenerList, error)
	GetRoute(ctx context.Context, name, namespace string) (*api.Route, error)
	ListRoutesByNamespace(ctx context.Context, namespace string) (*api.RouteList, error)
	GetEndpoint(ctx context.Context, name, namespace string) (*api.Endpoint, error)
	ListEndpointsByNamespace(ctx context.Context, namespace string) (*api.EndpointList, error)
	GetPod(ctx context.Context, name, namespace string) (*corev1.Pod, error)
	ListPodsByNamespace(ctx context.Context, namespace string, options ...ListOption) (*corev1.PodList, error)
}

func New

func New(c client.Client, reader client.Reader) Store