types

May 6, 2024

Changes in this version

+ func NodeFilterForEndpointCalculatorMode(mode EndpointsCalculatorMode) zonegetter.Filter

+ func NodeFilterForNetworkEndpointType(negType NetworkEndpointType) zonegetter.Filter

Jul 6, 2023

Changes in this version

+ const DualStackMigration

+ const Duplicate

+ const IPInvalid

+ const IPNotFromPod

+ const IPOutOfPodCIDR

+ const NodeMissing

+ const NodeNotFound

+ const OtherError

+ const PodInvalid

+ const PodLabelMismatch

+ const PodTerminal

+ const ReasonCurrentNegEPNotFound

+ const ReasonEPCalculationCountZero

+ const ReasonEPCountsDiffer

+ const ReasonEPIPInvalid

+ const ReasonEPIPNotFromPod

+ const ReasonEPIPOutOfPodCIDR

+ const ReasonEPNodeMissing

+ const ReasonEPNodeNotFound

+ const ReasonEPNodeTypeAssertionFailed

+ const ReasonEPPodLabelMismatch

+ const ReasonEPPodMissing

+ const ReasonEPPodNotFound

+ const ReasonEPPodTerminal

+ const ReasonEPPodTypeAssertionFailed

+ const ReasonEPSEndpointCountZero

+ const ReasonEPSNotFound

+ const ReasonEPServiceNotFound

+ const ReasonEPZoneMissing

+ const ReasonInvalidAPIResponse

+ const ReasonInvalidEPAttach

+ const ReasonInvalidEPDetach

+ const ReasonNegNotFound

+ const ReasonOtherError

+ const ReasonSuccess

+ const Total

+ const ZoneMissing

+ var ErrCurrentNegEPNotFound = NegSyncError

+ var ErrEPIPInvalid = NegSyncError

+ var ErrEPIPNotFromPod = NegSyncError

+ var ErrEPIPOutOfPodCIDR = NegSyncError

+ var ErrEPNodeTypeAssertionFailed = NegSyncError

+ var ErrEPPodLabelMismatch = NegSyncError

+ var ErrEPPodTerminal = NegSyncError

+ var ErrEPSNotFound = NegSyncError

+ var ErrEPServiceNotFound = NegSyncError

+ var ErrNegNotFound = NegSyncError

+ func IsStrategyQuotaError(err error) bool

type FakeNetworkEndpointGroupCloud

+ func (f *FakeNetworkEndpointGroupCloud) NetworkProjectID() string

+ func (f *FakeNetworkEndpointGroupCloud) Region() string

+ type NegSyncError struct

+ Err error

+ IsErrorState bool

+ Reason Reason

+ func ClassifyError(err error) NegSyncError

+ func (se NegSyncError) Error() string

type NetworkEndpointGroupCloud

+ func NewAdapterWithRateLimitSpecs(g *gce.Cloud, specs []string) NetworkEndpointGroupCloud

+ NetworkProjectID func() string

+ Region func() string

type PortInfo

+ NetworkInfo network.NetworkInfo

+ type Reason string

type State

+ func StatesForEndpointMetrics() []State

+ type StrategyQuotaError struct

+ Err error

+ func (e StrategyQuotaError) Error() string

type TestContext

+ GKENetworkParamSetInformer cache.SharedIndexInformer

+ NetworkInformer cache.SharedIndexInformer

Apr 17, 2023

Changes in this version

+ const EPDuplicate

+ const EPMissingField

+ const EPMissingNodeName

+ const EPMissingPod

+ const EPMissingZone

+ const EPSTotal

+ const EPSWithDuplicate

+ const EPSWithMissingField

+ const EPSWithMissingNodeName

+ const EPSWithMissingPod

+ const EPSWithMissingZone

+ const EPTotal

+ const ResultCurrentNegEPNotFound

+ const ResultEPNodeMissing

+ const ResultEPNodeNotFound

+ const ResultEPPodMissing

+ const ResultEPPodNotFound

+ const ResultEPPodTypeAssertionFailed

+ const ResultEPZoneMissing

+ var ErrEPNodeMissing = errors.New("endpoint has missing nodeName field")

+ var ErrEPNodeNotFound = errors.New("endpoint corresponds to an non-existing node")

+ var ErrEPPodMissing = errors.New("endpoint has missing pod field")

+ var ErrEPPodNotFound = errors.New("endpoint corresponds to an non-existing pod")

+ var ErrEPPodTypeAssertionFailed = errors.New("endpoint corresponds to an object that fails pod type assertion")

