envoy_service_tap_v2alpha

package

Go to main page

Versions in this module

v0

v0.9.13

Jun 10, 2021

v0.9.11

Jan 5, 2021

v0.9.10

Jan 5, 2021

v0.9.9

Jan 4, 2021

v0.9.8-felix

Jan 4, 2021

v0.7.1

Apr 19, 2019

v0.7.0

Apr 8, 2019

v0.6.9

Mar 11, 2019

v0.6.8

Mar 1, 2019

Changes in this version

+ var ErrIntOverflowCommon = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCommon = fmt.Errorf("proto: negative length found during unmarshaling")

type FilePerTapSink

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FilePerTapSink) Marshal() (dAtA []byte, err error)

+ func (m *FilePerTapSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *FilePerTapSink) Size() (n int)

+ func (m *FilePerTapSink) Unmarshal(dAtA []byte) error

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *HttpHeadersMatch) Marshal() (dAtA []byte, err error)

+ func (m *HttpHeadersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *HttpHeadersMatch) Size() (n int)

+ func (m *HttpHeadersMatch) Unmarshal(dAtA []byte) error

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MatchPredicate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *MatchPredicate) Marshal() (dAtA []byte, err error)

+ func (m *MatchPredicate) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate) Size() (n int)

+ func (m *MatchPredicate) Unmarshal(dAtA []byte) error

+ 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 (m *MatchPredicate) XXX_Size() int

+ func (m *MatchPredicate) XXX_Unmarshal(b []byte) error

type MatchPredicate_AndMatch

+ func (m *MatchPredicate_AndMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_AndMatch) Size() (n int)

type MatchPredicate_AnyMatch

+ func (m *MatchPredicate_AnyMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_AnyMatch) Size() (n int)

type MatchPredicate_HttpRequestHeadersMatch

+ func (m *MatchPredicate_HttpRequestHeadersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpRequestHeadersMatch) Size() (n int)

type MatchPredicate_HttpRequestTrailersMatch

+ func (m *MatchPredicate_HttpRequestTrailersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpRequestTrailersMatch) Size() (n int)

type MatchPredicate_HttpResponseHeadersMatch

+ func (m *MatchPredicate_HttpResponseHeadersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpResponseHeadersMatch) Size() (n int)

type MatchPredicate_HttpResponseTrailersMatch

+ func (m *MatchPredicate_HttpResponseTrailersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpResponseTrailersMatch) Size() (n int)

type MatchPredicate_MatchSet

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *MatchPredicate_MatchSet) Marshal() (dAtA []byte, err error)

+ func (m *MatchPredicate_MatchSet) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_MatchSet) Size() (n int)

+ func (m *MatchPredicate_MatchSet) Unmarshal(dAtA []byte) error

+ 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

+ func (m *MatchPredicate_NotMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_NotMatch) Size() (n int)

type MatchPredicate_OrMatch

+ func (m *MatchPredicate_OrMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_OrMatch) Size() (n int)

type OutputConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *OutputConfig) Marshal() (dAtA []byte, err error)

+ func (m *OutputConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputConfig) Size() (n int)

+ func (m *OutputConfig) Unmarshal(dAtA []byte) error

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OutputSink) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *OutputSink) Marshal() (dAtA []byte, err error)

+ func (m *OutputSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink) Size() (n int)

+ func (m *OutputSink) Unmarshal(dAtA []byte) error

+ 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 (m *OutputSink) XXX_Size() int

+ func (m *OutputSink) XXX_Unmarshal(b []byte) error

type OutputSink_FilePerTap

+ func (m *OutputSink_FilePerTap) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink_FilePerTap) Size() (n int)

type OutputSink_StreamingAdmin

+ func (m *OutputSink_StreamingAdmin) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink_StreamingAdmin) Size() (n int)

type StreamingAdminSink

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StreamingAdminSink) Marshal() (dAtA []byte, err error)

+ func (m *StreamingAdminSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamingAdminSink) Size() (n int)

+ func (m *StreamingAdminSink) Unmarshal(dAtA []byte) error

+ 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 TapConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TapConfig) Marshal() (dAtA []byte, err error)

+ func (m *TapConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *TapConfig) Size() (n int)

