public

Apr 16, 2018

Changes in this version

+ const K8sClientCheckDescription

+ const K8sClientSubsystemName

+ const PromClientCheckDescription

+ const PromClientSubsystemName

type MockConduitApiClient

+ StatSummaryResponseToReturn *pb.StatSummaryResponse

+ func (c *MockConduitApiClient) StatSummary(ctx context.Context, in *pb.StatSummaryRequest, opts ...grpc.CallOption) (*pb.StatSummaryResponse, error)

+ type MockProm struct

+ 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)

Jan 19, 2018

Changes in this version

+ const ApiPrefix

+ const ApiRoot

+ const ApiVersion

+ const ConduitApiSubsystemName

+ const ErrorHeader

+ const JsonContentType

+ const ProtobufContentType

+ const TelemetryClientCheckDescription

+ const TelemetryClientSubsystemName

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

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

+ type MockApi_TapClient struct

+ ErrorsToReturn []error

+ TapEventsToReturn []common.TapEvent

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

+ type MockConduitApiClient struct

+ Api_TapClientToReturn pb.Api_TapClient

+ ErrorToReturn error

+ ListPodsResponseToReturn *pb.ListPodsResponse

+ MetricResponseToReturn *pb.MetricResponse

+ SelfCheckResponseToReturn *healthcheckPb.SelfCheckResponse

+ VersionInfoToReturn *pb.VersionInfo

+ 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)

Dec 5, 2017

Changes in this version

+ func NewClient(config *Config, transport http.RoundTripper) (pb.ApiClient, error)

+ func NewServer(addr string, telemetryClient telemPb.TelemetryClient, ...) *http.Server

+ type Config struct

+ ServerURL *url.URL