+ var ErrEPZoneMissing = errors.New("endpoint has missing zone field")

+ var ErrInvalidAPIResponse = errors.New("received response error doesn't match googleapi.Error type")

+ var ErrInvalidEPAttach = errors.New("endpoint information for attach operation is incorrect")

+ var ErrInvalidEPDetach = errors.New("endpoint information for detach operation is incorrect")

+ var ErrorStateResult = map[error]Result

type NetworkEndpoint

+ IPv6 string

type NetworkEndpointsCalculator

+ CalculateEndpointsDegradedMode func(eds []EndpointsData, currentMap map[string]NetworkEndpointSet) (map[string]NetworkEndpointSet, EndpointPodMap, error)

+ ValidateEndpoints func(endpointData []EndpointsData, endpointPodMap EndpointPodMap, dupCount int) error

+ type Result string

+ type State string

+ type StateCountMap map[State]int

+ type SyncerEPStat struct

+ EndpointSliceStateCount StateCountMap

+ EndpointStateCount StateCountMap

+ func NewSyncerEPStat() *SyncerEPStat

type TestContext

+ EnableDualStackNEG bool

Mar 18, 2023

Changes in this version

type AddressData

+ AddressType discovery.AddressType

type TestContext

+ NumGCWorkers int

Feb 17, 2023

Changes in this version

+ var ErrEPCalculationCountZero = errors.New("endpoint count from endpointPodMap cannot be zero")

+ var ErrEPCountsDiffer = errors.New("endpoint counts from endpointData and endpointPodMap differ")

+ var ErrEPMissingNodeName = errors.New("endpoint has empty nodeName field")

+ var ErrEPMissingZone = errors.New("endpoint has empty zone field")

+ var ErrEPSEndpointCountZero = errors.New("endpoint count from endpointData cannot be zero")

+ var ErrNodeNotFound = errors.New("failed to retrieve associated zone of node")

+ var ResultCurrentEPNotFound = "CurrentEPNotFound"

+ var ResultEPCalculationCountZero = "EPCalculationCountZero"

+ var ResultEPCountsDiffer = "EPCountsDiffer"

+ var ResultEPMissingNodeName = "EPMissingNodeName"

+ var ResultEPMissingZone = "EPMissingZone"

+ var ResultEPSEndpointCountZero = "EPSEndpointCountZero"

+ var ResultEPSNotFound = "EPSNotFound"

+ var ResultInProgress = "InProgress"

+ var ResultInvalidAPIResponse = "InvalidAPIResponse"

+ var ResultInvalidEPAttach = "InvalidEPAttach"

+ var ResultInvalidEPDetach = "InvalidEPDetach"

+ var ResultNegNotFound = "NegNotFound"

+ var ResultNodeNotFound = "NodeNotFound"

+ var ResultOtherError = "OtherError"

+ var ResultSuccess = "Success"

+ type NegSyncResult struct

+ Error error

+ Result string

+ func NewNegSyncResult(err error, result string) *NegSyncResult

Oct 15, 2022

Changes in this version

+ func NodePredicateForNetworkEndpointType(negType NetworkEndpointType) utils.NodeConditionPredicate

Sep 24, 2021

Changes in this version

+ const TestUnreadyInstance1

+ const TestUnreadyInstance2

+ const TestUpgradeInstance1

+ const TestUpgradeInstance2

+ const TestZone3

+ const TestZone4

+ func NodePredicateForEndpointCalculatorMode(mode EndpointsCalculatorMode) utils.NodeConditionPredicate

+ type AddressData struct

+ Addresses []string

+ NodeName *string

+ Ready bool

+ TargetRef *apiv1.ObjectReference

+ type EndpointsData struct

+ Addresses []AddressData

+ Meta *metav1.ObjectMeta

+ Ports []PortData

+ func EndpointsDataFromEndpointSlices(slices []*discovery.EndpointSlice) []EndpointsData

+ func EndpointsDataFromEndpoints(ep *apiv1.Endpoints) []EndpointsData

+ type PortData struct

+ Name string

+ Port int32

type PortInfoMap

+ func (p1 PortInfoMap) EndpointsCalculatorMode() EndpointsCalculatorMode

type TestContext

+ EndpointSliceInformer cache.SharedIndexInformer

Nov 10, 2021

Changes in this version

+ type FakeZoneGetter struct

+ func (f *FakeZoneGetter) AddZone(newZone string, instances ...string) error

+ func (f *FakeZoneGetter) DeleteZone(newZone string)

+ func (f *FakeZoneGetter) GetZoneForNode(name string) (string, error)

