public

Documentation

Index

• Constants
• func NewExternalClient(controlPlaneNamespace string, kubeApi k8s.KubernetesApi) (pb.ApiClient, error)
• func NewInternalClient(kubernetesApiHost string) (pb.ApiClient, error)
• func NewServer(addr string, telemetryClient telemPb.TelemetryClient, ...) *http.Server
• type MockApi_TapClient
  • func (a *MockApi_TapClient) Recv() (*common.TapEvent, error)
• type MockConduitApiClient
  • func (c *MockConduitApiClient) ListPods(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.ListPodsResponse, error)
  • func (c *MockConduitApiClient) SelfCheck(ctx context.Context, in *healthcheckPb.SelfCheckRequest, _ ...grpc.CallOption) (*healthcheckPb.SelfCheckResponse, error)
  • func (c *MockConduitApiClient) Stat(ctx context.Context, in *pb.MetricRequest, opts ...grpc.CallOption) (*pb.MetricResponse, error)
  • func (c *MockConduitApiClient) Tap(ctx context.Context, in *pb.TapRequest, opts ...grpc.CallOption) (pb.Api_TapClient, error)
  • func (c *MockConduitApiClient) Version(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.VersionInfo, error)

Constants

const (
	ApiRoot                 = "/" // Must be absolute (with a leading slash).
	ApiVersion              = "v1"
	JsonContentType         = "application/json"
	ApiPrefix               = "api/" + ApiVersion + "/" // Must be relative (without a leading slash).
	ProtobufContentType     = "application/octet-stream"
	ErrorHeader             = "conduit-error"
	ConduitApiSubsystemName = "conduit-api"
)

const (
	TelemetryClientSubsystemName    = "telemetry"
	TelemetryClientCheckDescription = "control plane can use telemetry service"
)

Functions

func NewExternalClient

func NewExternalClient(controlPlaneNamespace string, kubeApi k8s.KubernetesApi) (pb.ApiClient, error)

func NewInternalClient

func NewInternalClient(kubernetesApiHost string) (pb.ApiClient, error)

func NewServer

func NewServer(addr string, telemetryClient telemPb.TelemetryClient, tapClient tapPb.TapClient) *http.Server

Types

type MockApi_TapClient

type MockApi_TapClient struct {
	TapEventsToReturn []common.TapEvent
	ErrorsToReturn    []error
	grpc.ClientStream
}

func (*MockApi_TapClient) Recv

func (a *MockApi_TapClient) Recv() (*common.TapEvent, error)

type MockConduitApiClient

type MockConduitApiClient struct {
	ErrorToReturn             error
	VersionInfoToReturn       *pb.VersionInfo
	ListPodsResponseToReturn  *pb.ListPodsResponse
	MetricResponseToReturn    *pb.MetricResponse
	SelfCheckResponseToReturn *healthcheckPb.SelfCheckResponse
	Api_TapClientToReturn     pb.Api_TapClient
}

func (*MockConduitApiClient) ListPods

func (c *MockConduitApiClient) ListPods(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.ListPodsResponse, error)

func (*MockConduitApiClient) SelfCheck

func (c *MockConduitApiClient) SelfCheck(ctx context.Context, in *healthcheckPb.SelfCheckRequest, _ ...grpc.CallOption) (*healthcheckPb.SelfCheckResponse, error)

func (*MockConduitApiClient) Stat

func (c *MockConduitApiClient) Stat(ctx context.Context, in *pb.MetricRequest, opts ...grpc.CallOption) (*pb.MetricResponse, error)

func (*MockConduitApiClient) Tap

func (c *MockConduitApiClient) Tap(ctx context.Context, in *pb.TapRequest, opts ...grpc.CallOption) (pb.Api_TapClient, error)

func (*MockConduitApiClient) Version

func (c *MockConduitApiClient) Version(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.VersionInfo, error)