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, prometheusClient promApi.Client, tapClient tapPb.TapClient, ...) *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) 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) Version(ctx context.Context, in *pb.Empty, opts ...grpc.CallOption) (*pb.VersionInfo, error)
• type MockProm
  • 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)

Constants

const (
	ApiRoot                 = "/" // Must be absolute (with a leading slash).
	ApiVersion              = "v1"
	ApiPrefix               = "api/" + ApiVersion + "/" // Must be relative (without a leading slash).
	ConduitApiSubsystemName = "conduit-api"
)

const (
	K8sClientSubsystemName     = "kubernetes"
	K8sClientCheckDescription  = "control plane can talk to Kubernetes"
	PromClientSubsystemName    = "prometheus"
	PromClientCheckDescription = "control plane can talk to Prometheus"
)

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,
	prometheusClient promApi.Client,
	tapClient tapPb.TapClient,
	namespaceLister corelisters.NamespaceLister,
	deployLister applisters.DeploymentLister,
	replicaSetLister applisters.ReplicaSetLister,
	podLister corelisters.PodLister,
	controllerNamespace string,
	ignoredNamespaces []string,
) *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
	StatSummaryResponseToReturn *pb.StatSummaryResponse
	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) StatSummary

func (c *MockConduitApiClient) StatSummary(ctx context.Context, in *pb.StatSummaryRequest, opts ...grpc.CallOption) (*pb.StatSummaryResponse, 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)

type MockProm

type MockProm struct {
	Res model.Value
	// contains filtered or unexported fields
}

func (*MockProm) LabelValues

func (m *MockProm) LabelValues(ctx context.Context, label string) (model.LabelValues, error)

func (*MockProm) Query

func (m *MockProm) Query(ctx context.Context, query string, ts time.Time) (model.Value, error)

satisfies v1.API

func (*MockProm) QueryRange

func (m *MockProm) QueryRange(ctx context.Context, query string, r v1.Range) (model.Value, error)

func (*MockProm) Series

func (m *MockProm) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, error)