smi

package
v1.1.4 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package smi is a generated GoMock package.

Package smi implements the Service Mesh Interface (SMI) kubernetes client to observe and retrieve information regarding SMI traffic resources.

Index

Constants

View Source 
const (
	// ServiceAccountKind is the kind specified for the destination and sources in an SMI TrafficTarget policy
	ServiceAccountKind = "ServiceAccount"

	// TCPRouteKind is the kind specified for the TCP route rules in an SMI Traffictarget policy
	TCPRouteKind = "TCPRoute"

	// HTTPRouteGroupKind is the kind specified for the HTTP route rules in an SMI Traffictarget policy
	HTTPRouteGroupKind = "HTTPRouteGroup"
)

Variables

This section is empty.

Functions

func GetSmiClientVersionHTTPHandler added in v0.9.0 

func GetSmiClientVersionHTTPHandler() http.Handler

GetSmiClientVersionHTTPHandler returns an http handler that returns supported smi version information

Types

type HealthChecker added in v0.9.0 

type HealthChecker struct {
	DiscoveryClient discovery.ServerResourcesInterface
}

HealthChecker has SMI clientset interface to access SMI CRDS

func (HealthChecker) GetID added in v0.9.0 

func (c HealthChecker) GetID() string

GetID returns the ID of the probe

func (HealthChecker) Liveness added in v0.9.0 

func (c HealthChecker) Liveness() bool

Liveness is the Kubernetes liveness probe handler.

func (HealthChecker) Readiness added in v0.9.0 

func (c HealthChecker) Readiness() bool

Readiness is the Kubernetes readiness probe handler.

type MeshSpec 

type MeshSpec interface {
	// ListTrafficSplits lists SMI TrafficSplit resources
	ListTrafficSplits(...TrafficSplitListOption) []*split.TrafficSplit

	// ListServiceAccounts lists ServiceAccount resources specified in SMI TrafficTarget resources
	ListServiceAccounts() []identity.K8sServiceAccount

	// ListHTTPTrafficSpecs lists SMI HTTPRouteGroup resources
	ListHTTPTrafficSpecs() []*spec.HTTPRouteGroup

	// GetHTTPRouteGroup returns an SMI HTTPRouteGroup resource given its name of the form <namespace>/<name>
	GetHTTPRouteGroup(string) *spec.HTTPRouteGroup

	// ListTCPTrafficSpecs lists SMI TCPRoute resources
	ListTCPTrafficSpecs() []*spec.TCPRoute

	// GetTCPRoute returns an SMI TCPRoute resource given its name of the form <namespace>/<name>
	GetTCPRoute(string) *spec.TCPRoute

	// ListTrafficTargets lists SMI TrafficTarget resources. An optional filter can be applied to filter the
	// returned list
	ListTrafficTargets(...TrafficTargetListOption) []*access.TrafficTarget
}

MeshSpec is an interface declaring functions, which provide the specs for a service mesh declared with SMI.

func NewFakeMeshSpecClient 

func NewFakeMeshSpecClient() MeshSpec

NewFakeMeshSpecClient creates a fake Mesh Spec used for testing. TODO(DEPRECATE): This fake is not extendable enough, deprecate it and use mocks or re-implement fakes

func NewMeshSpecClient 

func NewMeshSpecClient(smiKubeConfig *rest.Config, osmNamespace string, kubeController k8s.Controller,
	stop chan struct{}, msgBroker *messaging.Broker) (MeshSpec, error)

NewMeshSpecClient implements mesh.MeshSpec and creates the Kubernetes client, which retrieves SMI specific CRDs.

type MockMeshSpec added in v0.6.0 

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

MockMeshSpec is a mock of MeshSpec interface.

func NewMockMeshSpec added in v0.6.0 

func NewMockMeshSpec(ctrl *gomock.Controller) *MockMeshSpec

NewMockMeshSpec creates a new mock instance.

func (*MockMeshSpec) EXPECT added in v0.6.0 

func (m *MockMeshSpec) EXPECT() *MockMeshSpecMockRecorder

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

func (*MockMeshSpec) GetHTTPRouteGroup added in v0.9.0 

func (m *MockMeshSpec) GetHTTPRouteGroup(arg0 string) *v1alpha4.HTTPRouteGroup

GetHTTPRouteGroup mocks base method.

func (*MockMeshSpec) GetTCPRoute added in v0.7.0 

func (m *MockMeshSpec) GetTCPRoute(arg0 string) *v1alpha4.TCPRoute

GetTCPRoute mocks base method.

func (*MockMeshSpec) ListHTTPTrafficSpecs added in v0.6.0 

func (m *MockMeshSpec) ListHTTPTrafficSpecs() []*v1alpha4.HTTPRouteGroup

ListHTTPTrafficSpecs mocks base method.

