Versions in this module Expand all Collapse all v1 v1.0.0 Jan 25, 2023 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 (m *FilePerTapSink) ValidateAll() error + func (x *FilePerTapSink) GetPathPrefix() string + func (x *FilePerTapSink) ProtoReflect() protoreflect.Message + func (x *FilePerTapSink) Reset() + func (x *FilePerTapSink) String() string + type FilePerTapSinkMultiError []error + func (m FilePerTapSinkMultiError) AllErrors() []error + func (m FilePerTapSinkMultiError) Error() 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 (m *HttpHeadersMatch) ValidateAll() error + func (x *HttpHeadersMatch) GetHeaders() []*route.HeaderMatcher + func (x *HttpHeadersMatch) ProtoReflect() protoreflect.Message + func (x *HttpHeadersMatch) Reset() + func (x *HttpHeadersMatch) String() string + type HttpHeadersMatchMultiError []error + func (m HttpHeadersMatchMultiError) AllErrors() []error + func (m HttpHeadersMatchMultiError) Error() 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 (m *MatchPredicate) ValidateAll() 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 MatchPredicateMultiError []error + func (m MatchPredicateMultiError) AllErrors() []error + func (m MatchPredicateMultiError) Error() 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 (m *MatchPredicate_MatchSet) ValidateAll() 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_MatchSetMultiError []error + func (m MatchPredicate_MatchSetMultiError) AllErrors() []error + func (m MatchPredicate_MatchSetMultiError) Error() 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 (m *OutputConfig) ValidateAll() 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 OutputConfigMultiError []error + func (m OutputConfigMultiError) AllErrors() []error + func (m OutputConfigMultiError) Error() 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 (m *OutputSink) ValidateAll() 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 OutputSinkMultiError []error + func (m OutputSinkMultiError) AllErrors() []error + func (m OutputSinkMultiError) Error() 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 (m *StreamTapsRequest) ValidateAll() 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 StreamTapsRequestMultiError []error + func (m StreamTapsRequestMultiError) AllErrors() []error + func (m StreamTapsRequestMultiError) Error() 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 (m *StreamTapsRequest_Identifier) ValidateAll() 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_IdentifierMultiError []error + func (m StreamTapsRequest_IdentifierMultiError) AllErrors() []error + func (m StreamTapsRequest_IdentifierMultiError) Error() 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 (m *StreamTapsResponse) ValidateAll() error + func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message + func (x *StreamTapsResponse) Reset() + func (x *StreamTapsResponse) String() string + type StreamTapsResponseMultiError []error + func (m StreamTapsResponseMultiError) AllErrors() []error + func (m StreamTapsResponseMultiError) Error() 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 (m *StreamingAdminSink) ValidateAll() error + func (x *StreamingAdminSink) ProtoReflect() protoreflect.Message + func (x *StreamingAdminSink) Reset() + func (x *StreamingAdminSink) String() string + type StreamingAdminSinkMultiError []error + func (m StreamingAdminSinkMultiError) AllErrors() []error + func (m StreamingAdminSinkMultiError) Error() 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 (m *StreamingGrpcSink) ValidateAll() 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 StreamingGrpcSinkMultiError []error + func (m StreamingGrpcSinkMultiError) AllErrors() []error + func (m StreamingGrpcSinkMultiError) Error() 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 (m *TapConfig) ValidateAll() 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 TapConfigMultiError []error + func (m TapConfigMultiError) AllErrors() []error + func (m TapConfigMultiError) Error() 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