test

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Jul 16, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FakeNode 

func FakeNode() *corev3.Node

Types

type FakeService 

type FakeService struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewFakeService 

func NewFakeService(addr string) (*FakeService, error)

func (*FakeService) Addr 

func (f *FakeService) Addr() net.Addr

func (*FakeService) Check 

func (f *FakeService) Check(ctx context.Context, request *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*FakeService) Host 

func (f *FakeService) Host() string

func (*FakeService) List 

func (f *FakeService) List(ctx context.Context, request *grpc_health_v1.HealthListRequest) (*grpc_health_v1.HealthListResponse, error)

func (*FakeService) Port 

func (f *FakeService) Port() int32

func (*FakeService) Stop 

func (f *FakeService) Stop()

func (*FakeService) Watch 

func (f *FakeService) Watch(request *grpc_health_v1.HealthCheckRequest, g grpc.ServerStreamingServer[grpc_health_v1.HealthCheckResponse]) error

type K8SEndpoint 

type K8SEndpoint struct {
	Name      string
	Namespace string
	IP        []string
	Ports     []corev1.EndpointPort //nolint:staticcheck // We use Endpoint to simulate legacy Kube compatibility
}

func (*K8SEndpoint) AsK8S 

func (k *K8SEndpoint) AsK8S() *corev1.Endpoints

type K8SService 

type K8SService struct {
	Name        string
	Namespace   string
	Ports       []corev1.ServicePort
	Annotations map[string]string
}

func (*K8SService) AsK8S 

func (k *K8SService) AsK8S() *corev1.Service

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.