v2alpha

Aug 9, 2024

Changes in this version

+ const TapSinkService_StreamTaps_FullMethodName

+ var TapSinkService_ServiceDesc = grpc.ServiceDesc

+ type UnsafeTapSinkServiceServer interface

Oct 28, 2021

Changes in this version

type FilePerTapSink

+ func (m *FilePerTapSink) ValidateAll() error

+ type FilePerTapSinkMultiError []error

+ func (m FilePerTapSinkMultiError) AllErrors() []error

+ func (m FilePerTapSinkMultiError) Error() string

type HttpHeadersMatch

+ func (m *HttpHeadersMatch) ValidateAll() error

+ type HttpHeadersMatchMultiError []error

+ func (m HttpHeadersMatchMultiError) AllErrors() []error

+ func (m HttpHeadersMatchMultiError) Error() string

type MatchPredicate

+ func (m *MatchPredicate) ValidateAll() error

+ type MatchPredicateMultiError []error

+ func (m MatchPredicateMultiError) AllErrors() []error

+ func (m MatchPredicateMultiError) Error() string

type MatchPredicate_MatchSet

+ func (m *MatchPredicate_MatchSet) ValidateAll() error

+ type MatchPredicate_MatchSetMultiError []error

+ func (m MatchPredicate_MatchSetMultiError) AllErrors() []error

+ func (m MatchPredicate_MatchSetMultiError) Error() string

type OutputConfig

+ func (m *OutputConfig) ValidateAll() error

+ type OutputConfigMultiError []error

+ func (m OutputConfigMultiError) AllErrors() []error

+ func (m OutputConfigMultiError) Error() string

type OutputSink

+ func (m *OutputSink) ValidateAll() error

+ type OutputSinkMultiError []error

+ func (m OutputSinkMultiError) AllErrors() []error

+ func (m OutputSinkMultiError) Error() string

type StreamTapsRequest

+ func (m *StreamTapsRequest) ValidateAll() error

+ type StreamTapsRequestMultiError []error

+ func (m StreamTapsRequestMultiError) AllErrors() []error

+ func (m StreamTapsRequestMultiError) Error() string

type StreamTapsRequest_Identifier

+ func (m *StreamTapsRequest_Identifier) ValidateAll() error

+ type StreamTapsRequest_IdentifierMultiError []error

+ func (m StreamTapsRequest_IdentifierMultiError) AllErrors() []error

+ func (m StreamTapsRequest_IdentifierMultiError) Error() string

type StreamTapsResponse

+ func (m *StreamTapsResponse) ValidateAll() error

+ type StreamTapsResponseMultiError []error

+ func (m StreamTapsResponseMultiError) AllErrors() []error

+ func (m StreamTapsResponseMultiError) Error() string

type StreamingAdminSink

+ func (m *StreamingAdminSink) ValidateAll() error

+ type StreamingAdminSinkMultiError []error

+ func (m StreamingAdminSinkMultiError) AllErrors() []error

+ func (m StreamingAdminSinkMultiError) Error() string

type StreamingGrpcSink

+ func (m *StreamingGrpcSink) ValidateAll() error

+ type StreamingGrpcSinkMultiError []error

+ func (m StreamingGrpcSinkMultiError) AllErrors() []error

+ func (m StreamingGrpcSinkMultiError) Error() string

type TapConfig

+ func (m *TapConfig) ValidateAll() error

+ type TapConfigMultiError []error

+ func (m TapConfigMultiError) AllErrors() []error

+ func (m TapConfigMultiError) Error() string

Jul 5, 2020

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 File_envoy_service_tap_v2alpha_tapds_proto protoreflect.FileDescriptor

type FilePerTapSink

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

type HttpHeadersMatch

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

type MatchPredicate

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

type MatchPredicate_MatchSet

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

type OutputConfig

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

type OutputSink

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

type OutputSink_Format

+ func (OutputSink_Format) Descriptor() protoreflect.EnumDescriptor

