store

Aug 9, 2023

Changes in this version

type CacheStores

+ ConsumerGroup cache.Store

type FakeObjects

+ KongConsumerGroups []*kongv1beta1.KongConsumerGroup

+ func (objects FakeObjects) MarshalToYAML() ([]byte, error)

type Store

+ func (s Store) GetKongConsumerGroup(namespace, name string) (*kongv1beta1.KongConsumerGroup, error)

+ func (s Store) ListKongConsumerGroups() []*kongv1beta1.KongConsumerGroup

type Storer

+ GetKongConsumerGroup func(namespace, name string) (*kongv1beta1.KongConsumerGroup, error)

+ ListKongConsumerGroups func() []*kongv1beta1.KongConsumerGroup

Jun 5, 2023

Changes in this version

type CacheStores

+ EndpointSlice cache.Store

type FakeObjects

+ EndpointSlices []*discoveryv1.EndpointSlice

type Store

+ func (s Store) GetEndpointSlicesForService(namespace, name string) ([]*discoveryv1.EndpointSlice, error)

type Storer

+ GetEndpointSlicesForService func(namespace, name string) ([]*discoveryv1.EndpointSlice, error)

Mar 28, 2023

Changes in this version

type CacheStores

+ GRPCRoute cache.Store

type ErrNotFound

+ Message string

type FakeObjects

+ GRPCRoutes []*gatewayv1alpha2.GRPCRoute

type Store

+ func (s Store) GetIngressClassName() string

+ func (s Store) ListGRPCRoutes() ([]*gatewayv1alpha2.GRPCRoute, error)

type Storer

+ GetIngressClassName func() string

+ ListGRPCRoutes func() ([]*gatewayv1alpha2.GRPCRoute, error)

Dec 19, 2022

Changes in this version

type Store

+ func (s Store) GetGateway(namespace string, name string) (*gatewayv1beta1.Gateway, error)

+ func (s Store) ListKongClusterPlugins() []*kongv1.KongClusterPlugin

+ func (s Store) ListKongPlugins() []*kongv1.KongPlugin

type Storer

+ GetGateway func(namespace string, name string) (*gatewayv1beta1.Gateway, error)

+ ListKongClusterPlugins func() []*kongv1.KongClusterPlugin

+ ListKongPlugins func() []*kongv1.KongPlugin

Sep 14, 2022

Changes in this version

type CacheStores

+ IngressClassParametersV1alpha1 cache.Store

+ ReferenceGrant cache.Store

type FakeObjects

+ IngressClassParametersV1alpha1 []*configurationv1alpha1.IngressClassParameters

+ ReferenceGrants []*gatewayv1alpha2.ReferenceGrant

type Store

+ func (s Store) GetIngressClassParametersV1Alpha1() (*kongv1alpha1.IngressClassParameters, error)

+ func (s Store) ListIngressClassParametersV1Alpha1() []*kongv1alpha1.IngressClassParameters

+ func (s Store) ListReferenceGrants() ([]*gatewayv1alpha2.ReferenceGrant, error)

type Storer

+ GetIngressClassParametersV1Alpha1 func() (*kongv1alpha1.IngressClassParameters, error)

+ ListIngressClassParametersV1Alpha1 func() []*kongv1alpha1.IngressClassParameters

+ ListReferenceGrants func() ([]*gatewayv1alpha2.ReferenceGrant, error)

Jul 11, 2022

Changes in this version

type CacheStores

+ Gateway cache.Store

type FakeObjects

+ Gateways []*gatewayv1alpha2.Gateway

type Store

+ func (s Store) ListGateways() ([]*gatewayv1alpha2.Gateway, error)

type Storer

+ ListGateways func() ([]*gatewayv1alpha2.Gateway, error)

Jun 15, 2022

Changes in this version

type CacheStores

+ ReferencePolicy cache.Store

+ TCPRoute cache.Store

+ TLSRoute cache.Store

type FakeObjects

+ ReferencePolicies []*gatewayv1alpha2.ReferencePolicy

+ TCPRoutes []*gatewayv1alpha2.TCPRoute

+ TLSRoutes []*gatewayv1alpha2.TLSRoute

type Store

+ func (s Store) ListReferencePolicies() ([]*gatewayv1alpha2.ReferencePolicy, error)

+ func (s Store) ListTCPRoutes() ([]*gatewayv1alpha2.TCPRoute, error)

+ func (s Store) ListTLSRoutes() ([]*gatewayv1alpha2.TLSRoute, error)

type Storer

+ ListReferencePolicies func() ([]*gatewayv1alpha2.ReferencePolicy, error)

+ ListTCPRoutes func() ([]*gatewayv1alpha2.TCPRoute, error)

+ ListTLSRoutes func() ([]*gatewayv1alpha2.TLSRoute, error)

Apr 5, 2022

Changes in this version

+ const IngressClassKongController

type CacheStores

+ IngressClassV1 cache.Store

+ UDPRoute cache.Store

type FakeObjects

+ HTTPRoutes []*gatewayv1alpha2.HTTPRoute

+ IngressClassesV1 []*networkingv1.IngressClass

+ UDPRoutes []*gatewayv1alpha2.UDPRoute

type Store

+ func (s Store) GetIngressClassV1(name string) (*networkingv1.IngressClass, error)

+ func (s Store) ListIngressClassesV1() []*networkingv1.IngressClass

+ func (s Store) ListUDPRoutes() ([]*gatewayv1alpha2.UDPRoute, error)

