cache

package
v1.2.0-alpha.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 1, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

Package cache implements a cache of all the resources that are relevant to the gateway

Package cache is a generated GoMock package.

Package cache is a generated GoMock package.

Package cache contains the cache for the gateway

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessControlPoliciesProcessor 

type AccessControlPoliciesProcessor struct {
}

AccessControlPoliciesProcessor is responsible for processing AccessControlPolicy objects

func (*AccessControlPoliciesProcessor) Delete 

func (p *AccessControlPoliciesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a AccessControlPolicy from the cache and returns true if the policy was found

func (*AccessControlPoliciesProcessor) Insert 

func (p *AccessControlPoliciesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a AccessControlPolicy to the cache and returns true if the target service is routable

type AccessControlPolicyMatchType 

type AccessControlPolicyMatchType string

AccessControlPolicyMatchType is the type used to represent the rate limit policy match type 

const (
	// AccessControlPolicyMatchTypePort is the type used to represent the rate limit policy match type port
	AccessControlPolicyMatchTypePort AccessControlPolicyMatchType = "port"

	// AccessControlPolicyMatchTypeHostnames is the type used to represent the rate limit policy match type hostnames
	AccessControlPolicyMatchTypeHostnames AccessControlPolicyMatchType = "hostnames"

	// AccessControlPolicyMatchTypeRoute is the type used to represent the rate limit policy match type route
	AccessControlPolicyMatchTypeRoute AccessControlPolicyMatchType = "route"
)

type Cache 

type Cache interface {
	Insert(obj interface{}) bool
	Delete(obj interface{}) bool
	BuildConfigs()
}

Cache is the interface for the functionality provided by the cache

type CircuitBreakingPoliciesProcessor 

type CircuitBreakingPoliciesProcessor struct {
}

CircuitBreakingPoliciesProcessor is responsible for processing CircuitBreakingPolicy objects

func (*CircuitBreakingPoliciesProcessor) Delete 

func (p *CircuitBreakingPoliciesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a CircuitBreakingPolicy from the cache and returns true if the policy was found

func (*CircuitBreakingPoliciesProcessor) Insert 

func (p *CircuitBreakingPoliciesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a CircuitBreakingPolicy to the cache and returns true if the target service is routable

type EndpointSlicesProcessor 

type EndpointSlicesProcessor struct {
}

EndpointSlicesProcessor is responsible for processing EndpointSlices

func (*EndpointSlicesProcessor) Delete 

func (p *EndpointSlicesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes the EndpointSlice object from the cache and returns true if the cache was modified

func (*EndpointSlicesProcessor) Insert 

func (p *EndpointSlicesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds the EndpointSlice object to the cache and returns true if the cache was modified

type EndpointsProcessor 

type EndpointsProcessor struct {
}

EndpointsProcessor is responsible for processing Endpoints objects

func (*EndpointsProcessor) Delete 

func (p *EndpointsProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes the Endpoints object from the cache and returns true if the cache was modified

func (*EndpointsProcessor) Insert 

func (p *EndpointsProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds the Endpoints object to the cache and returns true if the cache was modified

type GRPCRoutesProcessor 

type GRPCRoutesProcessor struct {
}

GRPCRoutesProcessor is responsible for processing GRPCRoute objects

func (*GRPCRoutesProcessor) Delete 

func (p *GRPCRoutesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a GRPCRoute from the cache and returns true if the route was found

func (*GRPCRoutesProcessor) Insert 

func (p *GRPCRoutesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a GRPCRoute to the cache and returns true if the route is effective

type GatewayCache 

type GatewayCache struct {
	// contains filtered or unexported fields
}

GatewayCache is a cache of all the resources that are relevant to the gateway

func NewGatewayCache 

func NewGatewayCache(informerCollection *informers.InformerCollection, kubeClient kubernetes.Interface, cfg configurator.Configurator) *GatewayCache

NewGatewayCache creates a new gateway cache

func (*GatewayCache) BuildConfigs 

func (c *GatewayCache) BuildConfigs()

BuildConfigs builds the configs for all the gateways in the cache

func (*GatewayCache) Delete 

func (c *GatewayCache) Delete(obj interface{}) bool

Delete deletes an object from the cache

func (*GatewayCache) Insert 

func (c *GatewayCache) Insert(obj interface{}) bool

Insert inserts an object into the cache

type GatewayClassesProcessor 

type GatewayClassesProcessor struct {
}

GatewayClassesProcessor is responsible for processing GatewayClass objects

func (*GatewayClassesProcessor) Delete 

func (p *GatewayClassesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes the GatewayClass object from the cache and returns true if the cache was modified

func (*GatewayClassesProcessor) Insert 

func (p *GatewayClassesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds the GatewayClass object to the cache and returns true if the cache was modified

type GatewaysProcessor 

type GatewaysProcessor struct {
}

GatewaysProcessor is responsible for processing Gateway objects

func (*GatewaysProcessor) Delete 

func (p *GatewaysProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes the Gateway object from the cache and returns true if the cache was modified

func (*GatewaysProcessor) Insert 

func (p *GatewaysProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds the Gateway object to the cache and returns true if the cache was modified

type HTTPRoutesProcessor 

type HTTPRoutesProcessor struct {
}

HTTPRoutesProcessor is responsible for processing HTTPRoute objects

func (*HTTPRoutesProcessor) Delete 

func (p *HTTPRoutesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a HTTPRoute from the cache and returns true if the route was found

func (*HTTPRoutesProcessor) Insert 

func (p *HTTPRoutesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a HTTPRoute to the cache and returns true if the route is effective

type LoadBalancerPoliciesProcessor 

type LoadBalancerPoliciesProcessor struct {
}

LoadBalancerPoliciesProcessor is responsible for processing LoadBalancerPolicy objects

func (*LoadBalancerPoliciesProcessor) Delete 

func (p *LoadBalancerPoliciesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a LoadBalancerPolicy from the cache and returns true if the policy was found

func (*LoadBalancerPoliciesProcessor) Insert 

func (p *LoadBalancerPoliciesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a LoadBalancerPolicy to the cache and returns true if the target service is routable

type MockCache 

type MockCache struct {
	// contains filtered or unexported fields
}

MockCache is a mock of Cache interface.

func NewMockCache 

func NewMockCache(ctrl *gomock.Controller) *MockCache

NewMockCache creates a new mock instance.

func (*MockCache) BuildConfigs 

func (m *MockCache) BuildConfigs()

BuildConfigs mocks base method.

func (*MockCache) Delete 

func (m *MockCache) Delete(arg0 interface{}) bool

Delete mocks base method.

func (*MockCache) EXPECT 

func (m *MockCache) EXPECT() *MockCacheMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCache) Insert 

func (m *MockCache) Insert(arg0 interface{}) bool

Insert mocks base method.

type MockCacheMockRecorder 

type MockCacheMockRecorder struct {
	// contains filtered or unexported fields
}

MockCacheMockRecorder is the mock recorder for MockCache.

func (*MockCacheMockRecorder) BuildConfigs 

func (mr *MockCacheMockRecorder) BuildConfigs() *gomock.Call

BuildConfigs indicates an expected call of BuildConfigs.

func (*MockCacheMockRecorder) Delete 

func (mr *MockCacheMockRecorder) Delete(arg0 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockCacheMockRecorder) Insert 

func (mr *MockCacheMockRecorder) Insert(arg0 interface{}) *gomock.Call

Insert indicates an expected call of Insert.

type MockProcessor 

type MockProcessor struct {
	// contains filtered or unexported fields
}

MockProcessor is a mock of Processor interface.

func NewMockProcessor 

func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor

NewMockProcessor creates a new mock instance.

func (*MockProcessor) Delete 

func (m *MockProcessor) Delete(arg0 interface{}, arg1 *GatewayCache) bool

Delete mocks base method.

func (*MockProcessor) EXPECT 

func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProcessor) Insert 

func (m *MockProcessor) Insert(arg0 interface{}, arg1 *GatewayCache) bool

Insert mocks base method.

type MockProcessorMockRecorder 

type MockProcessorMockRecorder struct {
	// contains filtered or unexported fields
}

MockProcessorMockRecorder is the mock recorder for MockProcessor.

func (*MockProcessorMockRecorder) Delete 

func (mr *MockProcessorMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockProcessorMockRecorder) Insert 

func (mr *MockProcessorMockRecorder) Insert(arg0, arg1 interface{}) *gomock.Call

Insert indicates an expected call of Insert.

type Processor 

type Processor interface {
	Insert(obj interface{}, cache *GatewayCache) bool
	Delete(obj interface{}, cache *GatewayCache) bool
}

Processor is the interface for the functionality provided by the processors

type ProcessorType 

type ProcessorType string

ProcessorType is the type used to represent the type of processor 

const (
	// ServicesProcessorType is the type used to represent the services processor
	ServicesProcessorType ProcessorType = "services"

	// EndpointSlicesProcessorType is the type used to represent the endpoint slices processor
	EndpointSlicesProcessorType ProcessorType = "endpointslices"

	// EndpointsProcessorType is the type used to represent the endpoints processor
	EndpointsProcessorType ProcessorType = "endpoints"

	// ServiceImportsProcessorType is the type used to represent the service imports processor
	ServiceImportsProcessorType ProcessorType = "serviceimports"

	// SecretsProcessorType is the type used to represent the secrets processor
	SecretsProcessorType ProcessorType = "secrets"

	// GatewayClassesProcessorType is the type used to represent the gateway classes processor
	GatewayClassesProcessorType ProcessorType = "gatewayclasses"

	// GatewaysProcessorType is the type used to represent the gateways processor
	GatewaysProcessorType ProcessorType = "gateways"

	// HTTPRoutesProcessorType is the type used to represent the HTTP routes processor
	HTTPRoutesProcessorType ProcessorType = "httproutes"

	// GRPCRoutesProcessorType is the type used to represent the gRPC routes processor
	GRPCRoutesProcessorType ProcessorType = "grpcroutes"

	// TCPRoutesProcessorType is the type used to represent the TCP routes processor
	TCPRoutesProcessorType ProcessorType = "tcproutes"

	// TLSRoutesProcessorType is the type used to represent the TLS routes processor
	TLSRoutesProcessorType ProcessorType = "tlsroutes"

	// RateLimitPoliciesProcessorType is the type used to represent the rate limit policies processor
	RateLimitPoliciesProcessorType ProcessorType = "ratelimits"

	// SessionStickyPoliciesProcessorType is the type used to represent the session sticky policies processor
	SessionStickyPoliciesProcessorType ProcessorType = "sessionstickies"

	// LoadBalancerPoliciesProcessorType is the type used to represent the load balancer policies processor
	LoadBalancerPoliciesProcessorType ProcessorType = "loadbalancers"

	// CircuitBreakingPoliciesProcessorType is the type used to represent the circuit breaking policies processor
	CircuitBreakingPoliciesProcessorType ProcessorType = "circuitbreakings"

	// AccessControlPoliciesProcessorType is the type used to represent the access control policies processor
	AccessControlPoliciesProcessorType ProcessorType = "accesscontrols"
)

type RateLimitPoliciesProcessor 

type RateLimitPoliciesProcessor struct {
}

RateLimitPoliciesProcessor is responsible for processing RateLimitPolicy objects

func (*RateLimitPoliciesProcessor) Delete 

func (p *RateLimitPoliciesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a RateLimitPolicy from the cache and returns true if the policy was found

func (*RateLimitPoliciesProcessor) Insert 

func (p *RateLimitPoliciesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a RateLimitPolicy to the cache and returns true if the target service is routable

type RateLimitPolicyMatchType 

type RateLimitPolicyMatchType string

RateLimitPolicyMatchType is the type used to represent the rate limit policy match type 

const (
	// RateLimitPolicyMatchTypePort is the type used to represent the rate limit policy match type port
	RateLimitPolicyMatchTypePort RateLimitPolicyMatchType = "port"

	// RateLimitPolicyMatchTypeHostnames is the type used to represent the rate limit policy match type hostnames
	RateLimitPolicyMatchTypeHostnames RateLimitPolicyMatchType = "hostnames"

	// RateLimitPolicyMatchTypeRoute is the type used to represent the rate limit policy match type route
	RateLimitPolicyMatchTypeRoute RateLimitPolicyMatchType = "route"
)

type SecretProcessor 

type SecretProcessor struct {
}

SecretProcessor is a processor for Secret objects

func (*SecretProcessor) Delete 

func (p *SecretProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a Secret object from the cache and returns true if the cache is changed

func (*SecretProcessor) Insert 

func (p *SecretProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a Secret object to the cache and returns true if the cache is changed

type ServiceImportsProcessor 

type ServiceImportsProcessor struct {
}

ServiceImportsProcessor is responsible for processing ServiceImport objects

func (*ServiceImportsProcessor) Delete 

func (p *ServiceImportsProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a ServiceImport from the cache and returns true if the route was found

func (*ServiceImportsProcessor) Insert 

func (p *ServiceImportsProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a ServiceImport to the cache and returns true if the route is effective

type ServicesProcessor 

type ServicesProcessor struct{}

ServicesProcessor is responsible for processing Service objects

func (*ServicesProcessor) Delete 

func (p *ServicesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes the Service object from the cache and returns true if the cache was modified

func (*ServicesProcessor) Insert 

func (p *ServicesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds the Service object to the cache and returns true if the cache was modified

type SessionStickyPoliciesProcessor 

type SessionStickyPoliciesProcessor struct {
}

SessionStickyPoliciesProcessor is responsible for processing TLSRoute objects

func (*SessionStickyPoliciesProcessor) Delete 

func (p *SessionStickyPoliciesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a TLSRoute from the cache and returns true if the route was found

func (*SessionStickyPoliciesProcessor) Insert 

func (p *SessionStickyPoliciesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a TLSRoute to the cache and returns true if the route is effective

type TCPRoutesProcessor 

type TCPRoutesProcessor struct {
}

TCPRoutesProcessor is responsible for processing TCPRoute objects

func (*TCPRoutesProcessor) Delete 

func (p *TCPRoutesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a TCPRoute from the cache and returns true if the route was found

func (*TCPRoutesProcessor) Insert 

func (p *TCPRoutesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a TCPRoute to the cache and returns true if the route is effective

type TLSRoutesProcessor 

type TLSRoutesProcessor struct {
}

TLSRoutesProcessor is responsible for processing TLSRoute objects

func (*TLSRoutesProcessor) Delete 

func (p *TLSRoutesProcessor) Delete(obj interface{}, cache *GatewayCache) bool

Delete removes a TLSRoute from the cache and returns true if the route was found

func (*TLSRoutesProcessor) Insert 

func (p *TLSRoutesProcessor) Insert(obj interface{}, cache *GatewayCache) bool

Insert adds a TLSRoute to the cache and returns true if the route is effective

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.