func (*MockMeshSpec) ListServiceAccounts added in v0.6.0 

func (m *MockMeshSpec) ListServiceAccounts() []identity.K8sServiceAccount

ListServiceAccounts mocks base method.

func (*MockMeshSpec) ListTCPTrafficSpecs added in v0.6.0 

func (m *MockMeshSpec) ListTCPTrafficSpecs() []*v1alpha4.TCPRoute

ListTCPTrafficSpecs mocks base method.

func (*MockMeshSpec) ListTrafficSplits added in v0.6.0 

func (m *MockMeshSpec) ListTrafficSplits(arg0 ...TrafficSplitListOption) []*v1alpha2.TrafficSplit

ListTrafficSplits mocks base method.

func (*MockMeshSpec) ListTrafficTargets added in v0.6.0 

func (m *MockMeshSpec) ListTrafficTargets(arg0 ...TrafficTargetListOption) []*v1alpha3.TrafficTarget

ListTrafficTargets mocks base method.

type MockMeshSpecMockRecorder added in v0.6.0 

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

MockMeshSpecMockRecorder is the mock recorder for MockMeshSpec.

func (*MockMeshSpecMockRecorder) GetHTTPRouteGroup added in v0.9.0 

func (mr *MockMeshSpecMockRecorder) GetHTTPRouteGroup(arg0 interface{}) *gomock.Call

GetHTTPRouteGroup indicates an expected call of GetHTTPRouteGroup.

func (*MockMeshSpecMockRecorder) GetTCPRoute added in v0.7.0 

func (mr *MockMeshSpecMockRecorder) GetTCPRoute(arg0 interface{}) *gomock.Call

GetTCPRoute indicates an expected call of GetTCPRoute.

func (*MockMeshSpecMockRecorder) ListHTTPTrafficSpecs added in v0.6.0 

func (mr *MockMeshSpecMockRecorder) ListHTTPTrafficSpecs() *gomock.Call

ListHTTPTrafficSpecs indicates an expected call of ListHTTPTrafficSpecs.

func (*MockMeshSpecMockRecorder) ListServiceAccounts added in v0.6.0 

func (mr *MockMeshSpecMockRecorder) ListServiceAccounts() *gomock.Call

ListServiceAccounts indicates an expected call of ListServiceAccounts.

func (*MockMeshSpecMockRecorder) ListTCPTrafficSpecs added in v0.6.0 

func (mr *MockMeshSpecMockRecorder) ListTCPTrafficSpecs() *gomock.Call

ListTCPTrafficSpecs indicates an expected call of ListTCPTrafficSpecs.

func (*MockMeshSpecMockRecorder) ListTrafficSplits added in v0.6.0 

func (mr *MockMeshSpecMockRecorder) ListTrafficSplits(arg0 ...interface{}) *gomock.Call

ListTrafficSplits indicates an expected call of ListTrafficSplits.

func (*MockMeshSpecMockRecorder) ListTrafficTargets added in v0.6.0 

func (mr *MockMeshSpecMockRecorder) ListTrafficTargets(arg0 ...interface{}) *gomock.Call

ListTrafficTargets indicates an expected call of ListTrafficTargets.

type TrafficSplitListOpt added in v0.11.0 

type TrafficSplitListOpt struct {
	ApexService    service.MeshService
	BackendService service.MeshService
}

TrafficSplitListOpt specifies the options used to filter TrafficSplit objects as a part of its lister

type TrafficSplitListOption added in v0.11.0 

type TrafficSplitListOption func(o *TrafficSplitListOpt)

TrafficSplitListOption is a function type that implements filters on the TrafficSplit lister

func WithTrafficSplitApexService added in v0.11.0 

func WithTrafficSplitApexService(s service.MeshService) TrafficSplitListOption

WithTrafficSplitApexService applies a filter based on the apex service to the TrafficSplit lister

func WithTrafficSplitBackendService added in v0.11.0 

func WithTrafficSplitBackendService(s service.MeshService) TrafficSplitListOption

WithTrafficSplitBackendService applies a filter based on the backend service to the TrafficSplit lister

type TrafficTargetListOpt added in v0.11.0 

type TrafficTargetListOpt struct {
	Destination identity.K8sServiceAccount
}

TrafficTargetListOpt specifies the options used to filter TrafficTarget objects as a part of its lister

type TrafficTargetListOption added in v0.11.0 

type TrafficTargetListOption func(o *TrafficTargetListOpt)

TrafficTargetListOption is a function type that implements filters on TrafficTarget lister

func WithTrafficTargetDestination added in v0.11.0 

func WithTrafficTargetDestination(d identity.K8sServiceAccount) TrafficTargetListOption

WithTrafficTargetDestination applies a filter based on the destination service account to the TrafficTarget lister

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.