type Storer

+ GetIngressClassV1 func(name string) (*networkingv1.IngressClass, error)

+ ListIngressClassesV1 func() []*networkingv1.IngressClass

+ ListUDPRoutes func() ([]*gatewayv1alpha2.UDPRoute, error)

Jan 5, 2022

Changes in this version

type CacheStores

+ HTTPRoute cache.Store

type FakeObjects

+ HTTPRoute []*gatewayv1alpha2.HTTPRoute

type Store

+ func (s Store) ListHTTPRoutes() ([]*gatewayv1alpha2.HTTPRoute, error)

type Storer

+ ListHTTPRoutes func() ([]*gatewayv1alpha2.HTTPRoute, error)

Oct 22, 2021

Changes in this version

+ type CacheStores struct

+ ClusterPlugin cache.Store

+ Consumer cache.Store

+ Endpoint cache.Store

+ IngressV1 cache.Store

+ IngressV1beta1 cache.Store

+ KnativeIngress cache.Store

+ KongIngress cache.Store

+ Plugin cache.Store

+ Secret cache.Store

+ Service cache.Store

+ TCPIngress cache.Store

+ UDPIngress cache.Store

+ func NewCacheStores() (c CacheStores)

+ func NewCacheStoresFromObjYAML(objs ...[]byte) (c CacheStores, err error)

+ func NewCacheStoresFromObjs(objs ...runtime.Object) (CacheStores, error)

+ func (c CacheStores) Add(obj runtime.Object) error

+ func (c CacheStores) Delete(obj runtime.Object) error

+ func (c CacheStores) Get(obj runtime.Object) (item interface{}, exists bool, err error)

+ type ErrNotFound struct

+ func (e ErrNotFound) Error() string

+ type FakeObjects struct

+ Endpoints []*apiv1.Endpoints

+ IngressesV1 []*networkingv1.Ingress

+ IngressesV1beta1 []*networkingv1beta1.Ingress

+ KnativeIngresses []*knative.Ingress

+ KongClusterPlugins []*configurationv1.KongClusterPlugin

+ KongConsumers []*configurationv1.KongConsumer

+ KongIngresses []*configurationv1.KongIngress

+ KongPlugins []*configurationv1.KongPlugin

+ Secrets []*apiv1.Secret

+ Services []*apiv1.Service

+ TCPIngresses []*configurationv1beta1.TCPIngress

+ UDPIngresses []*configurationv1beta1.UDPIngress

+ type Store struct

+ func (s Store) GetEndpointsForService(namespace, name string) (*corev1.Endpoints, error)

+ func (s Store) GetKongClusterPlugin(name string) (*kongv1.KongClusterPlugin, error)

+ func (s Store) GetKongConsumer(namespace, name string) (*kongv1.KongConsumer, error)

+ func (s Store) GetKongIngress(namespace, name string) (*kongv1.KongIngress, error)

+ func (s Store) GetKongPlugin(namespace, name string) (*kongv1.KongPlugin, error)

+ func (s Store) GetSecret(namespace, name string) (*corev1.Secret, error)

+ func (s Store) GetService(namespace, name string) (*corev1.Service, error)

+ func (s Store) ListCACerts() ([]*corev1.Secret, error)

+ func (s Store) ListGlobalKongClusterPlugins() ([]*kongv1.KongClusterPlugin, error)

+ func (s Store) ListGlobalKongPlugins() ([]*kongv1.KongPlugin, error)

+ func (s Store) ListIngressesV1() []*networkingv1.Ingress

+ func (s Store) ListIngressesV1beta1() []*networkingv1beta1.Ingress

+ func (s Store) ListKnativeIngresses() ([]*knative.Ingress, error)

+ func (s Store) ListKongConsumers() []*kongv1.KongConsumer

+ func (s Store) ListTCPIngresses() ([]*kongv1beta1.TCPIngress, error)

+ func (s Store) ListUDPIngresses() ([]*kongv1beta1.UDPIngress, error)

+ type Storer interface

+ GetEndpointsForService func(namespace, name string) (*corev1.Endpoints, error)

+ GetKongClusterPlugin func(name string) (*kongv1.KongClusterPlugin, error)

+ GetKongConsumer func(namespace, name string) (*kongv1.KongConsumer, error)

+ GetKongIngress func(namespace, name string) (*kongv1.KongIngress, error)

+ GetKongPlugin func(namespace, name string) (*kongv1.KongPlugin, error)

+ GetSecret func(namespace, name string) (*corev1.Secret, error)

+ GetService func(namespace, name string) (*corev1.Service, error)

+ ListCACerts func() ([]*corev1.Secret, error)

+ ListGlobalKongClusterPlugins func() ([]*kongv1.KongClusterPlugin, error)

+ ListGlobalKongPlugins func() ([]*kongv1.KongPlugin, error)

+ ListIngressesV1 func() []*networkingv1.Ingress

+ ListIngressesV1beta1 func() []*networkingv1beta1.Ingress

+ ListKnativeIngresses func() ([]*knative.Ingress, error)

+ ListKongConsumers func() []*kongv1.KongConsumer

+ ListTCPIngresses func() ([]*kongv1beta1.TCPIngress, error)

+ ListUDPIngresses func() ([]*kongv1beta1.UDPIngress, error)

+ func New(cs CacheStores, ingressClass string, processClasslessIngressV1Beta1 bool, ...) Storer

+ func NewFakeStore(objects FakeObjects) (Storer, error)