+ func (OutputSink_Format) Type() protoreflect.EnumType

+ func (x OutputSink_Format) Enum() *OutputSink_Format

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

type StreamTapsRequest

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

type StreamTapsRequest_Identifier

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

type StreamTapsResponse

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

type StreamingAdminSink

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

type StreamingGrpcSink

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

type TapConfig

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

type TapResource

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

Nov 9, 2019

Changes in this version

+ type UnimplementedTapDiscoveryServiceServer struct

+ func (*UnimplementedTapDiscoveryServiceServer) DeltaTapConfigs(srv TapDiscoveryService_DeltaTapConfigsServer) error

+ func (*UnimplementedTapDiscoveryServiceServer) FetchTapConfigs(ctx context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (*UnimplementedTapDiscoveryServiceServer) StreamTapConfigs(srv TapDiscoveryService_StreamTapConfigsServer) error

+ type UnimplementedTapSinkServiceServer struct

+ func (*UnimplementedTapSinkServiceServer) StreamTaps(srv TapSinkService_StreamTapsServer) error

Sep 10, 2019

Changes in this version

type MatchPredicate

+ func (*MatchPredicate) XXX_OneofWrappers() []interface{}

type OutputSink

+ func (*OutputSink) XXX_OneofWrappers() []interface{}

Jul 8, 2019

Changes in this version

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

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

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

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

+ func RegisterTapDiscoveryServiceServer(s *grpc.Server, srv TapDiscoveryServiceServer)

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

type OutputSink

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

+ type OutputSink_StreamingGrpc struct

+ StreamingGrpc *StreamingGrpcSink

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

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

+ type StreamTapsRequest struct

+ Identifier *StreamTapsRequest_Identifier

+ Trace *v2alpha.TraceWrapper

+ TraceId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamTapsRequest) ProtoMessage()

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

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

+ func (m *StreamTapsRequest) GetTraceId() uint64

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

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

+ func (m *StreamTapsRequest) Reset()

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

+ func (m *StreamTapsRequest) String() string

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

+ func (m *StreamTapsRequest) Validate() error

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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamTapsRequest_Identifier) ProtoMessage()

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

+ func (m *StreamTapsRequest_Identifier) GetTapId() string

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

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

+ func (m *StreamTapsRequest_Identifier) Reset()

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

+ func (m *StreamTapsRequest_Identifier) String() string

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

+ func (m *StreamTapsRequest_Identifier) Validate() error

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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamTapsResponse) ProtoMessage()

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

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

+ func (m *StreamTapsResponse) Reset()

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

+ func (m *StreamTapsResponse) String() string

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

+ func (m *StreamTapsResponse) Validate() error

+ 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 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 StreamingGrpcSink struct

+ GrpcService *core.GrpcService

+ TapId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamingGrpcSink) ProtoMessage()

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

+ func (m *StreamingGrpcSink) GetTapId() string

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

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

+ func (m *StreamingGrpcSink) Reset()

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

+ func (m *StreamingGrpcSink) String() string

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

+ func (m *StreamingGrpcSink) Validate() error

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

+ TapEnabled *core.RuntimeFractionalPercent

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

+ type TapDiscoveryServiceClient interface

+ DeltaTapConfigs func(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_DeltaTapConfigsClient, error)

+ FetchTapConfigs func(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.DiscoveryResponse, error)

+ StreamTapConfigs func(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_StreamTapConfigsClient, error)

+ func NewTapDiscoveryServiceClient(cc *grpc.ClientConn) TapDiscoveryServiceClient

+ type TapDiscoveryServiceServer interface

+ DeltaTapConfigs func(TapDiscoveryService_DeltaTapConfigsServer) error

