Documentation ¶
Overview ¶
Package conduit_public is a generated protocol buffer package.
It is generated from these files:
public/api.proto
It has these top-level messages:
Empty VersionInfo ListPodsResponse Pod TapRequest ApiError Resource ResourceSelection ResourceError StatSummaryRequest StatSummaryResponse BasicStats StatTable
Index ¶
- Variables
- func RegisterApiServer(s *grpc.Server, srv ApiServer)
- type ApiClient
- type ApiError
- type ApiServer
- type Api_TapClient
- type Api_TapServer
- type BasicStats
- func (*BasicStats) Descriptor() ([]byte, []int)
- 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 (*BasicStats) ProtoMessage()
- func (m *BasicStats) Reset()
- func (m *BasicStats) String() string
- type Empty
- type ListPodsResponse
- type Pod
- func (*Pod) Descriptor() ([]byte, []int)
- 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 (*Pod) ProtoMessage()
- func (m *Pod) Reset()
- func (m *Pod) String() string
- type Resource
- type ResourceError
- type ResourceSelection
- type StatSummaryRequest
- func (*StatSummaryRequest) Descriptor() ([]byte, []int)
- 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() TimeWindow
- func (m *StatSummaryRequest) GetToResource() *Resource
- func (*StatSummaryRequest) ProtoMessage()
- func (m *StatSummaryRequest) Reset()
- func (m *StatSummaryRequest) String() string
- func (*StatSummaryRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type StatSummaryRequest_FromResource
- type StatSummaryRequest_None
- type StatSummaryRequest_ToResource
- type StatSummaryResponse
- func (*StatSummaryResponse) Descriptor() ([]byte, []int)
- func (m *StatSummaryResponse) GetError() *ResourceError
- func (m *StatSummaryResponse) GetOk() *StatSummaryResponse_Ok
- func (m *StatSummaryResponse) GetResponse() isStatSummaryResponse_Response
- func (*StatSummaryResponse) ProtoMessage()
- func (m *StatSummaryResponse) Reset()
- func (m *StatSummaryResponse) String() string
- func (*StatSummaryResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type StatSummaryResponse_Error
- type StatSummaryResponse_Ok
- type StatSummaryResponse_Ok_
- type StatTable
- func (*StatTable) Descriptor() ([]byte, []int)
- func (m *StatTable) GetPodGroup() *StatTable_PodGroup
- func (m *StatTable) GetTable() isStatTable_Table
- func (*StatTable) ProtoMessage()
- func (m *StatTable) Reset()
- func (m *StatTable) String() string
- func (*StatTable) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type StatTable_PodGroup
- type StatTable_PodGroup_
- type StatTable_PodGroup_Row
- func (*StatTable_PodGroup_Row) Descriptor() ([]byte, []int)
- func (m *StatTable_PodGroup_Row) GetMeshedPodCount() uint64
- func (m *StatTable_PodGroup_Row) GetResource() *Resource
- func (m *StatTable_PodGroup_Row) GetStats() *BasicStats
- func (m *StatTable_PodGroup_Row) GetTimeWindow() TimeWindow
- func (m *StatTable_PodGroup_Row) GetTotalPodCount() uint64
- func (*StatTable_PodGroup_Row) ProtoMessage()
- func (m *StatTable_PodGroup_Row) Reset()
- func (m *StatTable_PodGroup_Row) String() string
- type TapRequest
- func (*TapRequest) Descriptor() ([]byte, []int)
- 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 (*TapRequest) ProtoMessage()
- func (m *TapRequest) Reset()
- func (m *TapRequest) String() string
- func (*TapRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type TapRequest_Deployment
- type TapRequest_Pod
- type TimeWindow
- type VersionInfo
Constants ¶
This section is empty.
Variables ¶
View Source
var TimeWindow_name = map[int32]string{
0: "TEN_SEC",
1: "ONE_MIN",
2: "TEN_MIN",
3: "ONE_HOUR",
}
View Source
var TimeWindow_value = map[string]int32{
"TEN_SEC": 0,
"ONE_MIN": 1,
"TEN_MIN": 2,
"ONE_HOUR": 3,
}
Functions ¶
func RegisterApiServer ¶
Types ¶
type ApiClient ¶
type ApiClient interface { StatSummary(ctx context.Context, in *StatSummaryRequest, opts ...grpc.CallOption) (*StatSummaryResponse, error) Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionInfo, error) ListPods(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPodsResponse, error) SelfCheck(ctx context.Context, in *conduit_common_healthcheck.SelfCheckRequest, opts ...grpc.CallOption) (*conduit_common_healthcheck.SelfCheckResponse, error) Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Api_TapClient, error) }
func NewApiClient ¶
func NewApiClient(cc *grpc.ClientConn) ApiClient
type ApiError ¶ added in v0.1.1
type ApiError struct {
Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}
func (*ApiError) Descriptor ¶ added in v0.1.1
func (*ApiError) ProtoMessage ¶ added in v0.1.1
func (*ApiError) ProtoMessage()
type ApiServer ¶
type ApiServer interface { StatSummary(context.Context, *StatSummaryRequest) (*StatSummaryResponse, error) Version(context.Context, *Empty) (*VersionInfo, error) ListPods(context.Context, *Empty) (*ListPodsResponse, error) SelfCheck(context.Context, *conduit_common_healthcheck.SelfCheckRequest) (*conduit_common_healthcheck.SelfCheckResponse, error) Tap(*TapRequest, Api_TapServer) error }
type Api_TapClient ¶
type Api_TapClient interface { Recv() (*conduit_common.TapEvent, error) grpc.ClientStream }
type Api_TapServer ¶
type Api_TapServer interface { Send(*conduit_common.TapEvent) error grpc.ServerStream }
type BasicStats ¶ added in v0.4.0
type BasicStats struct { SuccessCount uint64 `protobuf:"varint,1,opt,name=success_count,json=successCount" json:"success_count,omitempty"` FailureCount uint64 `protobuf:"varint,2,opt,name=failure_count,json=failureCount" json:"failure_count,omitempty"` LatencyMsP50 uint64 `protobuf:"varint,3,opt,name=latency_ms_p50,json=latencyMsP50" json:"latency_ms_p50,omitempty"` LatencyMsP95 uint64 `protobuf:"varint,4,opt,name=latency_ms_p95,json=latencyMsP95" json:"latency_ms_p95,omitempty"` LatencyMsP99 uint64 `protobuf:"varint,5,opt,name=latency_ms_p99,json=latencyMsP99" json:"latency_ms_p99,omitempty"` }
func (*BasicStats) Descriptor ¶ added in v0.4.0
func (*BasicStats) Descriptor() ([]byte, []int)
func (*BasicStats) GetFailureCount ¶ added in v0.4.0
func (m *BasicStats) GetFailureCount() uint64
func (*BasicStats) GetLatencyMsP50 ¶ added in v0.4.0
func (m *BasicStats) GetLatencyMsP50() uint64
func (*BasicStats) GetLatencyMsP95 ¶ added in v0.4.0
func (m *BasicStats) GetLatencyMsP95() uint64
func (*BasicStats) GetLatencyMsP99 ¶ added in v0.4.0
func (m *BasicStats) GetLatencyMsP99() uint64
func (*BasicStats) GetSuccessCount ¶ added in v0.4.0
func (m *BasicStats) GetSuccessCount() uint64
func (*BasicStats) ProtoMessage ¶ added in v0.4.0
func (*BasicStats) ProtoMessage()
func (*BasicStats) Reset ¶ added in v0.4.0
func (m *BasicStats) Reset()
func (*BasicStats) String ¶ added in v0.4.0
func (m *BasicStats) String() string
type Empty ¶
type Empty struct { }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
type ListPodsResponse ¶
type ListPodsResponse struct {
Pods []*Pod `protobuf:"bytes,1,rep,name=pods" json:"pods,omitempty"`
}
func (*ListPodsResponse) Descriptor ¶
func (*ListPodsResponse) Descriptor() ([]byte, []int)
func (*ListPodsResponse) GetPods ¶
func (m *ListPodsResponse) GetPods() []*Pod
func (*ListPodsResponse) ProtoMessage ¶
func (*ListPodsResponse) ProtoMessage()
func (*ListPodsResponse) Reset ¶
func (m *ListPodsResponse) Reset()
func (*ListPodsResponse) String ¶
func (m *ListPodsResponse) String() string
type Pod ¶
type Pod struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` PodIP string `protobuf:"bytes,2,opt,name=podIP" json:"podIP,omitempty"` Deployment string `protobuf:"bytes,3,opt,name=deployment" json:"deployment,omitempty"` Status string `protobuf:"bytes,4,opt,name=status" json:"status,omitempty"` Added bool `protobuf:"varint,5,opt,name=added" json:"added,omitempty"` SinceLastReport *google_protobuf.Duration `protobuf:"bytes,6,opt,name=sinceLastReport" json:"sinceLastReport,omitempty"` ControllerNamespace string `protobuf:"bytes,7,opt,name=controllerNamespace" json:"controllerNamespace,omitempty"` ControlPlane bool `protobuf:"varint,8,opt,name=controlPlane" json:"controlPlane,omitempty"` }
func (*Pod) Descriptor ¶
func (*Pod) GetControlPlane ¶
func (*Pod) GetControllerNamespace ¶
func (*Pod) GetDeployment ¶
func (*Pod) GetSinceLastReport ¶
func (m *Pod) GetSinceLastReport() *google_protobuf.Duration
func (*Pod) ProtoMessage ¶
func (*Pod) ProtoMessage()
type Resource ¶ added in v0.4.0
type Resource struct { Namespace string `protobuf:"bytes,1,opt,name=namespace" json:"namespace,omitempty"` Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"` Name string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"` }
func (*Resource) Descriptor ¶ added in v0.4.0
func (*Resource) GetNamespace ¶ added in v0.4.0
func (*Resource) ProtoMessage ¶ added in v0.4.0
func (*Resource) ProtoMessage()
type ResourceError ¶ added in v0.4.0
type ResourceError struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"` Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` }
func (*ResourceError) Descriptor ¶ added in v0.4.0
func (*ResourceError) Descriptor() ([]byte, []int)
func (*ResourceError) GetError ¶ added in v0.4.0
func (m *ResourceError) GetError() string
func (*ResourceError) GetResource ¶ added in v0.4.0
func (m *ResourceError) GetResource() *Resource
func (*ResourceError) ProtoMessage ¶ added in v0.4.0
func (*ResourceError) ProtoMessage()
func (*ResourceError) Reset ¶ added in v0.4.0
func (m *ResourceError) Reset()
func (*ResourceError) String ¶ added in v0.4.0
func (m *ResourceError) String() string
type ResourceSelection ¶ added in v0.4.0
type ResourceSelection struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"` LabelSelector string `protobuf:"bytes,2,opt,name=label_selector,json=labelSelector" json:"label_selector,omitempty"` }
func (*ResourceSelection) Descriptor ¶ added in v0.4.0
func (*ResourceSelection) Descriptor() ([]byte, []int)
func (*ResourceSelection) GetLabelSelector ¶ added in v0.4.0
func (m *ResourceSelection) GetLabelSelector() string
func (*ResourceSelection) GetResource ¶ added in v0.4.0
func (m *ResourceSelection) GetResource() *Resource
func (*ResourceSelection) ProtoMessage ¶ added in v0.4.0
func (*ResourceSelection) ProtoMessage()
func (*ResourceSelection) Reset ¶ added in v0.4.0
func (m *ResourceSelection) Reset()
func (*ResourceSelection) String ¶ added in v0.4.0
func (m *ResourceSelection) String() string
type StatSummaryRequest ¶ added in v0.4.0
type StatSummaryRequest struct { Selector *ResourceSelection `protobuf:"bytes,1,opt,name=selector" json:"selector,omitempty"` TimeWindow TimeWindow `protobuf:"varint,2,opt,name=time_window,json=timeWindow,enum=conduit.public.TimeWindow" json:"time_window,omitempty"` // Types that are valid to be assigned to Outbound: // *StatSummaryRequest_None // *StatSummaryRequest_ToResource // *StatSummaryRequest_FromResource Outbound isStatSummaryRequest_Outbound `protobuf_oneof:"outbound"` }
func (*StatSummaryRequest) Descriptor ¶ added in v0.4.0
func (*StatSummaryRequest) Descriptor() ([]byte, []int)
func (*StatSummaryRequest) GetFromResource ¶ added in v0.4.0
func (m *StatSummaryRequest) GetFromResource() *Resource
func (*StatSummaryRequest) GetNone ¶ added in v0.4.0
func (m *StatSummaryRequest) GetNone() *Empty
func (*StatSummaryRequest) GetOutbound ¶ added in v0.4.0
func (m *StatSummaryRequest) GetOutbound() isStatSummaryRequest_Outbound
func (*StatSummaryRequest) GetSelector ¶ added in v0.4.0
func (m *StatSummaryRequest) GetSelector() *ResourceSelection
func (*StatSummaryRequest) GetTimeWindow ¶ added in v0.4.0
func (m *StatSummaryRequest) GetTimeWindow() TimeWindow
func (*StatSummaryRequest) GetToResource ¶ added in v0.4.0
func (m *StatSummaryRequest) GetToResource() *Resource
func (*StatSummaryRequest) ProtoMessage ¶ added in v0.4.0
func (*StatSummaryRequest) ProtoMessage()
func (*StatSummaryRequest) Reset ¶ added in v0.4.0
func (m *StatSummaryRequest) Reset()
func (*StatSummaryRequest) String ¶ added in v0.4.0
func (m *StatSummaryRequest) String() string
func (*StatSummaryRequest) XXX_OneofFuncs ¶ added in v0.4.0
func (*StatSummaryRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type StatSummaryRequest_FromResource ¶ added in v0.4.0
type StatSummaryRequest_FromResource struct {
FromResource *Resource `protobuf:"bytes,5,opt,name=from_resource,json=fromResource,oneof"`
}
type StatSummaryRequest_None ¶ added in v0.4.0
type StatSummaryRequest_None struct {
None *Empty `protobuf:"bytes,3,opt,name=none,oneof"`
}
type StatSummaryRequest_ToResource ¶ added in v0.4.0
type StatSummaryRequest_ToResource struct {
ToResource *Resource `protobuf:"bytes,4,opt,name=to_resource,json=toResource,oneof"`
}
type StatSummaryResponse ¶ added in v0.4.0
type StatSummaryResponse struct { // Types that are valid to be assigned to Response: // *StatSummaryResponse_Ok_ // *StatSummaryResponse_Error Response isStatSummaryResponse_Response `protobuf_oneof:"response"` }
func (*StatSummaryResponse) Descriptor ¶ added in v0.4.0
func (*StatSummaryResponse) Descriptor() ([]byte, []int)
func (*StatSummaryResponse) GetError ¶ added in v0.4.0
func (m *StatSummaryResponse) GetError() *ResourceError
func (*StatSummaryResponse) GetOk ¶ added in v0.4.0
func (m *StatSummaryResponse) GetOk() *StatSummaryResponse_Ok
func (*StatSummaryResponse) GetResponse ¶ added in v0.4.0
func (m *StatSummaryResponse) GetResponse() isStatSummaryResponse_Response
func (*StatSummaryResponse) ProtoMessage ¶ added in v0.4.0
func (*StatSummaryResponse) ProtoMessage()
func (*StatSummaryResponse) Reset ¶ added in v0.4.0
func (m *StatSummaryResponse) Reset()
func (*StatSummaryResponse) String ¶ added in v0.4.0
func (m *StatSummaryResponse) String() string
func (*StatSummaryResponse) XXX_OneofFuncs ¶ added in v0.4.0
func (*StatSummaryResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type StatSummaryResponse_Error ¶ added in v0.4.0
type StatSummaryResponse_Error struct {
Error *ResourceError `protobuf:"bytes,2,opt,name=error,oneof"`
}
type StatSummaryResponse_Ok ¶ added in v0.4.0
type StatSummaryResponse_Ok struct {
StatTables []*StatTable `protobuf:"bytes,1,rep,name=stat_tables,json=statTables" json:"stat_tables,omitempty"`
}
func (*StatSummaryResponse_Ok) Descriptor ¶ added in v0.4.0
func (*StatSummaryResponse_Ok) Descriptor() ([]byte, []int)
func (*StatSummaryResponse_Ok) GetStatTables ¶ added in v0.4.0
func (m *StatSummaryResponse_Ok) GetStatTables() []*StatTable
func (*StatSummaryResponse_Ok) ProtoMessage ¶ added in v0.4.0
func (*StatSummaryResponse_Ok) ProtoMessage()
func (*StatSummaryResponse_Ok) Reset ¶ added in v0.4.0
func (m *StatSummaryResponse_Ok) Reset()
func (*StatSummaryResponse_Ok) String ¶ added in v0.4.0
func (m *StatSummaryResponse_Ok) String() string
type StatSummaryResponse_Ok_ ¶ added in v0.4.0
type StatSummaryResponse_Ok_ struct {
Ok *StatSummaryResponse_Ok `protobuf:"bytes,1,opt,name=ok,oneof"`
}
type StatTable ¶ added in v0.4.0
type StatTable struct { // Types that are valid to be assigned to Table: // *StatTable_PodGroup_ Table isStatTable_Table `protobuf_oneof:"table"` }
func (*StatTable) Descriptor ¶ added in v0.4.0
func (*StatTable) GetPodGroup ¶ added in v0.4.0
func (m *StatTable) GetPodGroup() *StatTable_PodGroup
func (*StatTable) ProtoMessage ¶ added in v0.4.0
func (*StatTable) ProtoMessage()
func (*StatTable) XXX_OneofFuncs ¶ added in v0.4.0
func (*StatTable) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type StatTable_PodGroup ¶ added in v0.4.0
type StatTable_PodGroup struct {
Rows []*StatTable_PodGroup_Row `protobuf:"bytes,1,rep,name=rows" json:"rows,omitempty"`
}
func (*StatTable_PodGroup) Descriptor ¶ added in v0.4.0
func (*StatTable_PodGroup) Descriptor() ([]byte, []int)
func (*StatTable_PodGroup) GetRows ¶ added in v0.4.0
func (m *StatTable_PodGroup) GetRows() []*StatTable_PodGroup_Row
func (*StatTable_PodGroup) ProtoMessage ¶ added in v0.4.0
func (*StatTable_PodGroup) ProtoMessage()
func (*StatTable_PodGroup) Reset ¶ added in v0.4.0
func (m *StatTable_PodGroup) Reset()
func (*StatTable_PodGroup) String ¶ added in v0.4.0
func (m *StatTable_PodGroup) String() string
type StatTable_PodGroup_ ¶ added in v0.4.0
type StatTable_PodGroup_ struct {
PodGroup *StatTable_PodGroup `protobuf:"bytes,1,opt,name=pod_group,json=podGroup,oneof"`
}
type StatTable_PodGroup_Row ¶ added in v0.4.0
type StatTable_PodGroup_Row struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"` TimeWindow TimeWindow `protobuf:"varint,2,opt,name=time_window,json=timeWindow,enum=conduit.public.TimeWindow" json:"time_window,omitempty"` MeshedPodCount uint64 `protobuf:"varint,3,opt,name=meshed_pod_count,json=meshedPodCount" json:"meshed_pod_count,omitempty"` TotalPodCount uint64 `protobuf:"varint,4,opt,name=total_pod_count,json=totalPodCount" json:"total_pod_count,omitempty"` Stats *BasicStats `protobuf:"bytes,5,opt,name=stats" json:"stats,omitempty"` }
func (*StatTable_PodGroup_Row) Descriptor ¶ added in v0.4.0
func (*StatTable_PodGroup_Row) Descriptor() ([]byte, []int)
func (*StatTable_PodGroup_Row) GetMeshedPodCount ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) GetMeshedPodCount() uint64
func (*StatTable_PodGroup_Row) GetResource ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) GetResource() *Resource
func (*StatTable_PodGroup_Row) GetStats ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) GetStats() *BasicStats
func (*StatTable_PodGroup_Row) GetTimeWindow ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) GetTimeWindow() TimeWindow
func (*StatTable_PodGroup_Row) GetTotalPodCount ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) GetTotalPodCount() uint64
func (*StatTable_PodGroup_Row) ProtoMessage ¶ added in v0.4.0
func (*StatTable_PodGroup_Row) ProtoMessage()
func (*StatTable_PodGroup_Row) Reset ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) Reset()
func (*StatTable_PodGroup_Row) String ¶ added in v0.4.0
func (m *StatTable_PodGroup_Row) String() string
type TapRequest ¶
type TapRequest struct { // Types that are valid to be assigned to Target: // *TapRequest_Pod // *TapRequest_Deployment Target isTapRequest_Target `protobuf_oneof:"target"` // validation of these fields happens on the server MaxRps float32 `protobuf:"fixed32,3,opt,name=maxRps" json:"maxRps,omitempty"` ToPort uint32 `protobuf:"varint,4,opt,name=toPort" json:"toPort,omitempty"` ToIP string `protobuf:"bytes,5,opt,name=toIP" json:"toIP,omitempty"` FromPort uint32 `protobuf:"varint,6,opt,name=fromPort" json:"fromPort,omitempty"` FromIP string `protobuf:"bytes,7,opt,name=fromIP" json:"fromIP,omitempty"` Scheme string `protobuf:"bytes,8,opt,name=scheme" json:"scheme,omitempty"` Method string `protobuf:"bytes,9,opt,name=method" json:"method,omitempty"` Authority string `protobuf:"bytes,10,opt,name=authority" json:"authority,omitempty"` Path string `protobuf:"bytes,11,opt,name=path" json:"path,omitempty"` }
func (*TapRequest) Descriptor ¶
func (*TapRequest) Descriptor() ([]byte, []int)
func (*TapRequest) GetAuthority ¶
func (m *TapRequest) GetAuthority() string
func (*TapRequest) GetDeployment ¶
func (m *TapRequest) GetDeployment() string
func (*TapRequest) GetFromIP ¶
func (m *TapRequest) GetFromIP() string
func (*TapRequest) GetFromPort ¶
func (m *TapRequest) GetFromPort() uint32
func (*TapRequest) GetMaxRps ¶
func (m *TapRequest) GetMaxRps() float32
func (*TapRequest) GetMethod ¶
func (m *TapRequest) GetMethod() string
func (*TapRequest) GetPath ¶
func (m *TapRequest) GetPath() string
func (*TapRequest) GetPod ¶
func (m *TapRequest) GetPod() string
func (*TapRequest) GetScheme ¶
func (m *TapRequest) GetScheme() string
func (*TapRequest) GetTarget ¶
func (m *TapRequest) GetTarget() isTapRequest_Target
func (*TapRequest) GetToIP ¶
func (m *TapRequest) GetToIP() string
func (*TapRequest) GetToPort ¶
func (m *TapRequest) GetToPort() uint32
func (*TapRequest) ProtoMessage ¶
func (*TapRequest) ProtoMessage()
func (*TapRequest) Reset ¶
func (m *TapRequest) Reset()
func (*TapRequest) String ¶
func (m *TapRequest) String() string
func (*TapRequest) XXX_OneofFuncs ¶
func (*TapRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type TapRequest_Deployment ¶
type TapRequest_Deployment struct {
Deployment string `protobuf:"bytes,2,opt,name=deployment,oneof"`
}
type TapRequest_Pod ¶
type TapRequest_Pod struct {
Pod string `protobuf:"bytes,1,opt,name=pod,oneof"`
}
type TimeWindow ¶
type TimeWindow int32
const ( TimeWindow_TEN_SEC TimeWindow = 0 TimeWindow_ONE_MIN TimeWindow = 1 TimeWindow_TEN_MIN TimeWindow = 2 TimeWindow_ONE_HOUR TimeWindow = 3 )
func (TimeWindow) EnumDescriptor ¶
func (TimeWindow) EnumDescriptor() ([]byte, []int)
func (TimeWindow) String ¶
func (x TimeWindow) String() string
type VersionInfo ¶
type VersionInfo struct { GoVersion string `protobuf:"bytes,1,opt,name=goVersion" json:"goVersion,omitempty"` BuildDate string `protobuf:"bytes,2,opt,name=buildDate" json:"buildDate,omitempty"` ReleaseVersion string `protobuf:"bytes,3,opt,name=releaseVersion" json:"releaseVersion,omitempty"` }
func (*VersionInfo) Descriptor ¶
func (*VersionInfo) Descriptor() ([]byte, []int)
func (*VersionInfo) GetBuildDate ¶
func (m *VersionInfo) GetBuildDate() string
func (*VersionInfo) GetGoVersion ¶
func (m *VersionInfo) GetGoVersion() string
func (*VersionInfo) GetReleaseVersion ¶
func (m *VersionInfo) GetReleaseVersion() string
func (*VersionInfo) ProtoMessage ¶
func (*VersionInfo) ProtoMessage()
func (*VersionInfo) Reset ¶
func (m *VersionInfo) Reset()
func (*VersionInfo) String ¶
func (m *VersionInfo) String() string
Click to show internal directories.
Click to hide internal directories.