+ func (m *TapConfig) Unmarshal(dAtA []byte) error

+ 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

v0.0.12

Nov 3, 2021

v0.0.11

Sep 6, 2021

v0.0.10

Sep 6, 2021

v0.0.9

Aug 31, 2021

v0.0.7

Aug 18, 2021

v0.0.6

Jun 15, 2021

Changes in this version

+ var File_envoy_service_tap_v2alpha_common_proto protoreflect.FileDescriptor

+ var File_envoy_service_tap_v2alpha_tap_proto protoreflect.FileDescriptor

+ var OutputSink_Format_name = map[int32]string

+ var OutputSink_Format_value = map[string]int32

+ func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer)

+ type FilePerTapSink struct

+ PathPrefix string

+ func (*FilePerTapSink) Descriptor() ([]byte, []int)

+ func (*FilePerTapSink) ProtoMessage()

+ func (m *FilePerTapSink) Validate() error

+ func (x *FilePerTapSink) GetPathPrefix() string

+ func (x *FilePerTapSink) ProtoReflect() protoreflect.Message

+ func (x *FilePerTapSink) Reset()

+ func (x *FilePerTapSink) String() string

+ type FilePerTapSinkValidationError struct

+ func (e FilePerTapSinkValidationError) Cause() error

+ func (e FilePerTapSinkValidationError) Error() string

+ func (e FilePerTapSinkValidationError) ErrorName() string

+ func (e FilePerTapSinkValidationError) Field() string

+ func (e FilePerTapSinkValidationError) Key() bool

+ func (e FilePerTapSinkValidationError) Reason() string

+ type HttpHeadersMatch struct

+ Headers []*route.HeaderMatcher

+ func (*HttpHeadersMatch) Descriptor() ([]byte, []int)

+ func (*HttpHeadersMatch) ProtoMessage()

+ func (m *HttpHeadersMatch) Validate() error

+ func (x *HttpHeadersMatch) GetHeaders() []*route.HeaderMatcher

+ func (x *HttpHeadersMatch) ProtoReflect() protoreflect.Message

+ func (x *HttpHeadersMatch) Reset()

+ func (x *HttpHeadersMatch) String() string

+ type HttpHeadersMatchValidationError struct

+ func (e HttpHeadersMatchValidationError) Cause() error

+ func (e HttpHeadersMatchValidationError) Error() string

+ func (e HttpHeadersMatchValidationError) ErrorName() string

+ func (e HttpHeadersMatchValidationError) Field() string

+ func (e HttpHeadersMatchValidationError) Key() bool

+ func (e HttpHeadersMatchValidationError) Reason() string

+ type MatchPredicate struct

+ Rule isMatchPredicate_Rule

+ func (*MatchPredicate) Descriptor() ([]byte, []int)

+ func (*MatchPredicate) ProtoMessage()

+ func (m *MatchPredicate) GetRule() isMatchPredicate_Rule

+ func (m *MatchPredicate) Validate() error

+ func (x *MatchPredicate) GetAndMatch() *MatchPredicate_MatchSet

+ func (x *MatchPredicate) GetAnyMatch() bool

+ func (x *MatchPredicate) GetHttpRequestHeadersMatch() *HttpHeadersMatch

+ func (x *MatchPredicate) GetHttpRequestTrailersMatch() *HttpHeadersMatch

+ func (x *MatchPredicate) GetHttpResponseHeadersMatch() *HttpHeadersMatch

+ func (x *MatchPredicate) GetHttpResponseTrailersMatch() *HttpHeadersMatch

+ func (x *MatchPredicate) GetNotMatch() *MatchPredicate

+ func (x *MatchPredicate) GetOrMatch() *MatchPredicate_MatchSet

+ func (x *MatchPredicate) ProtoReflect() protoreflect.Message

+ func (x *MatchPredicate) Reset()

+ func (x *MatchPredicate) String() string

+ type MatchPredicateValidationError struct

+ func (e MatchPredicateValidationError) Cause() error

+ func (e MatchPredicateValidationError) Error() string

+ func (e MatchPredicateValidationError) ErrorName() string

+ func (e MatchPredicateValidationError) Field() string

