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
- 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 ¶
View Source
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" )
View Source
const ( TelemetryClientSubsystemName = "telemetry" TelemetryClientCheckDescription = "control plane can use telemetry service" )
Variables ¶
This section is empty.
Functions ¶
func NewExternalClient ¶ added in v0.1.2
func NewInternalClient ¶ added in v0.1.2
Types ¶
type MockApi_TapClient ¶ added in v0.1.2
type MockApi_TapClient struct {
TapEventsToReturn []common.TapEvent
ErrorsToReturn []error
grpc.ClientStream
}
type MockConduitApiClient ¶ added in v0.1.2
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 ¶ added in v0.1.2
func (c *MockConduitApiClient) ListPods(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.ListPodsResponse, error)
func (*MockConduitApiClient) SelfCheck ¶ added in v0.1.2
func (c *MockConduitApiClient) SelfCheck(ctx context.Context, in *healthcheckPb.SelfCheckRequest, _ ...grpc.CallOption) (*healthcheckPb.SelfCheckResponse, error)
func (*MockConduitApiClient) Stat ¶ added in v0.1.2
func (c *MockConduitApiClient) Stat(ctx context.Context, in *pb.MetricRequest, opts ...grpc.CallOption) (*pb.MetricResponse, error)
func (*MockConduitApiClient) Tap ¶ added in v0.1.2
func (c *MockConduitApiClient) Tap(ctx context.Context, in *pb.TapRequest, opts ...grpc.CallOption) (pb.Api_TapClient, error)
func (*MockConduitApiClient) Version ¶ added in v0.1.2
func (c *MockConduitApiClient) Version(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.VersionInfo, error)
Source Files
Click to show internal directories.
Click to hide internal directories.