public

package
v18.7.2+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 24, 2018 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source
const (
	K8sClientSubsystemName     = "kubernetes"
	K8sClientCheckDescription  = "control plane can talk to Kubernetes"
	PromClientSubsystemName    = "prometheus"
	PromClientCheckDescription = "control plane can talk to Prometheus"
)
View Source
const (
	ApiSubsystemName = "linkerd-api"
)

Variables

This section is empty.

Functions

func GenStatSummaryResponse added in v0.5.0

func GenStatSummaryResponse(resName, resType, resNs string, counts *PodCounts) pb.StatSummaryResponse

func NewExternalClient added in v0.1.2

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

func NewInternalClient added in v0.1.2

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

func NewServer

func NewServer(
	addr string,
	prometheusClient promApi.Client,
	tapClient tapPb.TapClient,
	k8sAPI *k8s.API,
	controllerNamespace string,
	ignoredNamespaces []string,
) *http.Server

Types

type MockApiClient

type MockApiClient struct {
	ErrorToReturn                   error
	VersionInfoToReturn             *pb.VersionInfo
	ListPodsResponseToReturn        *pb.ListPodsResponse
	StatSummaryResponseToReturn     *pb.StatSummaryResponse
	SelfCheckResponseToReturn       *healthcheckPb.SelfCheckResponse
	Api_TapClientToReturn           pb.Api_TapClient
	Api_TapByResourceClientToReturn pb.Api_TapByResourceClient
}

func (*MockApiClient) ListPods

func (*MockApiClient) StatSummary

func (*MockApiClient) Tap

func (*MockApiClient) TapByResource

func (*MockApiClient) Version

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

type MockApi_TapByResourceClient added in v0.4.1

type MockApi_TapByResourceClient struct {
	TapEventsToReturn []pb.TapEvent
	ErrorsToReturn    []error
	grpc.ClientStream
}

func (*MockApi_TapByResourceClient) Recv added in v0.4.1

type MockApi_TapClient added in v0.1.2

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

func (*MockApi_TapClient) Recv added in v0.1.2

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

type MockProm added in v0.4.0

type MockProm struct {
	Res             model.Value
	QueriesExecuted []string // expose the queries our Mock Prometheus receives, to test query generation
	// contains filtered or unexported fields
}

func (*MockProm) LabelValues added in v0.4.0

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

func (*MockProm) Query added in v0.4.0

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

satisfies v1.API

func (*MockProm) QueryRange added in v0.4.0

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

func (*MockProm) Series added in v0.4.0

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

type PodCounts added in v0.5.0

type PodCounts struct {
	MeshedPods  uint64
	RunningPods uint64
	FailedPods  uint64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL