Documentation ¶
Index ¶
- Variables
- func RegisterTapDiscoveryServiceServer(s *grpc.Server, srv TapDiscoveryServiceServer)
- func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer)
- type FilePerTapSink
- func (*FilePerTapSink) Descriptor() ([]byte, []int)
- func (m *FilePerTapSink) GetPathPrefix() string
- func (*FilePerTapSink) ProtoMessage()
- func (m *FilePerTapSink) Reset()
- func (m *FilePerTapSink) String() string
- func (m *FilePerTapSink) XXX_DiscardUnknown()
- func (m *FilePerTapSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FilePerTapSink) XXX_Merge(src proto.Message)
- func (m *FilePerTapSink) XXX_Size() int
- func (m *FilePerTapSink) XXX_Unmarshal(b []byte) error
- type HttpHeadersMatch
- func (*HttpHeadersMatch) Descriptor() ([]byte, []int)
- func (m *HttpHeadersMatch) GetHeaders() []*route.HeaderMatcher
- func (*HttpHeadersMatch) ProtoMessage()
- func (m *HttpHeadersMatch) Reset()
- func (m *HttpHeadersMatch) String() string
- func (m *HttpHeadersMatch) XXX_DiscardUnknown()
- func (m *HttpHeadersMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HttpHeadersMatch) XXX_Merge(src proto.Message)
- func (m *HttpHeadersMatch) XXX_Size() int
- func (m *HttpHeadersMatch) XXX_Unmarshal(b []byte) error
- type MatchPredicate
- func (*MatchPredicate) Descriptor() ([]byte, []int)
- func (m *MatchPredicate) GetAndMatch() *MatchPredicate_MatchSet
- func (m *MatchPredicate) GetAnyMatch() bool
- func (m *MatchPredicate) GetHttpRequestHeadersMatch() *HttpHeadersMatch
- func (m *MatchPredicate) GetHttpRequestTrailersMatch() *HttpHeadersMatch
- func (m *MatchPredicate) GetHttpResponseHeadersMatch() *HttpHeadersMatch
- func (m *MatchPredicate) GetHttpResponseTrailersMatch() *HttpHeadersMatch
- func (m *MatchPredicate) GetNotMatch() *MatchPredicate
- func (m *MatchPredicate) GetOrMatch() *MatchPredicate_MatchSet
- func (m *MatchPredicate) GetRule() isMatchPredicate_Rule
- func (*MatchPredicate) ProtoMessage()
- func (m *MatchPredicate) Reset()
- func (m *MatchPredicate) String() string
- func (m *MatchPredicate) XXX_DiscardUnknown()
- func (m *MatchPredicate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MatchPredicate) XXX_Merge(src proto.Message)
- func (*MatchPredicate) XXX_OneofWrappers() []interface{}
- func (m *MatchPredicate) XXX_Size() int
- func (m *MatchPredicate) XXX_Unmarshal(b []byte) error
- type MatchPredicate_AndMatch
- type MatchPredicate_AnyMatch
- type MatchPredicate_HttpRequestHeadersMatch
- type MatchPredicate_HttpRequestTrailersMatch
- type MatchPredicate_HttpResponseHeadersMatch
- type MatchPredicate_HttpResponseTrailersMatch
- type MatchPredicate_MatchSet
- func (*MatchPredicate_MatchSet) Descriptor() ([]byte, []int)
- func (m *MatchPredicate_MatchSet) GetRules() []*MatchPredicate
- func (*MatchPredicate_MatchSet) ProtoMessage()
- func (m *MatchPredicate_MatchSet) Reset()
- func (m *MatchPredicate_MatchSet) String() string
- func (m *MatchPredicate_MatchSet) XXX_DiscardUnknown()
- func (m *MatchPredicate_MatchSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MatchPredicate_MatchSet) XXX_Merge(src proto.Message)
- func (m *MatchPredicate_MatchSet) XXX_Size() int
- func (m *MatchPredicate_MatchSet) XXX_Unmarshal(b []byte) error
- type MatchPredicate_NotMatch
- type MatchPredicate_OrMatch
- type OutputConfig
- func (*OutputConfig) Descriptor() ([]byte, []int)
- func (m *OutputConfig) GetMaxBufferedRxBytes() *types.UInt32Value
- func (m *OutputConfig) GetMaxBufferedTxBytes() *types.UInt32Value
- func (m *OutputConfig) GetSinks() []*OutputSink
- func (m *OutputConfig) GetStreaming() bool
- func (*OutputConfig) ProtoMessage()
- func (m *OutputConfig) Reset()
- func (m *OutputConfig) String() string
- func (m *OutputConfig) XXX_DiscardUnknown()
- func (m *OutputConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OutputConfig) XXX_Merge(src proto.Message)
- func (m *OutputConfig) XXX_Size() int
- func (m *OutputConfig) XXX_Unmarshal(b []byte) error
- type OutputSink
- func (*OutputSink) Descriptor() ([]byte, []int)
- func (m *OutputSink) GetFilePerTap() *FilePerTapSink
- func (m *OutputSink) GetFormat() OutputSink_Format
- func (m *OutputSink) GetOutputSinkType() isOutputSink_OutputSinkType
- func (m *OutputSink) GetStreamingAdmin() *StreamingAdminSink
- func (m *OutputSink) GetStreamingGrpc() *StreamingGrpcSink
- func (*OutputSink) ProtoMessage()
- func (m *OutputSink) Reset()
- func (m *OutputSink) String() string
- func (m *OutputSink) XXX_DiscardUnknown()
- func (m *OutputSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OutputSink) XXX_Merge(src proto.Message)
- func (*OutputSink) XXX_OneofWrappers() []interface{}
- func (m *OutputSink) XXX_Size() int
- func (m *OutputSink) XXX_Unmarshal(b []byte) error
- type OutputSink_FilePerTap
- type OutputSink_Format
- type OutputSink_StreamingAdmin
- type OutputSink_StreamingGrpc
- type StreamTapsRequest
- func (*StreamTapsRequest) Descriptor() ([]byte, []int)
- func (m *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier
- func (m *StreamTapsRequest) GetTrace() *v2alpha.TraceWrapper
- func (m *StreamTapsRequest) GetTraceId() uint64
- func (*StreamTapsRequest) ProtoMessage()
- func (m *StreamTapsRequest) Reset()
- func (m *StreamTapsRequest) String() string
- func (m *StreamTapsRequest) XXX_DiscardUnknown()
- func (m *StreamTapsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamTapsRequest) XXX_Merge(src proto.Message)
- func (m *StreamTapsRequest) XXX_Size() int
- func (m *StreamTapsRequest) XXX_Unmarshal(b []byte) error
- type StreamTapsRequest_Identifier
- func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)
- func (m *StreamTapsRequest_Identifier) GetNode() *core.Node
- func (m *StreamTapsRequest_Identifier) GetTapId() string
- func (*StreamTapsRequest_Identifier) ProtoMessage()
- func (m *StreamTapsRequest_Identifier) Reset()
- func (m *StreamTapsRequest_Identifier) String() string
- func (m *StreamTapsRequest_Identifier) XXX_DiscardUnknown()
- func (m *StreamTapsRequest_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamTapsRequest_Identifier) XXX_Merge(src proto.Message)
- func (m *StreamTapsRequest_Identifier) XXX_Size() int
- func (m *StreamTapsRequest_Identifier) XXX_Unmarshal(b []byte) error
- type StreamTapsResponse
- func (*StreamTapsResponse) Descriptor() ([]byte, []int)
- func (*StreamTapsResponse) ProtoMessage()
- func (m *StreamTapsResponse) Reset()
- func (m *StreamTapsResponse) String() string
- func (m *StreamTapsResponse) XXX_DiscardUnknown()
- func (m *StreamTapsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamTapsResponse) XXX_Merge(src proto.Message)
- func (m *StreamTapsResponse) XXX_Size() int
- func (m *StreamTapsResponse) XXX_Unmarshal(b []byte) error
- type StreamingAdminSink
- func (*StreamingAdminSink) Descriptor() ([]byte, []int)
- func (*StreamingAdminSink) ProtoMessage()
- func (m *StreamingAdminSink) Reset()
- func (m *StreamingAdminSink) String() string
- func (m *StreamingAdminSink) XXX_DiscardUnknown()
- func (m *StreamingAdminSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingAdminSink) XXX_Merge(src proto.Message)
- func (m *StreamingAdminSink) XXX_Size() int
- func (m *StreamingAdminSink) XXX_Unmarshal(b []byte) error
- type StreamingGrpcSink
- func (*StreamingGrpcSink) Descriptor() ([]byte, []int)
- func (m *StreamingGrpcSink) GetGrpcService() *core.GrpcService
- func (m *StreamingGrpcSink) GetTapId() string
- func (*StreamingGrpcSink) ProtoMessage()
- func (m *StreamingGrpcSink) Reset()
- func (m *StreamingGrpcSink) String() string
- func (m *StreamingGrpcSink) XXX_DiscardUnknown()
- func (m *StreamingGrpcSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingGrpcSink) XXX_Merge(src proto.Message)
- func (m *StreamingGrpcSink) XXX_Size() int
- func (m *StreamingGrpcSink) XXX_Unmarshal(b []byte) error
- type TapConfig
- func (*TapConfig) Descriptor() ([]byte, []int)
- func (m *TapConfig) GetMatchConfig() *MatchPredicate
- func (m *TapConfig) GetOutputConfig() *OutputConfig
- func (m *TapConfig) GetTapEnabled() *core.RuntimeFractionalPercent
- func (*TapConfig) ProtoMessage()
- func (m *TapConfig) Reset()
- func (m *TapConfig) String() string
- func (m *TapConfig) XXX_DiscardUnknown()
- func (m *TapConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TapConfig) XXX_Merge(src proto.Message)
- func (m *TapConfig) XXX_Size() int
- func (m *TapConfig) XXX_Unmarshal(b []byte) error
- type TapDiscoveryServiceClient
- type TapDiscoveryServiceServer
- type TapDiscoveryService_DeltaTapConfigsClient
- type TapDiscoveryService_DeltaTapConfigsServer
- type TapDiscoveryService_StreamTapConfigsClient
- type TapDiscoveryService_StreamTapConfigsServer
- type TapResource
- func (*TapResource) Descriptor() ([]byte, []int)
- func (m *TapResource) GetConfig() *TapConfig
- func (m *TapResource) GetName() string
- func (*TapResource) ProtoMessage()
- func (m *TapResource) Reset()
- func (m *TapResource) String() string
- func (m *TapResource) XXX_DiscardUnknown()
- func (m *TapResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TapResource) XXX_Merge(src proto.Message)
- func (m *TapResource) XXX_Size() int
- func (m *TapResource) XXX_Unmarshal(b []byte) error
- type TapSinkServiceClient
- type TapSinkServiceServer
- type TapSinkService_StreamTapsClient
- type TapSinkService_StreamTapsServer
Constants ¶
This section is empty.
Variables ¶
var OutputSink_Format_name = map[int32]string{
0: "JSON_BODY_AS_BYTES",
1: "JSON_BODY_AS_STRING",
2: "PROTO_BINARY",
3: "PROTO_BINARY_LENGTH_DELIMITED",
4: "PROTO_TEXT",
}
var OutputSink_Format_value = map[string]int32{
"JSON_BODY_AS_BYTES": 0,
"JSON_BODY_AS_STRING": 1,
"PROTO_BINARY": 2,
"PROTO_BINARY_LENGTH_DELIMITED": 3,
"PROTO_TEXT": 4,
}
Functions ¶
func RegisterTapDiscoveryServiceServer ¶
func RegisterTapDiscoveryServiceServer(s *grpc.Server, srv TapDiscoveryServiceServer)
func RegisterTapSinkServiceServer ¶
func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer)
Types ¶
type FilePerTapSink ¶
type FilePerTapSink struct { // Path prefix. The output file will be of the form <path_prefix>_<id>.pb, where <id> is an // identifier distinguishing the recorded trace for stream instances (the Envoy // connection ID, HTTP stream ID, etc.). PathPrefix string `protobuf:"bytes,1,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The file per tap sink outputs a discrete file for every tapped stream.
func (*FilePerTapSink) Descriptor ¶
func (*FilePerTapSink) Descriptor() ([]byte, []int)
func (*FilePerTapSink) GetPathPrefix ¶
func (m *FilePerTapSink) GetPathPrefix() string
func (*FilePerTapSink) ProtoMessage ¶
func (*FilePerTapSink) ProtoMessage()
func (*FilePerTapSink) Reset ¶
func (m *FilePerTapSink) Reset()
func (*FilePerTapSink) String ¶
func (m *FilePerTapSink) String() string
func (*FilePerTapSink) XXX_DiscardUnknown ¶
func (m *FilePerTapSink) XXX_DiscardUnknown()
func (*FilePerTapSink) XXX_Marshal ¶
func (m *FilePerTapSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FilePerTapSink) XXX_Merge ¶
func (m *FilePerTapSink) XXX_Merge(src proto.Message)
func (*FilePerTapSink) XXX_Size ¶
func (m *FilePerTapSink) XXX_Size() int
func (*FilePerTapSink) XXX_Unmarshal ¶
func (m *FilePerTapSink) XXX_Unmarshal(b []byte) error
type HttpHeadersMatch ¶
type HttpHeadersMatch struct { // HTTP headers to match. Headers []*route.HeaderMatcher `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
HTTP headers match configuration.
func (*HttpHeadersMatch) Descriptor ¶
func (*HttpHeadersMatch) Descriptor() ([]byte, []int)
func (*HttpHeadersMatch) GetHeaders ¶
func (m *HttpHeadersMatch) GetHeaders() []*route.HeaderMatcher
func (*HttpHeadersMatch) ProtoMessage ¶
func (*HttpHeadersMatch) ProtoMessage()
func (*HttpHeadersMatch) Reset ¶
func (m *HttpHeadersMatch) Reset()
func (*HttpHeadersMatch) String ¶
func (m *HttpHeadersMatch) String() string
func (*HttpHeadersMatch) XXX_DiscardUnknown ¶
func (m *HttpHeadersMatch) XXX_DiscardUnknown()
func (*HttpHeadersMatch) XXX_Marshal ¶
func (m *HttpHeadersMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HttpHeadersMatch) XXX_Merge ¶
func (m *HttpHeadersMatch) XXX_Merge(src proto.Message)
func (*HttpHeadersMatch) XXX_Size ¶
func (m *HttpHeadersMatch) XXX_Size() int
func (*HttpHeadersMatch) XXX_Unmarshal ¶
func (m *HttpHeadersMatch) XXX_Unmarshal(b []byte) error
type MatchPredicate ¶
type MatchPredicate struct { // Types that are valid to be assigned to Rule: // *MatchPredicate_OrMatch // *MatchPredicate_AndMatch // *MatchPredicate_NotMatch // *MatchPredicate_AnyMatch // *MatchPredicate_HttpRequestHeadersMatch // *MatchPredicate_HttpRequestTrailersMatch // *MatchPredicate_HttpResponseHeadersMatch // *MatchPredicate_HttpResponseTrailersMatch Rule isMatchPredicate_Rule `protobuf_oneof:"rule"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Tap match configuration. This is a recursive structure which allows complex nested match configurations to be built using various logical operators. [#next-free-field: 9]
func (*MatchPredicate) Descriptor ¶
func (*MatchPredicate) Descriptor() ([]byte, []int)
func (*MatchPredicate) GetAndMatch ¶
func (m *MatchPredicate) GetAndMatch() *MatchPredicate_MatchSet
func (*MatchPredicate) GetAnyMatch ¶
func (m *MatchPredicate) GetAnyMatch() bool
func (*MatchPredicate) GetHttpRequestHeadersMatch ¶
func (m *MatchPredicate) GetHttpRequestHeadersMatch() *HttpHeadersMatch
func (*MatchPredicate) GetHttpRequestTrailersMatch ¶
func (m *MatchPredicate) GetHttpRequestTrailersMatch() *HttpHeadersMatch
func (*MatchPredicate) GetHttpResponseHeadersMatch ¶
func (m *MatchPredicate) GetHttpResponseHeadersMatch() *HttpHeadersMatch
func (*MatchPredicate) GetHttpResponseTrailersMatch ¶
func (m *MatchPredicate) GetHttpResponseTrailersMatch() *HttpHeadersMatch
func (*MatchPredicate) GetNotMatch ¶
func (m *MatchPredicate) GetNotMatch() *MatchPredicate
func (*MatchPredicate) GetOrMatch ¶
func (m *MatchPredicate) GetOrMatch() *MatchPredicate_MatchSet
func (*MatchPredicate) GetRule ¶
func (m *MatchPredicate) GetRule() isMatchPredicate_Rule
func (*MatchPredicate) ProtoMessage ¶
func (*MatchPredicate) ProtoMessage()
func (*MatchPredicate) Reset ¶
func (m *MatchPredicate) Reset()
func (*MatchPredicate) String ¶
func (m *MatchPredicate) String() string
func (*MatchPredicate) XXX_DiscardUnknown ¶
func (m *MatchPredicate) XXX_DiscardUnknown()
func (*MatchPredicate) XXX_Marshal ¶
func (m *MatchPredicate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MatchPredicate) XXX_Merge ¶
func (m *MatchPredicate) XXX_Merge(src proto.Message)
func (*MatchPredicate) XXX_OneofWrappers ¶
func (*MatchPredicate) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*MatchPredicate) XXX_Size ¶
func (m *MatchPredicate) XXX_Size() int
func (*MatchPredicate) XXX_Unmarshal ¶
func (m *MatchPredicate) XXX_Unmarshal(b []byte) error
type MatchPredicate_AndMatch ¶
type MatchPredicate_AndMatch struct {
AndMatch *MatchPredicate_MatchSet `protobuf:"bytes,2,opt,name=and_match,json=andMatch,proto3,oneof"`
}
type MatchPredicate_AnyMatch ¶
type MatchPredicate_AnyMatch struct {
AnyMatch bool `protobuf:"varint,4,opt,name=any_match,json=anyMatch,proto3,oneof"`
}
type MatchPredicate_HttpRequestHeadersMatch ¶
type MatchPredicate_HttpRequestHeadersMatch struct {
HttpRequestHeadersMatch *HttpHeadersMatch `protobuf:"bytes,5,opt,name=http_request_headers_match,json=httpRequestHeadersMatch,proto3,oneof"`
}
type MatchPredicate_HttpRequestTrailersMatch ¶
type MatchPredicate_HttpRequestTrailersMatch struct {
HttpRequestTrailersMatch *HttpHeadersMatch `protobuf:"bytes,6,opt,name=http_request_trailers_match,json=httpRequestTrailersMatch,proto3,oneof"`
}
type MatchPredicate_HttpResponseHeadersMatch ¶
type MatchPredicate_HttpResponseHeadersMatch struct {
HttpResponseHeadersMatch *HttpHeadersMatch `protobuf:"bytes,7,opt,name=http_response_headers_match,json=httpResponseHeadersMatch,proto3,oneof"`
}
type MatchPredicate_HttpResponseTrailersMatch ¶
type MatchPredicate_HttpResponseTrailersMatch struct {
HttpResponseTrailersMatch *HttpHeadersMatch `protobuf:"bytes,8,opt,name=http_response_trailers_match,json=httpResponseTrailersMatch,proto3,oneof"`
}
type MatchPredicate_MatchSet ¶
type MatchPredicate_MatchSet struct { // The list of rules that make up the set. Rules []*MatchPredicate `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A set of match configurations used for logical operations.
func (*MatchPredicate_MatchSet) Descriptor ¶
func (*MatchPredicate_MatchSet) Descriptor() ([]byte, []int)
func (*MatchPredicate_MatchSet) GetRules ¶
func (m *MatchPredicate_MatchSet) GetRules() []*MatchPredicate
func (*MatchPredicate_MatchSet) ProtoMessage ¶
func (*MatchPredicate_MatchSet) ProtoMessage()
func (*MatchPredicate_MatchSet) Reset ¶
func (m *MatchPredicate_MatchSet) Reset()
func (*MatchPredicate_MatchSet) String ¶
func (m *MatchPredicate_MatchSet) String() string
func (*MatchPredicate_MatchSet) XXX_DiscardUnknown ¶
func (m *MatchPredicate_MatchSet) XXX_DiscardUnknown()
func (*MatchPredicate_MatchSet) XXX_Marshal ¶
func (m *MatchPredicate_MatchSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MatchPredicate_MatchSet) XXX_Merge ¶
func (m *MatchPredicate_MatchSet) XXX_Merge(src proto.Message)
func (*MatchPredicate_MatchSet) XXX_Size ¶
func (m *MatchPredicate_MatchSet) XXX_Size() int
func (*MatchPredicate_MatchSet) XXX_Unmarshal ¶
func (m *MatchPredicate_MatchSet) XXX_Unmarshal(b []byte) error
type MatchPredicate_NotMatch ¶
type MatchPredicate_NotMatch struct {
NotMatch *MatchPredicate `protobuf:"bytes,3,opt,name=not_match,json=notMatch,proto3,oneof"`
}
type MatchPredicate_OrMatch ¶
type MatchPredicate_OrMatch struct {
OrMatch *MatchPredicate_MatchSet `protobuf:"bytes,1,opt,name=or_match,json=orMatch,proto3,oneof"`
}
type OutputConfig ¶
type OutputConfig struct { // Output sinks for tap data. Currently a single sink is allowed in the list. Once multiple // sink types are supported this constraint will be relaxed. Sinks []*OutputSink `protobuf:"bytes,1,rep,name=sinks,proto3" json:"sinks,omitempty"` // For buffered tapping, the maximum amount of received body that will be buffered prior to // truncation. If truncation occurs, the :ref:`truncated // <envoy_api_field_data.tap.v2alpha.Body.truncated>` field will be set. If not specified, the // default is 1KiB. MaxBufferedRxBytes *types.UInt32Value `protobuf:"bytes,2,opt,name=max_buffered_rx_bytes,json=maxBufferedRxBytes,proto3" json:"max_buffered_rx_bytes,omitempty"` // For buffered tapping, the maximum amount of transmitted body that will be buffered prior to // truncation. If truncation occurs, the :ref:`truncated // <envoy_api_field_data.tap.v2alpha.Body.truncated>` field will be set. If not specified, the // default is 1KiB. MaxBufferedTxBytes *types.UInt32Value `protobuf:"bytes,3,opt,name=max_buffered_tx_bytes,json=maxBufferedTxBytes,proto3" json:"max_buffered_tx_bytes,omitempty"` // Indicates whether taps produce a single buffered message per tap, or multiple streamed // messages per tap in the emitted :ref:`TraceWrapper // <envoy_api_msg_data.tap.v2alpha.TraceWrapper>` messages. Note that streamed tapping does not // mean that no buffering takes place. Buffering may be required if data is processed before a // match can be determined. See the HTTP tap filter :ref:`streaming // <config_http_filters_tap_streaming>` documentation for more information. Streaming bool `protobuf:"varint,4,opt,name=streaming,proto3" json:"streaming,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Tap output configuration.
func (*OutputConfig) Descriptor ¶
func (*OutputConfig) Descriptor() ([]byte, []int)
func (*OutputConfig) GetMaxBufferedRxBytes ¶
func (m *OutputConfig) GetMaxBufferedRxBytes() *types.UInt32Value
func (*OutputConfig) GetMaxBufferedTxBytes ¶
func (m *OutputConfig) GetMaxBufferedTxBytes() *types.UInt32Value
func (*OutputConfig) GetSinks ¶
func (m *OutputConfig) GetSinks() []*OutputSink
func (*OutputConfig) GetStreaming ¶
func (m *OutputConfig) GetStreaming() bool
func (*OutputConfig) ProtoMessage ¶
func (*OutputConfig) ProtoMessage()
func (*OutputConfig) Reset ¶
func (m *OutputConfig) Reset()
func (*OutputConfig) String ¶
func (m *OutputConfig) String() string
func (*OutputConfig) XXX_DiscardUnknown ¶
func (m *OutputConfig) XXX_DiscardUnknown()
func (*OutputConfig) XXX_Marshal ¶
func (m *OutputConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OutputConfig) XXX_Merge ¶
func (m *OutputConfig) XXX_Merge(src proto.Message)
func (*OutputConfig) XXX_Size ¶
func (m *OutputConfig) XXX_Size() int
func (*OutputConfig) XXX_Unmarshal ¶
func (m *OutputConfig) XXX_Unmarshal(b []byte) error
type OutputSink ¶
type OutputSink struct { // Sink output format. Format OutputSink_Format `protobuf:"varint,1,opt,name=format,proto3,enum=envoy.service.tap.v2alpha.OutputSink_Format" json:"format,omitempty"` // Types that are valid to be assigned to OutputSinkType: // *OutputSink_StreamingAdmin // *OutputSink_FilePerTap // *OutputSink_StreamingGrpc OutputSinkType isOutputSink_OutputSinkType `protobuf_oneof:"output_sink_type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Tap output sink configuration.
func (*OutputSink) Descriptor ¶
func (*OutputSink) Descriptor() ([]byte, []int)
func (*OutputSink) GetFilePerTap ¶
func (m *OutputSink) GetFilePerTap() *FilePerTapSink
func (*OutputSink) GetFormat ¶
func (m *OutputSink) GetFormat() OutputSink_Format
func (*OutputSink) GetOutputSinkType ¶
func (m *OutputSink) GetOutputSinkType() isOutputSink_OutputSinkType
func (*OutputSink) GetStreamingAdmin ¶
func (m *OutputSink) GetStreamingAdmin() *StreamingAdminSink
func (*OutputSink) GetStreamingGrpc ¶
func (m *OutputSink) GetStreamingGrpc() *StreamingGrpcSink
func (*OutputSink) ProtoMessage ¶
func (*OutputSink) ProtoMessage()
func (*OutputSink) Reset ¶
func (m *OutputSink) Reset()
func (*OutputSink) String ¶
func (m *OutputSink) String() string
func (*OutputSink) XXX_DiscardUnknown ¶
func (m *OutputSink) XXX_DiscardUnknown()
func (*OutputSink) XXX_Marshal ¶
func (m *OutputSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OutputSink) XXX_Merge ¶
func (m *OutputSink) XXX_Merge(src proto.Message)
func (*OutputSink) XXX_OneofWrappers ¶
func (*OutputSink) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*OutputSink) XXX_Size ¶
func (m *OutputSink) XXX_Size() int
func (*OutputSink) XXX_Unmarshal ¶
func (m *OutputSink) XXX_Unmarshal(b []byte) error
type OutputSink_FilePerTap ¶
type OutputSink_FilePerTap struct {
FilePerTap *FilePerTapSink `protobuf:"bytes,3,opt,name=file_per_tap,json=filePerTap,proto3,oneof"`
}
type OutputSink_Format ¶
type OutputSink_Format int32
Output format. All output is in the form of one or more :ref:`TraceWrapper <envoy_api_msg_data.tap.v2alpha.TraceWrapper>` messages. This enumeration indicates how those messages are written. Note that not all sinks support all output formats. See individual sink documentation for more information.
const ( // Each message will be written as JSON. Any :ref:`body <envoy_api_msg_data.tap.v2alpha.Body>` // data will be present in the :ref:`as_bytes // <envoy_api_field_data.tap.v2alpha.Body.as_bytes>` field. This means that body data will be // base64 encoded as per the `proto3 JSON mappings // <https://developers.google.com/protocol-buffers/docs/proto3#json>`_. OutputSink_JSON_BODY_AS_BYTES OutputSink_Format = 0 // Each message will be written as JSON. Any :ref:`body <envoy_api_msg_data.tap.v2alpha.Body>` // data will be present in the :ref:`as_string // <envoy_api_field_data.tap.v2alpha.Body.as_string>` field. This means that body data will be // string encoded as per the `proto3 JSON mappings // <https://developers.google.com/protocol-buffers/docs/proto3#json>`_. This format type is // useful when it is known that that body is human readable (e.g., JSON over HTTP) and the // user wishes to view it directly without being forced to base64 decode the body. OutputSink_JSON_BODY_AS_STRING OutputSink_Format = 1 // Binary proto format. Note that binary proto is not self-delimiting. If a sink writes // multiple binary messages without any length information the data stream will not be // useful. However, for certain sinks that are self-delimiting (e.g., one message per file) // this output format makes consumption simpler. OutputSink_PROTO_BINARY OutputSink_Format = 2 // Messages are written as a sequence tuples, where each tuple is the message length encoded // as a `protobuf 32-bit varint // <https://developers.google.com/protocol-buffers/docs/reference/cpp/google.protobuf.io.coded_stream>`_ // followed by the binary message. The messages can be read back using the language specific // protobuf coded stream implementation to obtain the message length and the message. OutputSink_PROTO_BINARY_LENGTH_DELIMITED OutputSink_Format = 3 // Text proto format. OutputSink_PROTO_TEXT OutputSink_Format = 4 )
func (OutputSink_Format) EnumDescriptor ¶
func (OutputSink_Format) EnumDescriptor() ([]byte, []int)
func (OutputSink_Format) String ¶
func (x OutputSink_Format) String() string
type OutputSink_StreamingAdmin ¶
type OutputSink_StreamingAdmin struct {
StreamingAdmin *StreamingAdminSink `protobuf:"bytes,2,opt,name=streaming_admin,json=streamingAdmin,proto3,oneof"`
}
type OutputSink_StreamingGrpc ¶
type OutputSink_StreamingGrpc struct {
StreamingGrpc *StreamingGrpcSink `protobuf:"bytes,4,opt,name=streaming_grpc,json=streamingGrpc,proto3,oneof"`
}
type StreamTapsRequest ¶
type StreamTapsRequest struct { // Identifier data effectively is a structured metadata. As a performance optimization this will // only be sent in the first message on the stream. Identifier *StreamTapsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // The trace id. this can be used to merge together a streaming trace. Note that the trace_id // is not guaranteed to be spatially or temporally unique. TraceId uint64 `protobuf:"varint,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // The trace data. Trace *v2alpha.TraceWrapper `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] Stream message for the Tap API. Envoy will open a stream to the server and stream taps without ever expecting a response.
func (*StreamTapsRequest) Descriptor ¶
func (*StreamTapsRequest) Descriptor() ([]byte, []int)
func (*StreamTapsRequest) GetIdentifier ¶
func (m *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier
func (*StreamTapsRequest) GetTrace ¶
func (m *StreamTapsRequest) GetTrace() *v2alpha.TraceWrapper
func (*StreamTapsRequest) GetTraceId ¶
func (m *StreamTapsRequest) GetTraceId() uint64
func (*StreamTapsRequest) ProtoMessage ¶
func (*StreamTapsRequest) ProtoMessage()
func (*StreamTapsRequest) Reset ¶
func (m *StreamTapsRequest) Reset()
func (*StreamTapsRequest) String ¶
func (m *StreamTapsRequest) String() string
func (*StreamTapsRequest) XXX_DiscardUnknown ¶
func (m *StreamTapsRequest) XXX_DiscardUnknown()
func (*StreamTapsRequest) XXX_Marshal ¶
func (m *StreamTapsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamTapsRequest) XXX_Merge ¶
func (m *StreamTapsRequest) XXX_Merge(src proto.Message)
func (*StreamTapsRequest) XXX_Size ¶
func (m *StreamTapsRequest) XXX_Size() int
func (*StreamTapsRequest) XXX_Unmarshal ¶
func (m *StreamTapsRequest) XXX_Unmarshal(b []byte) error
type StreamTapsRequest_Identifier ¶
type StreamTapsRequest_Identifier struct { // The node sending taps over the stream. Node *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // The opaque identifier that was set in the :ref:`output config // <envoy_api_field_service.tap.v2alpha.StreamingGrpcSink.tap_id>`. TapId string `protobuf:"bytes,2,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamTapsRequest_Identifier) Descriptor ¶
func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)
func (*StreamTapsRequest_Identifier) GetNode ¶
func (m *StreamTapsRequest_Identifier) GetNode() *core.Node
func (*StreamTapsRequest_Identifier) GetTapId ¶
func (m *StreamTapsRequest_Identifier) GetTapId() string
func (*StreamTapsRequest_Identifier) ProtoMessage ¶
func (*StreamTapsRequest_Identifier) ProtoMessage()
func (*StreamTapsRequest_Identifier) Reset ¶
func (m *StreamTapsRequest_Identifier) Reset()
func (*StreamTapsRequest_Identifier) String ¶
func (m *StreamTapsRequest_Identifier) String() string
func (*StreamTapsRequest_Identifier) XXX_DiscardUnknown ¶
func (m *StreamTapsRequest_Identifier) XXX_DiscardUnknown()
func (*StreamTapsRequest_Identifier) XXX_Marshal ¶
func (m *StreamTapsRequest_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamTapsRequest_Identifier) XXX_Merge ¶
func (m *StreamTapsRequest_Identifier) XXX_Merge(src proto.Message)
func (*StreamTapsRequest_Identifier) XXX_Size ¶
func (m *StreamTapsRequest_Identifier) XXX_Size() int
func (*StreamTapsRequest_Identifier) XXX_Unmarshal ¶
func (m *StreamTapsRequest_Identifier) XXX_Unmarshal(b []byte) error
type StreamTapsResponse ¶
type StreamTapsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:]
func (*StreamTapsResponse) Descriptor ¶
func (*StreamTapsResponse) Descriptor() ([]byte, []int)
func (*StreamTapsResponse) ProtoMessage ¶
func (*StreamTapsResponse) ProtoMessage()
func (*StreamTapsResponse) Reset ¶
func (m *StreamTapsResponse) Reset()
func (*StreamTapsResponse) String ¶
func (m *StreamTapsResponse) String() string
func (*StreamTapsResponse) XXX_DiscardUnknown ¶
func (m *StreamTapsResponse) XXX_DiscardUnknown()
func (*StreamTapsResponse) XXX_Marshal ¶
func (m *StreamTapsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamTapsResponse) XXX_Merge ¶
func (m *StreamTapsResponse) XXX_Merge(src proto.Message)
func (*StreamTapsResponse) XXX_Size ¶
func (m *StreamTapsResponse) XXX_Size() int
func (*StreamTapsResponse) XXX_Unmarshal ¶
func (m *StreamTapsResponse) XXX_Unmarshal(b []byte) error
type StreamingAdminSink ¶
type StreamingAdminSink struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Streaming admin sink configuration.
func (*StreamingAdminSink) Descriptor ¶
func (*StreamingAdminSink) Descriptor() ([]byte, []int)
func (*StreamingAdminSink) ProtoMessage ¶
func (*StreamingAdminSink) ProtoMessage()
func (*StreamingAdminSink) Reset ¶
func (m *StreamingAdminSink) Reset()
func (*StreamingAdminSink) String ¶
func (m *StreamingAdminSink) String() string
func (*StreamingAdminSink) XXX_DiscardUnknown ¶
func (m *StreamingAdminSink) XXX_DiscardUnknown()
func (*StreamingAdminSink) XXX_Marshal ¶
func (m *StreamingAdminSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingAdminSink) XXX_Merge ¶
func (m *StreamingAdminSink) XXX_Merge(src proto.Message)
func (*StreamingAdminSink) XXX_Size ¶
func (m *StreamingAdminSink) XXX_Size() int
func (*StreamingAdminSink) XXX_Unmarshal ¶
func (m *StreamingAdminSink) XXX_Unmarshal(b []byte) error
type StreamingGrpcSink ¶
type StreamingGrpcSink struct { // Opaque identifier, that will be sent back to the streaming grpc server. TapId string `protobuf:"bytes,1,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"` // The gRPC server that hosts the Tap Sink Service. GrpcService *core.GrpcService `protobuf:"bytes,2,opt,name=grpc_service,json=grpcService,proto3" json:"grpc_service,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] Streaming gRPC sink configuration sends the taps to an external gRPC server.
func (*StreamingGrpcSink) Descriptor ¶
func (*StreamingGrpcSink) Descriptor() ([]byte, []int)
func (*StreamingGrpcSink) GetGrpcService ¶
func (m *StreamingGrpcSink) GetGrpcService() *core.GrpcService
func (*StreamingGrpcSink) GetTapId ¶
func (m *StreamingGrpcSink) GetTapId() string
func (*StreamingGrpcSink) ProtoMessage ¶
func (*StreamingGrpcSink) ProtoMessage()
func (*StreamingGrpcSink) Reset ¶
func (m *StreamingGrpcSink) Reset()
func (*StreamingGrpcSink) String ¶
func (m *StreamingGrpcSink) String() string
func (*StreamingGrpcSink) XXX_DiscardUnknown ¶
func (m *StreamingGrpcSink) XXX_DiscardUnknown()
func (*StreamingGrpcSink) XXX_Marshal ¶
func (m *StreamingGrpcSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingGrpcSink) XXX_Merge ¶
func (m *StreamingGrpcSink) XXX_Merge(src proto.Message)
func (*StreamingGrpcSink) XXX_Size ¶
func (m *StreamingGrpcSink) XXX_Size() int
func (*StreamingGrpcSink) XXX_Unmarshal ¶
func (m *StreamingGrpcSink) XXX_Unmarshal(b []byte) error
type TapConfig ¶
type TapConfig struct { // The match configuration. If the configuration matches the data source being tapped, a tap will // occur, with the result written to the configured output. MatchConfig *MatchPredicate `protobuf:"bytes,1,opt,name=match_config,json=matchConfig,proto3" json:"match_config,omitempty"` // The tap output configuration. If a match configuration matches a data source being tapped, // a tap will occur and the data will be written to the configured output. OutputConfig *OutputConfig `protobuf:"bytes,2,opt,name=output_config,json=outputConfig,proto3" json:"output_config,omitempty"` // [#not-implemented-hide:] Specify if Tap matching is enabled. The % of requests\connections for // which the tap matching is enabled. When not enabled, the request\connection will not be // recorded. // // .. note:: // // This field defaults to 100/:ref:`HUNDRED // <envoy_api_enum_type.FractionalPercent.DenominatorType>`. TapEnabled *core.RuntimeFractionalPercent `protobuf:"bytes,3,opt,name=tap_enabled,json=tapEnabled,proto3" json:"tap_enabled,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Tap configuration.
func (*TapConfig) Descriptor ¶
func (*TapConfig) GetMatchConfig ¶
func (m *TapConfig) GetMatchConfig() *MatchPredicate
func (*TapConfig) GetOutputConfig ¶
func (m *TapConfig) GetOutputConfig() *OutputConfig
func (*TapConfig) GetTapEnabled ¶
func (m *TapConfig) GetTapEnabled() *core.RuntimeFractionalPercent
func (*TapConfig) ProtoMessage ¶
func (*TapConfig) ProtoMessage()
func (*TapConfig) XXX_DiscardUnknown ¶
func (m *TapConfig) XXX_DiscardUnknown()
func (*TapConfig) XXX_Marshal ¶
func (*TapConfig) XXX_Unmarshal ¶
type TapDiscoveryServiceClient ¶
type TapDiscoveryServiceClient interface { StreamTapConfigs(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_StreamTapConfigsClient, error) DeltaTapConfigs(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_DeltaTapConfigsClient, error) FetchTapConfigs(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error) }
TapDiscoveryServiceClient is the client API for TapDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTapDiscoveryServiceClient ¶
func NewTapDiscoveryServiceClient(cc *grpc.ClientConn) TapDiscoveryServiceClient
type TapDiscoveryServiceServer ¶
type TapDiscoveryServiceServer interface { StreamTapConfigs(TapDiscoveryService_StreamTapConfigsServer) error DeltaTapConfigs(TapDiscoveryService_DeltaTapConfigsServer) error FetchTapConfigs(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error) }
TapDiscoveryServiceServer is the server API for TapDiscoveryService service.
type TapDiscoveryService_DeltaTapConfigsClient ¶
type TapDiscoveryService_DeltaTapConfigsClient interface { Send(*v2.DeltaDiscoveryRequest) error Recv() (*v2.DeltaDiscoveryResponse, error) grpc.ClientStream }
type TapDiscoveryService_DeltaTapConfigsServer ¶
type TapDiscoveryService_DeltaTapConfigsServer interface { Send(*v2.DeltaDiscoveryResponse) error Recv() (*v2.DeltaDiscoveryRequest, error) grpc.ServerStream }
type TapDiscoveryService_StreamTapConfigsClient ¶
type TapDiscoveryService_StreamTapConfigsClient interface { Send(*v2.DiscoveryRequest) error Recv() (*v2.DiscoveryResponse, error) grpc.ClientStream }
type TapDiscoveryService_StreamTapConfigsServer ¶
type TapDiscoveryService_StreamTapConfigsServer interface { Send(*v2.DiscoveryResponse) error Recv() (*v2.DiscoveryRequest, error) grpc.ServerStream }
type TapResource ¶
type TapResource struct { // The name of the tap configuration. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Tap config to apply Config *TapConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] A tap resource is essentially a tap configuration with a name The filter TapDS config references this name.
func (*TapResource) Descriptor ¶
func (*TapResource) Descriptor() ([]byte, []int)
func (*TapResource) GetConfig ¶
func (m *TapResource) GetConfig() *TapConfig
func (*TapResource) GetName ¶
func (m *TapResource) GetName() string
func (*TapResource) ProtoMessage ¶
func (*TapResource) ProtoMessage()
func (*TapResource) Reset ¶
func (m *TapResource) Reset()
func (*TapResource) String ¶
func (m *TapResource) String() string
func (*TapResource) XXX_DiscardUnknown ¶
func (m *TapResource) XXX_DiscardUnknown()
func (*TapResource) XXX_Marshal ¶
func (m *TapResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TapResource) XXX_Merge ¶
func (m *TapResource) XXX_Merge(src proto.Message)
func (*TapResource) XXX_Size ¶
func (m *TapResource) XXX_Size() int
func (*TapResource) XXX_Unmarshal ¶
func (m *TapResource) XXX_Unmarshal(b []byte) error
type TapSinkServiceClient ¶
type TapSinkServiceClient interface { // Envoy will connect and send StreamTapsRequest messages forever. It does not expect any // response to be sent as nothing would be done in the case of failure. The server should // disconnect if it expects Envoy to reconnect. StreamTaps(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error) }
TapSinkServiceClient is the client API for TapSinkService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTapSinkServiceClient ¶
func NewTapSinkServiceClient(cc *grpc.ClientConn) TapSinkServiceClient
type TapSinkServiceServer ¶
type TapSinkServiceServer interface { // Envoy will connect and send StreamTapsRequest messages forever. It does not expect any // response to be sent as nothing would be done in the case of failure. The server should // disconnect if it expects Envoy to reconnect. StreamTaps(TapSinkService_StreamTapsServer) error }
TapSinkServiceServer is the server API for TapSinkService service.
type TapSinkService_StreamTapsClient ¶
type TapSinkService_StreamTapsClient interface { Send(*StreamTapsRequest) error CloseAndRecv() (*StreamTapsResponse, error) grpc.ClientStream }
type TapSinkService_StreamTapsServer ¶
type TapSinkService_StreamTapsServer interface { SendAndClose(*StreamTapsResponse) error Recv() (*StreamTapsRequest, error) grpc.ServerStream }