Documentation ¶
Overview ¶
Package configurator is a generated GoMock package.
Package configurator implements the Configurator interface that provides APIs to retrieve OSM control plane configurations.
Index ¶
- type Configurator
- type MockConfigurator
- func (m *MockConfigurator) EXPECT() *MockConfiguratorMockRecorder
- func (m *MockConfigurator) GetCertKeyBitSize() int
- func (m *MockConfigurator) GetConfigResyncInterval() time.Duration
- func (m *MockConfigurator) GetEnvoyImage() string
- func (m *MockConfigurator) GetEnvoyLogLevel() string
- func (m *MockConfigurator) GetEnvoyWindowsImage() string
- func (m *MockConfigurator) GetFeatureFlags() v1alpha1.FeatureFlags
- func (m *MockConfigurator) GetInboundExternalAuthConfig() auth.ExtAuthConfig
- func (m *MockConfigurator) GetInboundPortExclusionList() []int
- func (m *MockConfigurator) GetInitContainerImage() string
- func (m *MockConfigurator) GetMaxDataPlaneConnections() int
- func (m *MockConfigurator) GetMeshConfig() *v1alpha1.MeshConfig
- func (m *MockConfigurator) GetMeshConfigJSON() (string, error)
- func (m *MockConfigurator) GetOSMLogLevel() string
- func (m *MockConfigurator) GetOSMNamespace() string
- func (m *MockConfigurator) GetOutboundIPRangeExclusionList() []string
- func (m *MockConfigurator) GetOutboundPortExclusionList() []int
- func (m *MockConfigurator) GetProxyResources() v1.ResourceRequirements
- func (m *MockConfigurator) GetServiceCertValidityPeriod() time.Duration
- func (m *MockConfigurator) GetTracingEndpoint() string
- func (m *MockConfigurator) GetTracingHost() string
- func (m *MockConfigurator) GetTracingPort() uint32
- func (m *MockConfigurator) IsDebugServerEnabled() bool
- func (m *MockConfigurator) IsEgressEnabled() bool
- func (m *MockConfigurator) IsPermissiveTrafficPolicyMode() bool
- func (m *MockConfigurator) IsPrivilegedInitContainer() bool
- func (m *MockConfigurator) IsTracingEnabled() bool
- func (m *MockConfigurator) UseHTTPSIngress() bool
- type MockConfiguratorMockRecorder
- func (mr *MockConfiguratorMockRecorder) GetCertKeyBitSize() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetConfigResyncInterval() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetEnvoyImage() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetEnvoyLogLevel() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetEnvoyWindowsImage() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetFeatureFlags() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetInboundExternalAuthConfig() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetInboundPortExclusionList() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetInitContainerImage() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetMaxDataPlaneConnections() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetMeshConfig() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetMeshConfigJSON() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetOSMLogLevel() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetOSMNamespace() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetOutboundIPRangeExclusionList() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetOutboundPortExclusionList() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetProxyResources() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetServiceCertValidityPeriod() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetTracingEndpoint() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetTracingHost() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) GetTracingPort() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) IsDebugServerEnabled() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) IsEgressEnabled() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) IsPermissiveTrafficPolicyMode() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) IsPrivilegedInitContainer() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) IsTracingEnabled() *gomock.Call
- func (mr *MockConfiguratorMockRecorder) UseHTTPSIngress() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configurator ¶
type Configurator interface { // GetMeshConfig returns the MeshConfig resource corresponding to the control plane GetMeshConfig() *configv1alpha1.MeshConfig // GetOSMNamespace returns the namespace in which OSM controller pod resides GetOSMNamespace() string // GetMeshConfigJSON returns the MeshConfig in pretty JSON (human readable) GetMeshConfigJSON() (string, error) // IsPermissiveTrafficPolicyMode determines whether we are in "allow-all" mode or SMI policy (block by default) mode IsPermissiveTrafficPolicyMode() bool // IsEgressEnabled determines whether egress is globally enabled in the mesh or not IsEgressEnabled() bool // IsDebugServerEnabled determines whether osm debug HTTP server is enabled IsDebugServerEnabled() bool // IsTracingEnabled returns whether tracing is enabled IsTracingEnabled() bool // GetTracingHost is the host to which we send tracing spans GetTracingHost() string // GetTracingPort returns the tracing listener port GetTracingPort() uint32 // GetTracingEndpoint returns the collector endpoint GetTracingEndpoint() string // UseHTTPSIngress determines whether protocol used for traffic from ingress to backend pods should be HTTPS. UseHTTPSIngress() bool // GetMaxDataPlaneConnections returns the max data plane connections allowed, 0 if disabled GetMaxDataPlaneConnections() int // GetOsmLogLevel returns the configured OSM log level GetOSMLogLevel() string // GetEnvoyLogLevel returns the envoy log level GetEnvoyLogLevel() string // GetEnvoyImage returns the envoy image GetEnvoyImage() string // GetEnvoyWindowsImage returns the envoy windows image GetEnvoyWindowsImage() string // GetInitContainerImage returns the init container image GetInitContainerImage() string // GetServiceCertValidityPeriod returns the validity duration for service certificates GetServiceCertValidityPeriod() time.Duration // GetCertKeyBitSize returns the certificate key bit size GetCertKeyBitSize() int // GetOutboundIPRangeExclusionList returns the list of IP ranges of the form x.x.x.x/y to exclude from outbound sidecar interception GetOutboundIPRangeExclusionList() []string // GetOutboundPortExclusionList returns the list of ports to exclude from outbound sidecar interception GetOutboundPortExclusionList() []int // GetInboundPortExclusionList returns the list of ports to exclude from inbound sidecar interception GetInboundPortExclusionList() []int // IsPrivilegedInitContainer determines whether init containers should be privileged IsPrivilegedInitContainer() bool // GetConfigResyncInterval returns the duration for resync interval. // If error or non-parsable value, returns 0 duration GetConfigResyncInterval() time.Duration // GetProxyResources returns the `Resources` configured for proxies, if any GetProxyResources() corev1.ResourceRequirements // GetInboundExternalAuthConfig returns the External Authentication configuration for incoming traffic, if any GetInboundExternalAuthConfig() auth.ExtAuthConfig // GetFeatureFlags returns OSM's feature flags GetFeatureFlags() configv1alpha1.FeatureFlags }
Configurator is the controller interface for K8s namespaces
func NewConfigurator ¶
func NewConfigurator(kubeClient versioned.Interface, stop <-chan struct{}, osmNamespace, meshConfigName string) Configurator
NewConfigurator implements configurator.Configurator and creates the Kubernetes client to manage namespaces.
type MockConfigurator ¶ added in v0.4.0
type MockConfigurator struct {
// contains filtered or unexported fields
}
MockConfigurator is a mock of Configurator interface
func NewMockConfigurator ¶ added in v0.4.0
func NewMockConfigurator(ctrl *gomock.Controller) *MockConfigurator
NewMockConfigurator creates a new mock instance
func (*MockConfigurator) EXPECT ¶ added in v0.4.0
func (m *MockConfigurator) EXPECT() *MockConfiguratorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockConfigurator) GetCertKeyBitSize ¶ added in v0.10.0
func (m *MockConfigurator) GetCertKeyBitSize() int
GetCertKeyBitSize mocks base method
func (*MockConfigurator) GetConfigResyncInterval ¶ added in v0.8.1
func (m *MockConfigurator) GetConfigResyncInterval() time.Duration
GetConfigResyncInterval mocks base method
func (*MockConfigurator) GetEnvoyImage ¶ added in v0.9.0
func (m *MockConfigurator) GetEnvoyImage() string
GetEnvoyImage mocks base method
func (*MockConfigurator) GetEnvoyLogLevel ¶ added in v0.4.0
func (m *MockConfigurator) GetEnvoyLogLevel() string
GetEnvoyLogLevel mocks base method
func (*MockConfigurator) GetEnvoyWindowsImage ¶ added in v0.10.0
func (m *MockConfigurator) GetEnvoyWindowsImage() string
GetEnvoyWindowsImage mocks base method
func (*MockConfigurator) GetFeatureFlags ¶ added in v0.9.1
func (m *MockConfigurator) GetFeatureFlags() v1alpha1.FeatureFlags
GetFeatureFlags mocks base method
func (*MockConfigurator) GetInboundExternalAuthConfig ¶ added in v0.8.4
func (m *MockConfigurator) GetInboundExternalAuthConfig() auth.ExtAuthConfig
GetInboundExternalAuthConfig mocks base method
func (*MockConfigurator) GetInboundPortExclusionList ¶ added in v0.9.1
func (m *MockConfigurator) GetInboundPortExclusionList() []int
GetInboundPortExclusionList mocks base method
func (*MockConfigurator) GetInitContainerImage ¶ added in v0.9.0
func (m *MockConfigurator) GetInitContainerImage() string
GetInitContainerImage mocks base method
func (*MockConfigurator) GetMaxDataPlaneConnections ¶ added in v0.9.0
func (m *MockConfigurator) GetMaxDataPlaneConnections() int
GetMaxDataPlaneConnections mocks base method
func (*MockConfigurator) GetMeshConfig ¶ added in v0.10.0
func (m *MockConfigurator) GetMeshConfig() *v1alpha1.MeshConfig
GetMeshConfig mocks base method
func (*MockConfigurator) GetMeshConfigJSON ¶ added in v0.9.0
func (m *MockConfigurator) GetMeshConfigJSON() (string, error)
GetMeshConfigJSON mocks base method
func (*MockConfigurator) GetOSMLogLevel ¶ added in v0.9.1
func (m *MockConfigurator) GetOSMLogLevel() string
GetOSMLogLevel mocks base method
func (*MockConfigurator) GetOSMNamespace ¶ added in v0.4.0
func (m *MockConfigurator) GetOSMNamespace() string
GetOSMNamespace mocks base method
func (*MockConfigurator) GetOutboundIPRangeExclusionList ¶ added in v0.7.0
func (m *MockConfigurator) GetOutboundIPRangeExclusionList() []string
GetOutboundIPRangeExclusionList mocks base method
func (*MockConfigurator) GetOutboundPortExclusionList ¶ added in v0.9.0
func (m *MockConfigurator) GetOutboundPortExclusionList() []int
GetOutboundPortExclusionList mocks base method
func (*MockConfigurator) GetProxyResources ¶ added in v0.9.0
func (m *MockConfigurator) GetProxyResources() v1.ResourceRequirements
GetProxyResources mocks base method
func (*MockConfigurator) GetServiceCertValidityPeriod ¶ added in v0.4.2
func (m *MockConfigurator) GetServiceCertValidityPeriod() time.Duration
GetServiceCertValidityPeriod mocks base method
func (*MockConfigurator) GetTracingEndpoint ¶ added in v0.4.0
func (m *MockConfigurator) GetTracingEndpoint() string
GetTracingEndpoint mocks base method
func (*MockConfigurator) GetTracingHost ¶ added in v0.4.0
func (m *MockConfigurator) GetTracingHost() string
GetTracingHost mocks base method
func (*MockConfigurator) GetTracingPort ¶ added in v0.4.0
func (m *MockConfigurator) GetTracingPort() uint32
GetTracingPort mocks base method
func (*MockConfigurator) IsDebugServerEnabled ¶ added in v0.4.2
func (m *MockConfigurator) IsDebugServerEnabled() bool
IsDebugServerEnabled mocks base method
func (*MockConfigurator) IsEgressEnabled ¶ added in v0.4.0
func (m *MockConfigurator) IsEgressEnabled() bool
IsEgressEnabled mocks base method
func (*MockConfigurator) IsPermissiveTrafficPolicyMode ¶ added in v0.4.0
func (m *MockConfigurator) IsPermissiveTrafficPolicyMode() bool
IsPermissiveTrafficPolicyMode mocks base method
func (*MockConfigurator) IsPrivilegedInitContainer ¶ added in v0.8.0
func (m *MockConfigurator) IsPrivilegedInitContainer() bool
IsPrivilegedInitContainer mocks base method
func (*MockConfigurator) IsTracingEnabled ¶ added in v0.4.0
func (m *MockConfigurator) IsTracingEnabled() bool
IsTracingEnabled mocks base method
func (*MockConfigurator) UseHTTPSIngress ¶ added in v0.4.0
func (m *MockConfigurator) UseHTTPSIngress() bool
UseHTTPSIngress mocks base method
type MockConfiguratorMockRecorder ¶ added in v0.4.0
type MockConfiguratorMockRecorder struct {
// contains filtered or unexported fields
}
MockConfiguratorMockRecorder is the mock recorder for MockConfigurator
func (*MockConfiguratorMockRecorder) GetCertKeyBitSize ¶ added in v0.10.0
func (mr *MockConfiguratorMockRecorder) GetCertKeyBitSize() *gomock.Call
GetCertKeyBitSize indicates an expected call of GetCertKeyBitSize
func (*MockConfiguratorMockRecorder) GetConfigResyncInterval ¶ added in v0.8.1
func (mr *MockConfiguratorMockRecorder) GetConfigResyncInterval() *gomock.Call
GetConfigResyncInterval indicates an expected call of GetConfigResyncInterval
func (*MockConfiguratorMockRecorder) GetEnvoyImage ¶ added in v0.9.0
func (mr *MockConfiguratorMockRecorder) GetEnvoyImage() *gomock.Call
GetEnvoyImage indicates an expected call of GetEnvoyImage
func (*MockConfiguratorMockRecorder) GetEnvoyLogLevel ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) GetEnvoyLogLevel() *gomock.Call
GetEnvoyLogLevel indicates an expected call of GetEnvoyLogLevel
func (*MockConfiguratorMockRecorder) GetEnvoyWindowsImage ¶ added in v0.10.0
func (mr *MockConfiguratorMockRecorder) GetEnvoyWindowsImage() *gomock.Call
GetEnvoyWindowsImage indicates an expected call of GetEnvoyWindowsImage
func (*MockConfiguratorMockRecorder) GetFeatureFlags ¶ added in v0.9.1
func (mr *MockConfiguratorMockRecorder) GetFeatureFlags() *gomock.Call
GetFeatureFlags indicates an expected call of GetFeatureFlags
func (*MockConfiguratorMockRecorder) GetInboundExternalAuthConfig ¶ added in v0.8.4
func (mr *MockConfiguratorMockRecorder) GetInboundExternalAuthConfig() *gomock.Call
GetInboundExternalAuthConfig indicates an expected call of GetInboundExternalAuthConfig
func (*MockConfiguratorMockRecorder) GetInboundPortExclusionList ¶ added in v0.9.1
func (mr *MockConfiguratorMockRecorder) GetInboundPortExclusionList() *gomock.Call
GetInboundPortExclusionList indicates an expected call of GetInboundPortExclusionList
func (*MockConfiguratorMockRecorder) GetInitContainerImage ¶ added in v0.9.0
func (mr *MockConfiguratorMockRecorder) GetInitContainerImage() *gomock.Call
GetInitContainerImage indicates an expected call of GetInitContainerImage
func (*MockConfiguratorMockRecorder) GetMaxDataPlaneConnections ¶ added in v0.9.0
func (mr *MockConfiguratorMockRecorder) GetMaxDataPlaneConnections() *gomock.Call
GetMaxDataPlaneConnections indicates an expected call of GetMaxDataPlaneConnections
func (*MockConfiguratorMockRecorder) GetMeshConfig ¶ added in v0.10.0
func (mr *MockConfiguratorMockRecorder) GetMeshConfig() *gomock.Call
GetMeshConfig indicates an expected call of GetMeshConfig
func (*MockConfiguratorMockRecorder) GetMeshConfigJSON ¶ added in v0.9.0
func (mr *MockConfiguratorMockRecorder) GetMeshConfigJSON() *gomock.Call
GetMeshConfigJSON indicates an expected call of GetMeshConfigJSON
func (*MockConfiguratorMockRecorder) GetOSMLogLevel ¶ added in v0.9.1
func (mr *MockConfiguratorMockRecorder) GetOSMLogLevel() *gomock.Call
GetOSMLogLevel indicates an expected call of GetOSMLogLevel
func (*MockConfiguratorMockRecorder) GetOSMNamespace ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) GetOSMNamespace() *gomock.Call
GetOSMNamespace indicates an expected call of GetOSMNamespace
func (*MockConfiguratorMockRecorder) GetOutboundIPRangeExclusionList ¶ added in v0.7.0
func (mr *MockConfiguratorMockRecorder) GetOutboundIPRangeExclusionList() *gomock.Call
GetOutboundIPRangeExclusionList indicates an expected call of GetOutboundIPRangeExclusionList
func (*MockConfiguratorMockRecorder) GetOutboundPortExclusionList ¶ added in v0.9.0
func (mr *MockConfiguratorMockRecorder) GetOutboundPortExclusionList() *gomock.Call
GetOutboundPortExclusionList indicates an expected call of GetOutboundPortExclusionList
func (*MockConfiguratorMockRecorder) GetProxyResources ¶ added in v0.9.0
func (mr *MockConfiguratorMockRecorder) GetProxyResources() *gomock.Call
GetProxyResources indicates an expected call of GetProxyResources
func (*MockConfiguratorMockRecorder) GetServiceCertValidityPeriod ¶ added in v0.4.2
func (mr *MockConfiguratorMockRecorder) GetServiceCertValidityPeriod() *gomock.Call
GetServiceCertValidityPeriod indicates an expected call of GetServiceCertValidityPeriod
func (*MockConfiguratorMockRecorder) GetTracingEndpoint ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) GetTracingEndpoint() *gomock.Call
GetTracingEndpoint indicates an expected call of GetTracingEndpoint
func (*MockConfiguratorMockRecorder) GetTracingHost ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) GetTracingHost() *gomock.Call
GetTracingHost indicates an expected call of GetTracingHost
func (*MockConfiguratorMockRecorder) GetTracingPort ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) GetTracingPort() *gomock.Call
GetTracingPort indicates an expected call of GetTracingPort
func (*MockConfiguratorMockRecorder) IsDebugServerEnabled ¶ added in v0.4.2
func (mr *MockConfiguratorMockRecorder) IsDebugServerEnabled() *gomock.Call
IsDebugServerEnabled indicates an expected call of IsDebugServerEnabled
func (*MockConfiguratorMockRecorder) IsEgressEnabled ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) IsEgressEnabled() *gomock.Call
IsEgressEnabled indicates an expected call of IsEgressEnabled
func (*MockConfiguratorMockRecorder) IsPermissiveTrafficPolicyMode ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) IsPermissiveTrafficPolicyMode() *gomock.Call
IsPermissiveTrafficPolicyMode indicates an expected call of IsPermissiveTrafficPolicyMode
func (*MockConfiguratorMockRecorder) IsPrivilegedInitContainer ¶ added in v0.8.0
func (mr *MockConfiguratorMockRecorder) IsPrivilegedInitContainer() *gomock.Call
IsPrivilegedInitContainer indicates an expected call of IsPrivilegedInitContainer
func (*MockConfiguratorMockRecorder) IsTracingEnabled ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) IsTracingEnabled() *gomock.Call
IsTracingEnabled indicates an expected call of IsTracingEnabled
func (*MockConfiguratorMockRecorder) UseHTTPSIngress ¶ added in v0.4.0
func (mr *MockConfiguratorMockRecorder) UseHTTPSIngress() *gomock.Call
UseHTTPSIngress indicates an expected call of UseHTTPSIngress