+ func (e MatchPredicateValidationError) Key() bool

+ func (e MatchPredicateValidationError) Reason() string

+ type MatchPredicate_AndMatch struct

+ AndMatch *MatchPredicate_MatchSet

+ type MatchPredicate_AnyMatch struct

+ AnyMatch bool

+ type MatchPredicate_HttpRequestHeadersMatch struct

+ HttpRequestHeadersMatch *HttpHeadersMatch

+ type MatchPredicate_HttpRequestTrailersMatch struct

+ HttpRequestTrailersMatch *HttpHeadersMatch

+ type MatchPredicate_HttpResponseHeadersMatch struct

+ HttpResponseHeadersMatch *HttpHeadersMatch

+ type MatchPredicate_HttpResponseTrailersMatch struct

+ HttpResponseTrailersMatch *HttpHeadersMatch

+ type MatchPredicate_MatchSet struct

+ Rules []*MatchPredicate

+ func (*MatchPredicate_MatchSet) Descriptor() ([]byte, []int)

+ func (*MatchPredicate_MatchSet) ProtoMessage()

+ func (m *MatchPredicate_MatchSet) Validate() error

+ func (x *MatchPredicate_MatchSet) GetRules() []*MatchPredicate

+ func (x *MatchPredicate_MatchSet) ProtoReflect() protoreflect.Message

+ func (x *MatchPredicate_MatchSet) Reset()

+ func (x *MatchPredicate_MatchSet) String() string

+ type MatchPredicate_MatchSetValidationError struct

+ func (e MatchPredicate_MatchSetValidationError) Cause() error

+ func (e MatchPredicate_MatchSetValidationError) Error() string

+ func (e MatchPredicate_MatchSetValidationError) ErrorName() string

+ func (e MatchPredicate_MatchSetValidationError) Field() string

+ func (e MatchPredicate_MatchSetValidationError) Key() bool

+ func (e MatchPredicate_MatchSetValidationError) Reason() string

+ type MatchPredicate_NotMatch struct

+ NotMatch *MatchPredicate

+ type MatchPredicate_OrMatch struct

+ OrMatch *MatchPredicate_MatchSet

+ type OutputConfig struct

+ MaxBufferedRxBytes *wrappers.UInt32Value

+ MaxBufferedTxBytes *wrappers.UInt32Value

+ Sinks []*OutputSink

+ Streaming bool

+ func (*OutputConfig) Descriptor() ([]byte, []int)

+ func (*OutputConfig) ProtoMessage()

+ func (m *OutputConfig) Validate() error

+ func (x *OutputConfig) GetMaxBufferedRxBytes() *wrappers.UInt32Value

+ func (x *OutputConfig) GetMaxBufferedTxBytes() *wrappers.UInt32Value

+ func (x *OutputConfig) GetSinks() []*OutputSink

+ func (x *OutputConfig) GetStreaming() bool

+ func (x *OutputConfig) ProtoReflect() protoreflect.Message

+ func (x *OutputConfig) Reset()

+ func (x *OutputConfig) String() string

+ type OutputConfigValidationError struct

+ func (e OutputConfigValidationError) Cause() error

+ func (e OutputConfigValidationError) Error() string

+ func (e OutputConfigValidationError) ErrorName() string

+ func (e OutputConfigValidationError) Field() string

+ func (e OutputConfigValidationError) Key() bool

+ func (e OutputConfigValidationError) Reason() string

+ type OutputSink struct

+ Format OutputSink_Format

+ OutputSinkType isOutputSink_OutputSinkType

+ func (*OutputSink) Descriptor() ([]byte, []int)

+ func (*OutputSink) ProtoMessage()

+ func (m *OutputSink) GetOutputSinkType() isOutputSink_OutputSinkType

+ func (m *OutputSink) Validate() error

+ func (x *OutputSink) GetFilePerTap() *FilePerTapSink

+ func (x *OutputSink) GetFormat() OutputSink_Format

+ func (x *OutputSink) GetStreamingAdmin() *StreamingAdminSink

+ func (x *OutputSink) GetStreamingGrpc() *StreamingGrpcSink

+ func (x *OutputSink) ProtoReflect() protoreflect.Message

