Versions in this module Expand all Collapse all v0 v0.5.0 Jul 5, 2018 Changes in this version + const ConduitApiSubsystemName + const K8sClientCheckDescription + const K8sClientSubsystemName + const PromClientCheckDescription + const PromClientSubsystemName + func GenStatSummaryResponse(resName, resType, resNs string, counts *PodCounts) pb.StatSummaryResponse + func NewExternalClient(controlPlaneNamespace string, kubeApi k8s.KubernetesApi) (pb.ApiClient, error) + func NewInternalClient(kubernetesApiHost string) (pb.ApiClient, error) + func NewServer(addr string, prometheusClient promApi.Client, tapClient tapPb.TapClient, ...) *http.Server + type MockApi_TapByResourceClient struct + ErrorsToReturn []error + TapEventsToReturn []common.TapEvent + func (a *MockApi_TapByResourceClient) Recv() (*common.TapEvent, error) + type MockApi_TapClient struct + ErrorsToReturn []error + TapEventsToReturn []common.TapEvent + func (a *MockApi_TapClient) Recv() (*common.TapEvent, error) + type MockConduitApiClient struct + Api_TapByResourceClientToReturn pb.Api_TapByResourceClient + Api_TapClientToReturn pb.Api_TapClient + ErrorToReturn error + ListPodsResponseToReturn *pb.ListPodsResponse + SelfCheckResponseToReturn *healthcheckPb.SelfCheckResponse + StatSummaryResponseToReturn *pb.StatSummaryResponse + VersionInfoToReturn *pb.VersionInfo + func (c *MockConduitApiClient) ListPods(ctx context.Context, in *pb.ListPodsRequest, opts ...grpc.CallOption) (*pb.ListPodsResponse, error) + func (c *MockConduitApiClient) SelfCheck(ctx context.Context, in *healthcheckPb.SelfCheckRequest, _ ...grpc.CallOption) (*healthcheckPb.SelfCheckResponse, error) + func (c *MockConduitApiClient) StatSummary(ctx context.Context, in *pb.StatSummaryRequest, opts ...grpc.CallOption) (*pb.StatSummaryResponse, error) + func (c *MockConduitApiClient) Tap(ctx context.Context, in *pb.TapRequest, opts ...grpc.CallOption) (pb.Api_TapClient, error) + func (c *MockConduitApiClient) TapByResource(ctx context.Context, in *pb.TapByResourceRequest, opts ...grpc.CallOption) (pb.Api_TapByResourceClient, error) + func (c *MockConduitApiClient) Version(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.VersionInfo, error) + type MockProm struct + QueriesExecuted []string + Res model.Value + func (m *MockProm) LabelValues(ctx context.Context, label string) (model.LabelValues, error) + func (m *MockProm) Query(ctx context.Context, query string, ts time.Time) (model.Value, error) + func (m *MockProm) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, error) + func (m *MockProm) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, error) + type PodCounts struct + FailedPods uint64 + MeshedPods uint64 + RunningPods uint64 Incompatible versions in this module v18.9.1+incompatible Sep 12, 2018