+ func (f *FakeZoneGetter) ListZones() ([]string, error)

Apr 13, 2021

Changes in this version

+ type TestContext struct

+ Cloud *gce.Cloud

+ EndpointInformer cache.SharedIndexInformer

+ IngressInformer cache.SharedIndexInformer

+ KubeClient kubernetes.Interface

+ KubeSystemUID types.UID

+ L4Namer namer.L4ResourcesNamer

+ NegNamer NetworkEndpointGroupNamer

+ NodeInformer cache.SharedIndexInformer

+ PodInformer cache.SharedIndexInformer

+ ResyncPeriod time.Duration

+ ServiceInformer cache.SharedIndexInformer

+ SvcNegClient svcnegclient.Interface

+ SvcNegInformer cache.SharedIndexInformer

+ func NewTestContext() *TestContext

+ func NewTestContextWithKubeClient(kubeClient kubernetes.Interface) *TestContext

Dec 17, 2020

Changes in this version

+ func MockBetaAggregatedListNetworkEndpointGroupHook(ctx context.Context, fl *filter.F, m *cloud.MockBetaNetworkEndpointGroups) (bool, map[string][]*computebeta.NetworkEndpointGroup, error)

+ func MockBetaAttachNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) error

+ func MockBetaDetachNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) error

+ func MockBetaListNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) ([]*computebeta.NetworkEndpointWithHealthStatus, error)

Oct 23, 2020

Changes in this version

type NetworkEndpointGroupCloud

+ func NewAdapterWithNetwork(g *gce.Cloud, network, subnetwork string) NetworkEndpointGroupCloud

Aug 6, 2020

Changes in this version

+ const NegCRControllerValue

+ const NegCRManagedByKey

+ const NegCRServiceNameKey

+ const NegCRServicePortKey

+ const NegGCError

+ const NegInitializationFailed

+ const NegInitializationSuccessful

+ const NegSyncFailed

+ const NegSyncSuccessful

type NegSyncerKey

+ EpCalculatorMode EndpointsCalculatorMode

+ NegName string

type PortInfo

+ EpCalculatorMode EndpointsCalculatorMode

type ZoneGetter

+ func NewSimpleZoneGetter(zone string) ZoneGetter

May 27, 2020

Changes in this version

+ const VmIpEndpointType

type NetworkEndpointGroupNamer

+ VMIPNEG func(namespace, name string) string

type PortInfoMap

+ func NewPortInfoMapForVMIPNEG(namespace, name string, namer NetworkEndpointGroupNamer, randomize bool) PortInfoMap

Mar 9, 2020

Changes in this version

+ const L4ClusterMode

+ const L4LocalMode

+ const L7Mode

+ const TestInstance5

+ const TestInstance6

+ func MockAlphaAggregatedListNetworkEndpointGroupHook(ctx context.Context, fl *filter.F, m *cloud.MockAlphaNetworkEndpointGroups) (bool, map[string][]*computealpha.NetworkEndpointGroup, error)

+ func MockAlphaAttachNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) error

+ func MockAlphaDetachNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) error

+ func MockAlphaListNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) ([]*computealpha.NetworkEndpointWithHealthStatus, error)

+ type EndpointsCalculatorMode string

type NegSyncerManager

+ SyncNodes func()

type NetworkEndpointGroupNamer

+ PrimaryIPNEG func(namespace, name string) string

+ type NetworkEndpointsCalculator interface

+ CalculateEndpoints func(ep *v1.Endpoints, currentMap map[string]NetworkEndpointSet) (map[string]NetworkEndpointSet, EndpointPodMap, error)

+ Mode func() EndpointsCalculatorMode

type PortInfo

+ RandomizeEndpoints bool

type PortInfoMap

+ func NewPortInfoMapForPrimaryIPNEG(namespace, name string, namer NetworkEndpointGroupNamer, randomize bool) PortInfoMap

type SvcPortTuple

+ func (t SvcPortTuple) Empty() bool

Nov 18, 2019

Changes in this version

+ const NonGCPPrivateEndpointType

+ const VmIpPortEndpointType

+ const VmPrimaryIpEndpointType

type NegSyncerKey

+ NegType NetworkEndpointType

+ PortTuple SvcPortTuple

+ func (key NegSyncerKey) GetAPIVersion() meta.Version

+ type NetworkEndpointType string

type PortInfo

+ PortTuple SvcPortTuple

+ type SvcPortTuple struct

+ Name string

+ Port int32

+ TargetPort string