+ FetchTapConfigs func(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ StreamTapConfigs func(TapDiscoveryService_StreamTapConfigsServer) error

+ type TapDiscoveryService_DeltaTapConfigsClient interface

+ Recv func() (*v2.DeltaDiscoveryResponse, error)

+ Send func(*v2.DeltaDiscoveryRequest) error

+ type TapDiscoveryService_DeltaTapConfigsServer interface

+ Recv func() (*v2.DeltaDiscoveryRequest, error)

+ Send func(*v2.DeltaDiscoveryResponse) error

+ type TapDiscoveryService_StreamTapConfigsClient interface

+ Recv func() (*v2.DiscoveryResponse, error)

+ Send func(*v2.DiscoveryRequest) error

+ type TapDiscoveryService_StreamTapConfigsServer interface

+ Recv func() (*v2.DiscoveryRequest, error)

+ Send func(*v2.DiscoveryResponse) error

+ type TapResource struct

+ Config *TapConfig

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TapResource) ProtoMessage()

+ func (m *TapResource) GetConfig() *TapConfig

+ func (m *TapResource) GetName() string

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

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

+ func (m *TapResource) Reset()

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

+ func (m *TapResource) String() string

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

+ func (m *TapResource) Validate() error

+ 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 TapResourceValidationError struct

+ func (e TapResourceValidationError) Cause() error

+ func (e TapResourceValidationError) Error() string

+ func (e TapResourceValidationError) ErrorName() string

+ func (e TapResourceValidationError) Field() string

+ func (e TapResourceValidationError) Key() bool

+ func (e TapResourceValidationError) Reason() string

+ type TapSinkServiceClient interface

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

+ func NewTapSinkServiceClient(cc *grpc.ClientConn) 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

Apr 8, 2019

Changes in this version

type FilePerTapSinkValidationError

+ func (e FilePerTapSinkValidationError) ErrorName() string

type HttpHeadersMatchValidationError

+ func (e HttpHeadersMatchValidationError) ErrorName() string

type MatchPredicateValidationError

+ func (e MatchPredicateValidationError) ErrorName() string

type MatchPredicate_MatchSetValidationError

+ func (e MatchPredicate_MatchSetValidationError) ErrorName() string

type OutputConfigValidationError

+ func (e OutputConfigValidationError) ErrorName() string

type OutputSinkValidationError

+ func (e OutputSinkValidationError) ErrorName() string

type StreamingAdminSinkValidationError

+ func (e StreamingAdminSinkValidationError) ErrorName() string

type TapConfigValidationError

+ func (e TapConfigValidationError) ErrorName() string

Mar 11, 2019

Changes in this version

type OutputConfig

+ Streaming bool

+ func (m *OutputConfig) GetStreaming() bool

type OutputSink_Format

+ const OutputSink_PROTO_BINARY_LENGTH_DELIMITED

Mar 1, 2019

Changes in this version

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

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

+ var OutputSink_Format_name = map[int32]string

+ var OutputSink_Format_value = map[string]int32

+ type FilePerTapSink struct

+ PathPrefix string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*FilePerTapSink) ProtoMessage()

+ func (m *FilePerTapSink) GetPathPrefix() string

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

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

+ func (m *FilePerTapSink) Reset()

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

+ func (m *FilePerTapSink) String() string

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

+ func (m *FilePerTapSink) Validate() 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 FilePerTapSinkValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e FilePerTapSinkValidationError) Error() string

+ type HttpHeadersMatch struct

+ Headers []*route.HeaderMatcher

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HttpHeadersMatch) ProtoMessage()

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

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

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

+ func (m *HttpHeadersMatch) Reset()

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

+ func (m *HttpHeadersMatch) String() string

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

+ func (m *HttpHeadersMatch) Validate() 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 HttpHeadersMatchValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e HttpHeadersMatchValidationError) Error() string

+ type MatchPredicate struct

+ Rule isMatchPredicate_Rule

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MatchPredicate) ProtoMessage()

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

+ 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 (m *MatchPredicate) Marshal() (dAtA []byte, err error)

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

+ func (m *MatchPredicate) Reset()

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

+ func (m *MatchPredicate) String() string

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

+ func (m *MatchPredicate) Validate() 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 MatchPredicateValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e MatchPredicateValidationError) Error() string

+ type MatchPredicate_AndMatch struct

+ AndMatch *MatchPredicate_MatchSet

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

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

+ type MatchPredicate_AnyMatch struct

+ AnyMatch bool

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

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

+ type MatchPredicate_HttpRequestHeadersMatch struct

+ HttpRequestHeadersMatch *HttpHeadersMatch

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

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

+ type MatchPredicate_HttpRequestTrailersMatch struct

+ HttpRequestTrailersMatch *HttpHeadersMatch

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

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

+ type MatchPredicate_HttpResponseHeadersMatch struct

+ HttpResponseHeadersMatch *HttpHeadersMatch

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

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

+ type MatchPredicate_HttpResponseTrailersMatch struct

+ HttpResponseTrailersMatch *HttpHeadersMatch

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

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

+ type MatchPredicate_MatchSet struct

+ Rules []*MatchPredicate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MatchPredicate_MatchSet) ProtoMessage()

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

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

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

+ func (m *MatchPredicate_MatchSet) Reset()

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

+ func (m *MatchPredicate_MatchSet) String() string

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

+ func (m *MatchPredicate_MatchSet) Validate() 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_MatchSetValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e MatchPredicate_MatchSetValidationError) Error() string

+ type MatchPredicate_NotMatch struct

+ NotMatch *MatchPredicate

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

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

+ type MatchPredicate_OrMatch struct

+ OrMatch *MatchPredicate_MatchSet

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

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

+ type OutputConfig struct

+ MaxBufferedRxBytes *types.UInt32Value

+ MaxBufferedTxBytes *types.UInt32Value

+ Sinks []*OutputSink

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OutputConfig) ProtoMessage()

+ func (m *OutputConfig) GetMaxBufferedRxBytes() *types.UInt32Value

+ func (m *OutputConfig) GetMaxBufferedTxBytes() *types.UInt32Value

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

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

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

+ func (m *OutputConfig) Reset()

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

+ func (m *OutputConfig) String() string

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

+ func (m *OutputConfig) Validate() 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 OutputConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e OutputConfigValidationError) Error() string

+ type OutputSink struct

+ Format OutputSink_Format

+ OutputSinkType isOutputSink_OutputSinkType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OutputSink) ProtoMessage()

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

+ 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) Marshal() (dAtA []byte, err error)

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

+ func (m *OutputSink) Reset()

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

+ func (m *OutputSink) String() string

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

+ func (m *OutputSink) Validate() 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 OutputSinkValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e OutputSinkValidationError) Error() string

+ type OutputSink_FilePerTap struct

+ FilePerTap *FilePerTapSink

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

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

+ type OutputSink_Format int32

+ const OutputSink_JSON_BODY_AS_BYTES

+ const OutputSink_JSON_BODY_AS_STRING

+ const OutputSink_PROTO_BINARY

+ const OutputSink_PROTO_TEXT

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

+ func (x OutputSink_Format) String() string

+ type OutputSink_StreamingAdmin struct

+ StreamingAdmin *StreamingAdminSink

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

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

+ type StreamingAdminSink struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamingAdminSink) ProtoMessage()

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

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

+ func (m *StreamingAdminSink) Reset()

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

+ func (m *StreamingAdminSink) String() string

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

+ func (m *StreamingAdminSink) Validate() 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 StreamingAdminSinkValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e StreamingAdminSinkValidationError) Error() string

+ type TapConfig struct

+ MatchConfig *MatchPredicate

+ OutputConfig *OutputConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TapConfig) ProtoMessage()

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

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

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

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

+ func (m *TapConfig) Reset()

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

+ func (m *TapConfig) String() string

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

+ func (m *TapConfig) Validate() 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

+ type TapConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e TapConfigValidationError) Error() string