+ func (x *OutputSink) Reset()

+ func (x *OutputSink) String() string

+ type OutputSinkValidationError struct

+ func (e OutputSinkValidationError) Cause() error

+ func (e OutputSinkValidationError) Error() string

+ func (e OutputSinkValidationError) ErrorName() string

+ func (e OutputSinkValidationError) Field() string

+ func (e OutputSinkValidationError) Key() bool

+ func (e OutputSinkValidationError) Reason() string

+ type OutputSink_FilePerTap struct

+ FilePerTap *FilePerTapSink

+ type OutputSink_Format int32

+ const OutputSink_JSON_BODY_AS_BYTES

+ const OutputSink_JSON_BODY_AS_STRING

+ const OutputSink_PROTO_BINARY

+ const OutputSink_PROTO_BINARY_LENGTH_DELIMITED

+ const OutputSink_PROTO_TEXT

+ func (OutputSink_Format) Descriptor() protoreflect.EnumDescriptor

+ func (OutputSink_Format) EnumDescriptor() ([]byte, []int)

+ func (OutputSink_Format) Type() protoreflect.EnumType

+ func (x OutputSink_Format) Enum() *OutputSink_Format

+ func (x OutputSink_Format) Number() protoreflect.EnumNumber

+ func (x OutputSink_Format) String() string

+ type OutputSink_StreamingAdmin struct

+ StreamingAdmin *StreamingAdminSink

+ type OutputSink_StreamingGrpc struct

+ StreamingGrpc *StreamingGrpcSink

+ type StreamTapsRequest struct

+ Identifier *StreamTapsRequest_Identifier

+ Trace *v2alpha.TraceWrapper

+ TraceId uint64

+ func (*StreamTapsRequest) Descriptor() ([]byte, []int)

+ func (*StreamTapsRequest) ProtoMessage()

+ func (m *StreamTapsRequest) Validate() error

+ func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier

+ func (x *StreamTapsRequest) GetTrace() *v2alpha.TraceWrapper

+ func (x *StreamTapsRequest) GetTraceId() uint64

+ func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message

+ func (x *StreamTapsRequest) Reset()

+ func (x *StreamTapsRequest) String() string

+ type StreamTapsRequestValidationError struct

+ func (e StreamTapsRequestValidationError) Cause() error

+ func (e StreamTapsRequestValidationError) Error() string

+ func (e StreamTapsRequestValidationError) ErrorName() string

+ func (e StreamTapsRequestValidationError) Field() string

+ func (e StreamTapsRequestValidationError) Key() bool

+ func (e StreamTapsRequestValidationError) Reason() string

+ type StreamTapsRequest_Identifier struct

+ Node *core.Node

+ TapId string

+ func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)

+ func (*StreamTapsRequest_Identifier) ProtoMessage()

+ func (m *StreamTapsRequest_Identifier) Validate() error

+ func (x *StreamTapsRequest_Identifier) GetNode() *core.Node

+ func (x *StreamTapsRequest_Identifier) GetTapId() string

+ func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message

+ func (x *StreamTapsRequest_Identifier) Reset()

+ func (x *StreamTapsRequest_Identifier) String() string

+ type StreamTapsRequest_IdentifierValidationError struct

+ func (e StreamTapsRequest_IdentifierValidationError) Cause() error

+ func (e StreamTapsRequest_IdentifierValidationError) Error() string

+ func (e StreamTapsRequest_IdentifierValidationError) ErrorName() string

+ func (e StreamTapsRequest_IdentifierValidationError) Field() string

+ func (e StreamTapsRequest_IdentifierValidationError) Key() bool

+ func (e StreamTapsRequest_IdentifierValidationError) Reason() string

+ type StreamTapsResponse struct

+ func (*StreamTapsResponse) Descriptor() ([]byte, []int)

+ func (*StreamTapsResponse) ProtoMessage()

+ func (m *StreamTapsResponse) Validate() error

+ func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message

+ func (x *StreamTapsResponse) Reset()

+ func (x *StreamTapsResponse) String() string

+ type StreamTapsResponseValidationError struct

+ func (e StreamTapsResponseValidationError) Cause() error

+ func (e StreamTapsResponseValidationError) Error() string

