Versions in this module Expand all Collapse all v0 v0.5.0 Jul 5, 2018 Changes in this version + func RegisterApiServer(s *grpc.Server, srv ApiServer) + type ApiClient interface + ListPods func(ctx context.Context, in *ListPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error) + SelfCheck func(ctx context.Context, in *conduit_common_healthcheck.SelfCheckRequest, ...) (*conduit_common_healthcheck.SelfCheckResponse, error) + StatSummary func(ctx context.Context, in *StatSummaryRequest, opts ...grpc.CallOption) (*StatSummaryResponse, error) + Tap func(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Api_TapClient, error) + TapByResource func(ctx context.Context, in *TapByResourceRequest, opts ...grpc.CallOption) (Api_TapByResourceClient, error) + Version func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionInfo, error) + func NewApiClient(cc *grpc.ClientConn) ApiClient + type ApiError struct + Error string + func (*ApiError) Descriptor() ([]byte, []int) + func (*ApiError) ProtoMessage() + func (m *ApiError) GetError() string + func (m *ApiError) Reset() + func (m *ApiError) String() string + type ApiServer interface + ListPods func(context.Context, *ListPodsRequest) (*ListPodsResponse, error) + SelfCheck func(context.Context, *conduit_common_healthcheck.SelfCheckRequest) (*conduit_common_healthcheck.SelfCheckResponse, error) + StatSummary func(context.Context, *StatSummaryRequest) (*StatSummaryResponse, error) + Tap func(*TapRequest, Api_TapServer) error + TapByResource func(*TapByResourceRequest, Api_TapByResourceServer) error + Version func(context.Context, *Empty) (*VersionInfo, error) + type Api_TapByResourceClient interface + Recv func() (*conduit_common.TapEvent, error) + type Api_TapByResourceServer interface + Send func(*conduit_common.TapEvent) error + type Api_TapClient interface + Recv func() (*conduit_common.TapEvent, error) + type Api_TapServer interface + Send func(*conduit_common.TapEvent) error + type BasicStats struct + FailureCount uint64 + LatencyMsP50 uint64 + LatencyMsP95 uint64 + LatencyMsP99 uint64 + SuccessCount uint64 + TlsRequestCount uint64 + func (*BasicStats) Descriptor() ([]byte, []int) + func (*BasicStats) ProtoMessage() + func (m *BasicStats) GetFailureCount() uint64 + func (m *BasicStats) GetLatencyMsP50() uint64 + func (m *BasicStats) GetLatencyMsP95() uint64 + func (m *BasicStats) GetLatencyMsP99() uint64 + func (m *BasicStats) GetSuccessCount() uint64 + func (m *BasicStats) GetTlsRequestCount() uint64 + func (m *BasicStats) Reset() + func (m *BasicStats) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + type ListPodsRequest struct + Namespace string + func (*ListPodsRequest) Descriptor() ([]byte, []int) + func (*ListPodsRequest) ProtoMessage() + func (m *ListPodsRequest) GetNamespace() string + func (m *ListPodsRequest) Reset() + func (m *ListPodsRequest) String() string + type ListPodsResponse struct + Pods []*Pod + func (*ListPodsResponse) Descriptor() ([]byte, []int) + func (*ListPodsResponse) ProtoMessage() + func (m *ListPodsResponse) GetPods() []*Pod + func (m *ListPodsResponse) Reset() + func (m *ListPodsResponse) String() string + type Pod struct + Added bool + ControlPlane bool + ControllerNamespace string + Deployment string + Name string + PodIP string + SinceLastReport *google_protobuf.Duration + Status string + Uptime *google_protobuf.Duration + func (*Pod) Descriptor() ([]byte, []int) + func (*Pod) ProtoMessage() + func (m *Pod) GetAdded() bool + func (m *Pod) GetControlPlane() bool + func (m *Pod) GetControllerNamespace() string + func (m *Pod) GetDeployment() string + func (m *Pod) GetName() string + func (m *Pod) GetPodIP() string + func (m *Pod) GetSinceLastReport() *google_protobuf.Duration + func (m *Pod) GetStatus() string + func (m *Pod) GetUptime() *google_protobuf.Duration + func (m *Pod) Reset() + func (m *Pod) String() string + type PodErrors struct + Errors []*PodErrors_PodError + func (*PodErrors) Descriptor() ([]byte, []int) + func (*PodErrors) ProtoMessage() + func (m *PodErrors) GetErrors() []*PodErrors_PodError + func (m *PodErrors) Reset() + func (m *PodErrors) String() string + type PodErrors_PodError struct + Error isPodErrors_PodError_Error + func (*PodErrors_PodError) Descriptor() ([]byte, []int) + func (*PodErrors_PodError) ProtoMessage() + func (*PodErrors_PodError) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *PodErrors_PodError) GetContainer() *PodErrors_PodError_ContainerError + func (m *PodErrors_PodError) GetError() isPodErrors_PodError_Error + func (m *PodErrors_PodError) Reset() + func (m *PodErrors_PodError) String() string + type PodErrors_PodError_Container struct + Container *PodErrors_PodError_ContainerError + type PodErrors_PodError_ContainerError struct + Container string + Image string + Message string + Reason string + func (*PodErrors_PodError_ContainerError) Descriptor() ([]byte, []int) + func (*PodErrors_PodError_ContainerError) ProtoMessage() + func (m *PodErrors_PodError_ContainerError) GetContainer() string + func (m *PodErrors_PodError_ContainerError) GetImage() string + func (m *PodErrors_PodError_ContainerError) GetMessage() string + func (m *PodErrors_PodError_ContainerError) GetReason() string + func (m *PodErrors_PodError_ContainerError) Reset() + func (m *PodErrors_PodError_ContainerError) String() string + type Resource struct + Name string + Namespace string + Type string + func (*Resource) Descriptor() ([]byte, []int) + func (*Resource) ProtoMessage() + func (m *Resource) GetName() string + func (m *Resource) GetNamespace() string + func (m *Resource) GetType() string + func (m *Resource) Reset() + func (m *Resource) String() string + type ResourceError struct + Error string + Resource *Resource + func (*ResourceError) Descriptor() ([]byte, []int) + func (*ResourceError) ProtoMessage() + func (m *ResourceError) GetError() string + func (m *ResourceError) GetResource() *Resource + func (m *ResourceError) Reset() + func (m *ResourceError) String() string + type ResourceSelection struct + LabelSelector string + Resource *Resource + func (*ResourceSelection) Descriptor() ([]byte, []int) + func (*ResourceSelection) ProtoMessage() + func (m *ResourceSelection) GetLabelSelector() string + func (m *ResourceSelection) GetResource() *Resource + func (m *ResourceSelection) Reset() + func (m *ResourceSelection) String() string + type StatSummaryRequest struct + Outbound isStatSummaryRequest_Outbound + Selector *ResourceSelection + TimeWindow string + func (*StatSummaryRequest) Descriptor() ([]byte, []int) + func (*StatSummaryRequest) ProtoMessage() + func (*StatSummaryRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *StatSummaryRequest) GetFromResource() *Resource + func (m *StatSummaryRequest) GetNone() *Empty + func (m *StatSummaryRequest) GetOutbound() isStatSummaryRequest_Outbound + func (m *StatSummaryRequest) GetSelector() *ResourceSelection + func (m *StatSummaryRequest) GetTimeWindow() string + func (m *StatSummaryRequest) GetToResource() *Resource + func (m *StatSummaryRequest) Reset() + func (m *StatSummaryRequest) String() string + type StatSummaryRequest_FromResource struct + FromResource *Resource + type StatSummaryRequest_None struct + None *Empty + type StatSummaryRequest_ToResource struct + ToResource *Resource + type StatSummaryResponse struct + Response isStatSummaryResponse_Response + func (*StatSummaryResponse) Descriptor() ([]byte, []int) + func (*StatSummaryResponse) ProtoMessage() + func (*StatSummaryResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *StatSummaryResponse) GetError() *ResourceError + func (m *StatSummaryResponse) GetOk() *StatSummaryResponse_Ok + func (m *StatSummaryResponse) GetResponse() isStatSummaryResponse_Response + func (m *StatSummaryResponse) Reset() + func (m *StatSummaryResponse) String() string + type StatSummaryResponse_Error struct + Error *ResourceError + type StatSummaryResponse_Ok struct + StatTables []*StatTable + func (*StatSummaryResponse_Ok) Descriptor() ([]byte, []int) + func (*StatSummaryResponse_Ok) ProtoMessage() + func (m *StatSummaryResponse_Ok) GetStatTables() []*StatTable + func (m *StatSummaryResponse_Ok) Reset() + func (m *StatSummaryResponse_Ok) String() string + type StatSummaryResponse_Ok_ struct + Ok *StatSummaryResponse_Ok + type StatTable struct + Table isStatTable_Table + func (*StatTable) Descriptor() ([]byte, []int) + func (*StatTable) ProtoMessage() + func (*StatTable) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *StatTable) GetPodGroup() *StatTable_PodGroup + func (m *StatTable) GetTable() isStatTable_Table + func (m *StatTable) Reset() + func (m *StatTable) String() string + type StatTable_PodGroup struct + Rows []*StatTable_PodGroup_Row + func (*StatTable_PodGroup) Descriptor() ([]byte, []int) + func (*StatTable_PodGroup) ProtoMessage() + func (m *StatTable_PodGroup) GetRows() []*StatTable_PodGroup_Row + func (m *StatTable_PodGroup) Reset() + func (m *StatTable_PodGroup) String() string + type StatTable_PodGroup_ struct + PodGroup *StatTable_PodGroup + type StatTable_PodGroup_Row struct + ErrorsByPod map[string]*PodErrors + FailedPodCount uint64 + MeshedPodCount uint64 + Resource *Resource + RunningPodCount uint64 + Stats *BasicStats + TimeWindow string + func (*StatTable_PodGroup_Row) Descriptor() ([]byte, []int) + func (*StatTable_PodGroup_Row) ProtoMessage() + func (m *StatTable_PodGroup_Row) GetErrorsByPod() map[string]*PodErrors + func (m *StatTable_PodGroup_Row) GetFailedPodCount() uint64 + func (m *StatTable_PodGroup_Row) GetMeshedPodCount() uint64 + func (m *StatTable_PodGroup_Row) GetResource() *Resource + func (m *StatTable_PodGroup_Row) GetRunningPodCount() uint64 + func (m *StatTable_PodGroup_Row) GetStats() *BasicStats + func (m *StatTable_PodGroup_Row) GetTimeWindow() string + func (m *StatTable_PodGroup_Row) Reset() + func (m *StatTable_PodGroup_Row) String() string + type TapByResourceRequest struct + Match *TapByResourceRequest_Match + MaxRps float32 + Target *ResourceSelection + func (*TapByResourceRequest) Descriptor() ([]byte, []int) + func (*TapByResourceRequest) ProtoMessage() + func (m *TapByResourceRequest) GetMatch() *TapByResourceRequest_Match + func (m *TapByResourceRequest) GetMaxRps() float32 + func (m *TapByResourceRequest) GetTarget() *ResourceSelection + func (m *TapByResourceRequest) Reset() + func (m *TapByResourceRequest) String() string + type TapByResourceRequest_Match struct + Match isTapByResourceRequest_Match_Match + func (*TapByResourceRequest_Match) Descriptor() ([]byte, []int) + func (*TapByResourceRequest_Match) ProtoMessage() + func (*TapByResourceRequest_Match) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *TapByResourceRequest_Match) GetAll() *TapByResourceRequest_Match_Seq + func (m *TapByResourceRequest_Match) GetAny() *TapByResourceRequest_Match_Seq + func (m *TapByResourceRequest_Match) GetDestinations() *ResourceSelection + func (m *TapByResourceRequest_Match) GetHttp() *TapByResourceRequest_Match_Http + func (m *TapByResourceRequest_Match) GetMatch() isTapByResourceRequest_Match_Match + func (m *TapByResourceRequest_Match) GetNot() *TapByResourceRequest_Match + func (m *TapByResourceRequest_Match) Reset() + func (m *TapByResourceRequest_Match) String() string + type TapByResourceRequest_Match_All struct + All *TapByResourceRequest_Match_Seq + type TapByResourceRequest_Match_Any struct + Any *TapByResourceRequest_Match_Seq + type TapByResourceRequest_Match_Destinations struct + Destinations *ResourceSelection + type TapByResourceRequest_Match_Http struct + Match isTapByResourceRequest_Match_Http_Match + func (*TapByResourceRequest_Match_Http) Descriptor() ([]byte, []int) + func (*TapByResourceRequest_Match_Http) ProtoMessage() + func (*TapByResourceRequest_Match_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *TapByResourceRequest_Match_Http) GetAuthority() string + func (m *TapByResourceRequest_Match_Http) GetMatch() isTapByResourceRequest_Match_Http_Match + func (m *TapByResourceRequest_Match_Http) GetMethod() string + func (m *TapByResourceRequest_Match_Http) GetPath() string + func (m *TapByResourceRequest_Match_Http) GetScheme() string + func (m *TapByResourceRequest_Match_Http) Reset() + func (m *TapByResourceRequest_Match_Http) String() string + type TapByResourceRequest_Match_Http_ struct + Http *TapByResourceRequest_Match_Http + type TapByResourceRequest_Match_Http_Authority struct + Authority string + type TapByResourceRequest_Match_Http_Method struct + Method string + type TapByResourceRequest_Match_Http_Path struct + Path string + type TapByResourceRequest_Match_Http_Scheme struct + Scheme string + type TapByResourceRequest_Match_Not struct + Not *TapByResourceRequest_Match + type TapByResourceRequest_Match_Seq struct + Matches []*TapByResourceRequest_Match + func (*TapByResourceRequest_Match_Seq) Descriptor() ([]byte, []int) + func (*TapByResourceRequest_Match_Seq) ProtoMessage() + func (m *TapByResourceRequest_Match_Seq) GetMatches() []*TapByResourceRequest_Match + func (m *TapByResourceRequest_Match_Seq) Reset() + func (m *TapByResourceRequest_Match_Seq) String() string + type TapRequest struct + Authority string + FromIP string + FromPort uint32 + MaxRps float32 + Method string + Path string + Scheme string + Target isTapRequest_Target + ToIP string + ToPort uint32 + func (*TapRequest) Descriptor() ([]byte, []int) + func (*TapRequest) ProtoMessage() + func (*TapRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *TapRequest) GetAuthority() string + func (m *TapRequest) GetDeployment() string + func (m *TapRequest) GetFromIP() string + func (m *TapRequest) GetFromPort() uint32 + func (m *TapRequest) GetMaxRps() float32 + func (m *TapRequest) GetMethod() string + func (m *TapRequest) GetPath() string + func (m *TapRequest) GetPod() string + func (m *TapRequest) GetScheme() string + func (m *TapRequest) GetTarget() isTapRequest_Target + func (m *TapRequest) GetToIP() string + func (m *TapRequest) GetToPort() uint32 + func (m *TapRequest) Reset() + func (m *TapRequest) String() string + type TapRequest_Deployment struct + Deployment string + type TapRequest_Pod struct + Pod string + type VersionInfo struct + BuildDate string + GoVersion string + ReleaseVersion string + func (*VersionInfo) Descriptor() ([]byte, []int) + func (*VersionInfo) ProtoMessage() + func (m *VersionInfo) GetBuildDate() string + func (m *VersionInfo) GetGoVersion() string + func (m *VersionInfo) GetReleaseVersion() string + func (m *VersionInfo) Reset() + func (m *VersionInfo) String() string
Go to main page