+ func (t SvcPortTuple) String() string

+ type SvcPortTupleSet map[SvcPortTuple]struct

+ func NewSvcPortTupleSet(tuples ...SvcPortTuple) SvcPortTupleSet

+ func (set SvcPortTupleSet) Get(svcPort int32) (SvcPortTuple, bool)

+ func (set SvcPortTupleSet) Insert(tuples ...SvcPortTuple)

Sep 26, 2019

Changes in this version

+ func MockAggregatedListNetworkEndpointGroupHook(ctx context.Context, fl *filter.F, m *cloud.MockNetworkEndpointGroups) (bool, map[string][]*compute.NetworkEndpointGroup, error)

type NegSyncerKey

+ Subset string

+ SubsetLabels string

type NetworkEndpointGroupNamer

+ NEGWithSubset func(namespace, name, subset string, port int32) string

type NetworkEndpointStore

+ func GetNetworkEndpointStore(negCloud NetworkEndpointGroupCloud) NetworkEndpointStore

+ func (s NetworkEndpointStore) AddNetworkEndpointHealthStatus(key meta.Key, entry NetworkEndpointEntry)

type PortInfo

+ Subset string

+ SubsetLabels string

type PortInfoMap

+ func NewPortInfoMapWithDestinationRule(namespace, name string, svcPortMap SvcPortMap, namer NetworkEndpointGroupNamer, ...) (PortInfoMap, error)

+ func (p1 PortInfoMap) ToPortSubsetNegMap() annotations.PortSubsetNegMap

+ type PortInfoMapKey struct

+ ServicePort int32

+ Subset string

Jun 14, 2019

Changes in this version

+ type EndpointPodMap map[NetworkEndpoint]types.NamespacedName

+ type NegSyncerKey struct

+ Name string

+ Namespace string

+ Port int32

+ TargetPort string

+ func (key NegSyncerKey) String() string

+ type NetworkEndpoint struct

+ IP string

+ Node string

+ Port string

type NetworkEndpointGroupCloud

+ func NewAdapter(g *gce.Cloud) NetworkEndpointGroupCloud

+ type NetworkEndpointSet map[NetworkEndpoint]struct

+ func NetworkEndpointSetKeySet(theMap interface{}) NetworkEndpointSet

+ func NewNetworkEndpointSet(items ...NetworkEndpoint) NetworkEndpointSet

+ func (s NetworkEndpointSet) Delete(items ...NetworkEndpoint)

+ func (s NetworkEndpointSet) Difference(s2 NetworkEndpointSet) NetworkEndpointSet

+ func (s NetworkEndpointSet) Has(item NetworkEndpoint) bool

+ func (s NetworkEndpointSet) HasAll(items ...NetworkEndpoint) bool

+ func (s NetworkEndpointSet) HasAny(items ...NetworkEndpoint) bool

+ func (s NetworkEndpointSet) Insert(items ...NetworkEndpoint)

+ func (s NetworkEndpointSet) Len() int

+ func (s NetworkEndpointSet) List() []NetworkEndpoint

+ func (s NetworkEndpointSet) PopAny() (NetworkEndpoint, bool)

+ func (s1 NetworkEndpointSet) Equal(s2 NetworkEndpointSet) bool

+ func (s1 NetworkEndpointSet) Intersection(s2 NetworkEndpointSet) NetworkEndpointSet

+ func (s1 NetworkEndpointSet) IsSuperset(s2 NetworkEndpointSet) bool

+ func (s1 NetworkEndpointSet) Union(s2 NetworkEndpointSet) NetworkEndpointSet

+ type PortInfo struct

+ NegName string

+ ReadinessGate bool

+ TargetPort string

+ type PortInfoMap map[int32]PortInfo

+ func NewPortInfoMap(namespace, name string, svcPortMap SvcPortMap, namer NetworkEndpointGroupNamer, ...) PortInfoMap

+ func (p1 PortInfoMap) Difference(p2 PortInfoMap) PortInfoMap

+ func (p1 PortInfoMap) Merge(p2 PortInfoMap) error

+ func (p1 PortInfoMap) NegsWithReadinessGate() sets.String

+ func (p1 PortInfoMap) ToPortNegMap() annotations.PortNegMap

+ type SvcPortMap map[int32]string

Feb 27, 2019

Changes in this version

+ func MockAttachNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) error

+ func MockDetachNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) error

+ func MockListNetworkEndpointsHook(ctx context.Context, key *meta.Key, ...) ([]*compute.NetworkEndpointWithHealthStatus, error)

+ func MockNetworkEndpointAPIs(fakeGCE *gce.GCECloud)

+ type NetworkEndpointEntry struct

+ Healths []*compute.HealthStatusForNetworkEndpoint

+ NetworkEndpoint *compute.NetworkEndpoint

+ type NetworkEndpointStore map[meta.Key][]NetworkEndpointEntry

Nov 1, 2018

Changes in this version

+ const TestInstance1

+ const TestInstance2

+ const TestInstance3

+ const TestInstance4

+ const TestZone1

+ const TestZone2

+ var NotFoundError = fmt.Errorf("Not Found")

+ func NewFakeZoneGetter() *fakeZoneGetter

+ type FakeNetworkEndpointGroupCloud struct

+ Network string

+ NetworkEndpointGroups map[string][]*computebeta.NetworkEndpointGroup

+ NetworkEndpoints map[string][]*computebeta.NetworkEndpoint

+ Subnetwork string

+ func (f *FakeNetworkEndpointGroupCloud) AggregatedListNetworkEndpointGroup() (map[string][]*computebeta.NetworkEndpointGroup, error)

+ func (f *FakeNetworkEndpointGroupCloud) AttachNetworkEndpoints(name, zone string, endpoints []*computebeta.NetworkEndpoint) error

+ func (f *FakeNetworkEndpointGroupCloud) CreateNetworkEndpointGroup(neg *computebeta.NetworkEndpointGroup, zone string) error

+ func (f *FakeNetworkEndpointGroupCloud) DeleteNetworkEndpointGroup(name string, zone string) error

+ func (f *FakeNetworkEndpointGroupCloud) DetachNetworkEndpoints(name, zone string, endpoints []*computebeta.NetworkEndpoint) error

+ func (f *FakeNetworkEndpointGroupCloud) GetNetworkEndpointGroup(name string, zone string) (*computebeta.NetworkEndpointGroup, error)

+ func (f *FakeNetworkEndpointGroupCloud) ListNetworkEndpointGroup(zone string) ([]*computebeta.NetworkEndpointGroup, error)

+ func (f *FakeNetworkEndpointGroupCloud) ListNetworkEndpoints(name, zone string, showHealthStatus bool) ([]*computebeta.NetworkEndpointWithHealthStatus, error)

+ func (f *FakeNetworkEndpointGroupCloud) NetworkURL() string

+ func (f *FakeNetworkEndpointGroupCloud) SubnetworkURL() string

+ type NegStatus struct

+ NetworkEndpointGroups PortNameMap

+ Zones []string

+ type NegSyncer interface

+ IsShuttingDown func() bool

+ IsStopped func() bool

+ Start func() error

+ Stop func()

+ Sync func() bool

+ type NegSyncerManager interface

+ EnsureSyncers func(namespace, name string, portMap PortNameMap) error

+ GC func() error

+ ShutDown func()

+ StopSyncer func(namespace, name string)

+ Sync func(namespace, name string)

+ type NetworkEndpointGroupCloud interface

+ AggregatedListNetworkEndpointGroup func() (map[string][]*computebeta.NetworkEndpointGroup, error)

+ AttachNetworkEndpoints func(name, zone string, endpoints []*computebeta.NetworkEndpoint) error

+ CreateNetworkEndpointGroup func(neg *computebeta.NetworkEndpointGroup, zone string) error

+ DeleteNetworkEndpointGroup func(name string, zone string) error

+ DetachNetworkEndpoints func(name, zone string, endpoints []*computebeta.NetworkEndpoint) error

+ GetNetworkEndpointGroup func(name string, zone string) (*computebeta.NetworkEndpointGroup, error)

+ ListNetworkEndpointGroup func(zone string) ([]*computebeta.NetworkEndpointGroup, error)

+ ListNetworkEndpoints func(name, zone string, showHealthStatus bool) ([]*computebeta.NetworkEndpointWithHealthStatus, error)

+ NetworkURL func() string

+ SubnetworkURL func() string

+ func NewFakeNetworkEndpointGroupCloud(subnetwork, network string) NetworkEndpointGroupCloud

+ type NetworkEndpointGroupNamer interface

+ IsNEG func(name string) bool

+ NEG func(namespace, name string, port int32) string

+ type PortNameMap map[int32]string

+ func (p1 PortNameMap) Difference(p2 PortNameMap) PortNameMap

+ func (p1 PortNameMap) Union(p2 PortNameMap) PortNameMap

+ type ZoneGetter interface

+ GetZoneForNode func(name string) (string, error)

+ ListZones func() ([]string, error)