+ func (e StreamTapsResponseValidationError) ErrorName() string

+ func (e StreamTapsResponseValidationError) Field() string

+ func (e StreamTapsResponseValidationError) Key() bool

+ func (e StreamTapsResponseValidationError) Reason() string

+ type StreamingAdminSink struct

+ func (*StreamingAdminSink) Descriptor() ([]byte, []int)

+ func (*StreamingAdminSink) ProtoMessage()

+ func (m *StreamingAdminSink) Validate() error

+ func (x *StreamingAdminSink) ProtoReflect() protoreflect.Message

+ func (x *StreamingAdminSink) Reset()

+ func (x *StreamingAdminSink) String() string

+ type StreamingAdminSinkValidationError struct

+ func (e StreamingAdminSinkValidationError) Cause() error

+ func (e StreamingAdminSinkValidationError) Error() string

+ func (e StreamingAdminSinkValidationError) ErrorName() string

+ func (e StreamingAdminSinkValidationError) Field() string

+ func (e StreamingAdminSinkValidationError) Key() bool

+ func (e StreamingAdminSinkValidationError) Reason() string

+ type StreamingGrpcSink struct

+ GrpcService *core.GrpcService

+ TapId string

+ func (*StreamingGrpcSink) Descriptor() ([]byte, []int)

+ func (*StreamingGrpcSink) ProtoMessage()

+ func (m *StreamingGrpcSink) Validate() error

+ func (x *StreamingGrpcSink) GetGrpcService() *core.GrpcService

+ func (x *StreamingGrpcSink) GetTapId() string

+ func (x *StreamingGrpcSink) ProtoReflect() protoreflect.Message

+ func (x *StreamingGrpcSink) Reset()

+ func (x *StreamingGrpcSink) String() string

+ type StreamingGrpcSinkValidationError struct

+ func (e StreamingGrpcSinkValidationError) Cause() error

+ func (e StreamingGrpcSinkValidationError) Error() string

+ func (e StreamingGrpcSinkValidationError) ErrorName() string

+ func (e StreamingGrpcSinkValidationError) Field() string

+ func (e StreamingGrpcSinkValidationError) Key() bool

+ func (e StreamingGrpcSinkValidationError) Reason() string

+ type TapConfig struct

+ MatchConfig *MatchPredicate

+ OutputConfig *OutputConfig

+ TapEnabled *core.RuntimeFractionalPercent

+ func (*TapConfig) Descriptor() ([]byte, []int)

+ func (*TapConfig) ProtoMessage()

+ func (m *TapConfig) Validate() error

+ func (x *TapConfig) GetMatchConfig() *MatchPredicate

+ func (x *TapConfig) GetOutputConfig() *OutputConfig

+ func (x *TapConfig) GetTapEnabled() *core.RuntimeFractionalPercent

+ func (x *TapConfig) ProtoReflect() protoreflect.Message

+ func (x *TapConfig) Reset()

+ func (x *TapConfig) String() string

+ type TapConfigValidationError struct

+ func (e TapConfigValidationError) Cause() error

+ func (e TapConfigValidationError) Error() string

+ func (e TapConfigValidationError) ErrorName() string

+ func (e TapConfigValidationError) Field() string

+ func (e TapConfigValidationError) Key() bool

+ func (e TapConfigValidationError) Reason() string

+ type TapSinkServiceClient interface

+ StreamTaps func(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error)

+ func NewTapSinkServiceClient(cc grpc.ClientConnInterface) TapSinkServiceClient

+ type TapSinkServiceServer interface

+ StreamTaps func(TapSinkService_StreamTapsServer) error

+ type TapSinkService_StreamTapsClient interface

+ CloseAndRecv func() (*StreamTapsResponse, error)

+ Send func(*StreamTapsRequest) error

+ type TapSinkService_StreamTapsServer interface

+ Recv func() (*StreamTapsRequest, error)

+ SendAndClose func(*StreamTapsResponse) error

+ type UnimplementedTapSinkServiceServer struct

+ func (*UnimplementedTapSinkServiceServer) StreamTaps(TapSinkService_StreamTapsServer) error

v0.0.1

Jun 10, 2021

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