Documentation

Index

Constants

This section is empty.

Variables

View Source
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",
	}
	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,
	}
)

    Enum value maps for OutputSink_Format.

    View Source
    var File_envoy_service_tap_v2alpha_common_proto protoreflect.FileDescriptor
    View Source
    var File_envoy_service_tap_v2alpha_tap_proto protoreflect.FileDescriptor
    View Source
    var File_envoy_service_tap_v2alpha_tapds_proto protoreflect.FileDescriptor

    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 {
    	PathPrefix string `protobuf:"bytes,1,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
    	// contains filtered or unexported fields
    }

    func (*FilePerTapSink) Descriptor

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

      Deprecated: Use FilePerTapSink.ProtoReflect.Descriptor instead.

      func (*FilePerTapSink) GetPathPrefix

      func (x *FilePerTapSink) GetPathPrefix() string

      func (*FilePerTapSink) ProtoMessage

      func (*FilePerTapSink) ProtoMessage()

      func (*FilePerTapSink) ProtoReflect

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

      func (*FilePerTapSink) Reset

      func (x *FilePerTapSink) Reset()

      func (*FilePerTapSink) String

      func (x *FilePerTapSink) String() string

      func (*FilePerTapSink) Validate

      func (m *FilePerTapSink) Validate() error

        Validate checks the field values on FilePerTapSink with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

        type FilePerTapSinkValidationError

        type FilePerTapSinkValidationError struct {
        	// contains filtered or unexported fields
        }

          FilePerTapSinkValidationError is the validation error returned by FilePerTapSink.Validate if the designated constraints aren't met.

          func (FilePerTapSinkValidationError) Cause

            Cause function returns cause value.

            func (FilePerTapSinkValidationError) Error

              Error satisfies the builtin error interface

              func (FilePerTapSinkValidationError) ErrorName

              func (e FilePerTapSinkValidationError) ErrorName() string

                ErrorName returns error name.

                func (FilePerTapSinkValidationError) Field

                  Field function returns field value.

                  func (FilePerTapSinkValidationError) Key

                    Key function returns key value.

                    func (FilePerTapSinkValidationError) Reason

                      Reason function returns reason value.

                      type HttpHeadersMatch

                      type HttpHeadersMatch struct {
                      	Headers []*route.HeaderMatcher `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
                      	// contains filtered or unexported fields
                      }

                      func (*HttpHeadersMatch) Descriptor

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

                        Deprecated: Use HttpHeadersMatch.ProtoReflect.Descriptor instead.

                        func (*HttpHeadersMatch) GetHeaders

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

                        func (*HttpHeadersMatch) ProtoMessage

                        func (*HttpHeadersMatch) ProtoMessage()

                        func (*HttpHeadersMatch) ProtoReflect

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

                        func (*HttpHeadersMatch) Reset

                        func (x *HttpHeadersMatch) Reset()

                        func (*HttpHeadersMatch) String

                        func (x *HttpHeadersMatch) String() string

                        func (*HttpHeadersMatch) Validate

                        func (m *HttpHeadersMatch) Validate() error

                          Validate checks the field values on HttpHeadersMatch with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                          type HttpHeadersMatchValidationError

                          type HttpHeadersMatchValidationError struct {
                          	// contains filtered or unexported fields
                          }

                            HttpHeadersMatchValidationError is the validation error returned by HttpHeadersMatch.Validate if the designated constraints aren't met.

                            func (HttpHeadersMatchValidationError) Cause

                              Cause function returns cause value.

                              func (HttpHeadersMatchValidationError) Error

                                Error satisfies the builtin error interface

                                func (HttpHeadersMatchValidationError) ErrorName

                                  ErrorName returns error name.

                                  func (HttpHeadersMatchValidationError) Field

                                    Field function returns field value.

                                    func (HttpHeadersMatchValidationError) Key

                                      Key function returns key value.

                                      func (HttpHeadersMatchValidationError) Reason

                                        Reason function returns reason value.

                                        type MatchPredicate

                                        type MatchPredicate struct {
                                        
                                        	// Types that are assignable to Rule:
                                        	//	*MatchPredicate_OrMatch
                                        	//	*MatchPredicate_AndMatch
                                        	//	*MatchPredicate_NotMatch
                                        	//	*MatchPredicate_AnyMatch
                                        	//	*MatchPredicate_HttpRequestHeadersMatch
                                        	//	*MatchPredicate_HttpRequestTrailersMatch
                                        	//	*MatchPredicate_HttpResponseHeadersMatch
                                        	//	*MatchPredicate_HttpResponseTrailersMatch
                                        	Rule isMatchPredicate_Rule `protobuf_oneof:"rule"`
                                        	// contains filtered or unexported fields
                                        }

                                        func (*MatchPredicate) Descriptor

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

                                          Deprecated: Use MatchPredicate.ProtoReflect.Descriptor instead.

                                          func (*MatchPredicate) GetAndMatch

                                          func (x *MatchPredicate) GetAndMatch() *MatchPredicate_MatchSet

                                          func (*MatchPredicate) GetAnyMatch

                                          func (x *MatchPredicate) GetAnyMatch() bool

                                          func (*MatchPredicate) GetHttpRequestHeadersMatch

                                          func (x *MatchPredicate) GetHttpRequestHeadersMatch() *HttpHeadersMatch

                                          func (*MatchPredicate) GetHttpRequestTrailersMatch

                                          func (x *MatchPredicate) GetHttpRequestTrailersMatch() *HttpHeadersMatch

                                          func (*MatchPredicate) GetHttpResponseHeadersMatch

                                          func (x *MatchPredicate) GetHttpResponseHeadersMatch() *HttpHeadersMatch

                                          func (*MatchPredicate) GetHttpResponseTrailersMatch

                                          func (x *MatchPredicate) GetHttpResponseTrailersMatch() *HttpHeadersMatch

                                          func (*MatchPredicate) GetNotMatch

                                          func (x *MatchPredicate) GetNotMatch() *MatchPredicate

                                          func (*MatchPredicate) GetOrMatch

                                          func (x *MatchPredicate) GetOrMatch() *MatchPredicate_MatchSet

                                          func (*MatchPredicate) GetRule

                                          func (m *MatchPredicate) GetRule() isMatchPredicate_Rule

                                          func (*MatchPredicate) ProtoMessage

                                          func (*MatchPredicate) ProtoMessage()

                                          func (*MatchPredicate) ProtoReflect

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

                                          func (*MatchPredicate) Reset

                                          func (x *MatchPredicate) Reset()

                                          func (*MatchPredicate) String

                                          func (x *MatchPredicate) String() string

                                          func (*MatchPredicate) Validate

                                          func (m *MatchPredicate) Validate() error

                                            Validate checks the field values on MatchPredicate with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                            type MatchPredicateValidationError

                                            type MatchPredicateValidationError struct {
                                            	// contains filtered or unexported fields
                                            }

                                              MatchPredicateValidationError is the validation error returned by MatchPredicate.Validate if the designated constraints aren't met.

                                              func (MatchPredicateValidationError) Cause

                                                Cause function returns cause value.

                                                func (MatchPredicateValidationError) Error

                                                  Error satisfies the builtin error interface

                                                  func (MatchPredicateValidationError) ErrorName

                                                  func (e MatchPredicateValidationError) ErrorName() string

                                                    ErrorName returns error name.

                                                    func (MatchPredicateValidationError) Field

                                                      Field function returns field value.

                                                      func (MatchPredicateValidationError) Key

                                                        Key function returns key value.

                                                        func (MatchPredicateValidationError) Reason

                                                          Reason function returns reason value.

                                                          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 {
                                                          	Rules []*MatchPredicate `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
                                                          	// contains filtered or unexported fields
                                                          }

                                                          func (*MatchPredicate_MatchSet) Descriptor

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

                                                            Deprecated: Use MatchPredicate_MatchSet.ProtoReflect.Descriptor instead.

                                                            func (*MatchPredicate_MatchSet) GetRules

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

                                                            func (*MatchPredicate_MatchSet) ProtoMessage

                                                            func (*MatchPredicate_MatchSet) ProtoMessage()

                                                            func (*MatchPredicate_MatchSet) ProtoReflect

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

                                                            func (*MatchPredicate_MatchSet) Reset

                                                            func (x *MatchPredicate_MatchSet) Reset()

                                                            func (*MatchPredicate_MatchSet) String

                                                            func (x *MatchPredicate_MatchSet) String() string

                                                            func (*MatchPredicate_MatchSet) Validate

                                                            func (m *MatchPredicate_MatchSet) Validate() error

                                                              Validate checks the field values on MatchPredicate_MatchSet with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                              type MatchPredicate_MatchSetValidationError

                                                              type MatchPredicate_MatchSetValidationError struct {
                                                              	// contains filtered or unexported fields
                                                              }

                                                                MatchPredicate_MatchSetValidationError is the validation error returned by MatchPredicate_MatchSet.Validate if the designated constraints aren't met.

                                                                func (MatchPredicate_MatchSetValidationError) Cause

                                                                  Cause function returns cause value.

                                                                  func (MatchPredicate_MatchSetValidationError) Error

                                                                    Error satisfies the builtin error interface

                                                                    func (MatchPredicate_MatchSetValidationError) ErrorName

                                                                      ErrorName returns error name.

                                                                      func (MatchPredicate_MatchSetValidationError) Field

                                                                        Field function returns field value.

                                                                        func (MatchPredicate_MatchSetValidationError) Key

                                                                          Key function returns key value.

                                                                          func (MatchPredicate_MatchSetValidationError) Reason

                                                                            Reason function returns reason value.

                                                                            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 {
                                                                            	Sinks              []*OutputSink         `protobuf:"bytes,1,rep,name=sinks,proto3" json:"sinks,omitempty"`
                                                                            	MaxBufferedRxBytes *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=max_buffered_rx_bytes,json=maxBufferedRxBytes,proto3" json:"max_buffered_rx_bytes,omitempty"`
                                                                            	MaxBufferedTxBytes *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=max_buffered_tx_bytes,json=maxBufferedTxBytes,proto3" json:"max_buffered_tx_bytes,omitempty"`
                                                                            	Streaming          bool                  `protobuf:"varint,4,opt,name=streaming,proto3" json:"streaming,omitempty"`
                                                                            	// contains filtered or unexported fields
                                                                            }

                                                                            func (*OutputConfig) Descriptor

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

                                                                              Deprecated: Use OutputConfig.ProtoReflect.Descriptor instead.

                                                                              func (*OutputConfig) GetMaxBufferedRxBytes

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

                                                                              func (*OutputConfig) GetMaxBufferedTxBytes

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

                                                                              func (*OutputConfig) GetSinks

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

                                                                              func (*OutputConfig) GetStreaming

                                                                              func (x *OutputConfig) GetStreaming() bool

                                                                              func (*OutputConfig) ProtoMessage

                                                                              func (*OutputConfig) ProtoMessage()

                                                                              func (*OutputConfig) ProtoReflect

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

                                                                              func (*OutputConfig) Reset

                                                                              func (x *OutputConfig) Reset()

                                                                              func (*OutputConfig) String

                                                                              func (x *OutputConfig) String() string

                                                                              func (*OutputConfig) Validate

                                                                              func (m *OutputConfig) Validate() error

                                                                                Validate checks the field values on OutputConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                type OutputConfigValidationError

                                                                                type OutputConfigValidationError struct {
                                                                                	// contains filtered or unexported fields
                                                                                }

                                                                                  OutputConfigValidationError is the validation error returned by OutputConfig.Validate if the designated constraints aren't met.

                                                                                  func (OutputConfigValidationError) Cause

                                                                                    Cause function returns cause value.

                                                                                    func (OutputConfigValidationError) Error

                                                                                      Error satisfies the builtin error interface

                                                                                      func (OutputConfigValidationError) ErrorName

                                                                                      func (e OutputConfigValidationError) ErrorName() string

                                                                                        ErrorName returns error name.

                                                                                        func (OutputConfigValidationError) Field

                                                                                          Field function returns field value.

                                                                                          func (OutputConfigValidationError) Key

                                                                                            Key function returns key value.

                                                                                            func (OutputConfigValidationError) Reason

                                                                                              Reason function returns reason value.

                                                                                              type OutputSink

                                                                                              type OutputSink struct {
                                                                                              	Format OutputSink_Format `protobuf:"varint,1,opt,name=format,proto3,enum=envoy.service.tap.v2alpha.OutputSink_Format" json:"format,omitempty"`
                                                                                              	// Types that are assignable to OutputSinkType:
                                                                                              	//	*OutputSink_StreamingAdmin
                                                                                              	//	*OutputSink_FilePerTap
                                                                                              	//	*OutputSink_StreamingGrpc
                                                                                              	OutputSinkType isOutputSink_OutputSinkType `protobuf_oneof:"output_sink_type"`
                                                                                              	// contains filtered or unexported fields
                                                                                              }

                                                                                              func (*OutputSink) Descriptor

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

                                                                                                Deprecated: Use OutputSink.ProtoReflect.Descriptor instead.

                                                                                                func (*OutputSink) GetFilePerTap

                                                                                                func (x *OutputSink) GetFilePerTap() *FilePerTapSink

                                                                                                func (*OutputSink) GetFormat

                                                                                                func (x *OutputSink) GetFormat() OutputSink_Format

                                                                                                func (*OutputSink) GetOutputSinkType

                                                                                                func (m *OutputSink) GetOutputSinkType() isOutputSink_OutputSinkType

                                                                                                func (*OutputSink) GetStreamingAdmin

                                                                                                func (x *OutputSink) GetStreamingAdmin() *StreamingAdminSink

                                                                                                func (*OutputSink) GetStreamingGrpc

                                                                                                func (x *OutputSink) GetStreamingGrpc() *StreamingGrpcSink

                                                                                                func (*OutputSink) ProtoMessage

                                                                                                func (*OutputSink) ProtoMessage()

                                                                                                func (*OutputSink) ProtoReflect

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

                                                                                                func (*OutputSink) Reset

                                                                                                func (x *OutputSink) Reset()

                                                                                                func (*OutputSink) String

                                                                                                func (x *OutputSink) String() string

                                                                                                func (*OutputSink) Validate

                                                                                                func (m *OutputSink) Validate() error

                                                                                                  Validate checks the field values on OutputSink with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                  type OutputSinkValidationError

                                                                                                  type OutputSinkValidationError struct {
                                                                                                  	// contains filtered or unexported fields
                                                                                                  }

                                                                                                    OutputSinkValidationError is the validation error returned by OutputSink.Validate if the designated constraints aren't met.

                                                                                                    func (OutputSinkValidationError) Cause

                                                                                                    func (e OutputSinkValidationError) Cause() error

                                                                                                      Cause function returns cause value.

                                                                                                      func (OutputSinkValidationError) Error

                                                                                                        Error satisfies the builtin error interface

                                                                                                        func (OutputSinkValidationError) ErrorName

                                                                                                        func (e OutputSinkValidationError) ErrorName() string

                                                                                                          ErrorName returns error name.

                                                                                                          func (OutputSinkValidationError) Field

                                                                                                            Field function returns field value.

                                                                                                            func (OutputSinkValidationError) Key

                                                                                                              Key function returns key value.

                                                                                                              func (OutputSinkValidationError) Reason

                                                                                                              func (e OutputSinkValidationError) Reason() string

                                                                                                                Reason function returns reason value.

                                                                                                                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
                                                                                                                const (
                                                                                                                	OutputSink_JSON_BODY_AS_BYTES            OutputSink_Format = 0
                                                                                                                	OutputSink_JSON_BODY_AS_STRING           OutputSink_Format = 1
                                                                                                                	OutputSink_PROTO_BINARY                  OutputSink_Format = 2
                                                                                                                	OutputSink_PROTO_BINARY_LENGTH_DELIMITED OutputSink_Format = 3
                                                                                                                	OutputSink_PROTO_TEXT                    OutputSink_Format = 4
                                                                                                                )

                                                                                                                func (OutputSink_Format) Descriptor

                                                                                                                func (OutputSink_Format) Enum

                                                                                                                func (OutputSink_Format) EnumDescriptor

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

                                                                                                                  Deprecated: Use OutputSink_Format.Descriptor instead.

                                                                                                                  func (OutputSink_Format) Number

                                                                                                                  func (OutputSink_Format) String

                                                                                                                  func (x OutputSink_Format) String() string

                                                                                                                  func (OutputSink_Format) Type

                                                                                                                  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 *StreamTapsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
                                                                                                                  	TraceId    uint64                        `protobuf:"varint,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
                                                                                                                  	Trace      *v2alpha.TraceWrapper         `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
                                                                                                                  	// contains filtered or unexported fields
                                                                                                                  }

                                                                                                                  func (*StreamTapsRequest) Descriptor

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

                                                                                                                    Deprecated: Use StreamTapsRequest.ProtoReflect.Descriptor instead.

                                                                                                                    func (*StreamTapsRequest) GetIdentifier

                                                                                                                    func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier

                                                                                                                    func (*StreamTapsRequest) GetTrace

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

                                                                                                                    func (*StreamTapsRequest) GetTraceId

                                                                                                                    func (x *StreamTapsRequest) GetTraceId() uint64

                                                                                                                    func (*StreamTapsRequest) ProtoMessage

                                                                                                                    func (*StreamTapsRequest) ProtoMessage()

                                                                                                                    func (*StreamTapsRequest) ProtoReflect

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

                                                                                                                    func (*StreamTapsRequest) Reset

                                                                                                                    func (x *StreamTapsRequest) Reset()

                                                                                                                    func (*StreamTapsRequest) String

                                                                                                                    func (x *StreamTapsRequest) String() string

                                                                                                                    func (*StreamTapsRequest) Validate

                                                                                                                    func (m *StreamTapsRequest) Validate() error

                                                                                                                      Validate checks the field values on StreamTapsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                      type StreamTapsRequestValidationError

                                                                                                                      type StreamTapsRequestValidationError struct {
                                                                                                                      	// contains filtered or unexported fields
                                                                                                                      }

                                                                                                                        StreamTapsRequestValidationError is the validation error returned by StreamTapsRequest.Validate if the designated constraints aren't met.

                                                                                                                        func (StreamTapsRequestValidationError) Cause

                                                                                                                          Cause function returns cause value.

                                                                                                                          func (StreamTapsRequestValidationError) Error

                                                                                                                            Error satisfies the builtin error interface

                                                                                                                            func (StreamTapsRequestValidationError) ErrorName

                                                                                                                              ErrorName returns error name.

                                                                                                                              func (StreamTapsRequestValidationError) Field

                                                                                                                                Field function returns field value.

                                                                                                                                func (StreamTapsRequestValidationError) Key

                                                                                                                                  Key function returns key value.

                                                                                                                                  func (StreamTapsRequestValidationError) Reason

                                                                                                                                    Reason function returns reason value.

                                                                                                                                    type StreamTapsRequest_Identifier

                                                                                                                                    type StreamTapsRequest_Identifier struct {
                                                                                                                                    	Node  *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
                                                                                                                                    	TapId string     `protobuf:"bytes,2,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"`
                                                                                                                                    	// contains filtered or unexported fields
                                                                                                                                    }

                                                                                                                                    func (*StreamTapsRequest_Identifier) Descriptor

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

                                                                                                                                      Deprecated: Use StreamTapsRequest_Identifier.ProtoReflect.Descriptor instead.

                                                                                                                                      func (*StreamTapsRequest_Identifier) GetNode

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

                                                                                                                                      func (*StreamTapsRequest_Identifier) GetTapId

                                                                                                                                      func (x *StreamTapsRequest_Identifier) GetTapId() string

                                                                                                                                      func (*StreamTapsRequest_Identifier) ProtoMessage

                                                                                                                                      func (*StreamTapsRequest_Identifier) ProtoMessage()

                                                                                                                                      func (*StreamTapsRequest_Identifier) ProtoReflect

                                                                                                                                      func (*StreamTapsRequest_Identifier) Reset

                                                                                                                                      func (x *StreamTapsRequest_Identifier) Reset()

                                                                                                                                      func (*StreamTapsRequest_Identifier) String

                                                                                                                                      func (*StreamTapsRequest_Identifier) Validate

                                                                                                                                      func (m *StreamTapsRequest_Identifier) Validate() error

                                                                                                                                        Validate checks the field values on StreamTapsRequest_Identifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                                        type StreamTapsRequest_IdentifierValidationError

                                                                                                                                        type StreamTapsRequest_IdentifierValidationError struct {
                                                                                                                                        	// contains filtered or unexported fields
                                                                                                                                        }

                                                                                                                                          StreamTapsRequest_IdentifierValidationError is the validation error returned by StreamTapsRequest_Identifier.Validate if the designated constraints aren't met.

                                                                                                                                          func (StreamTapsRequest_IdentifierValidationError) Cause

                                                                                                                                            Cause function returns cause value.

                                                                                                                                            func (StreamTapsRequest_IdentifierValidationError) Error

                                                                                                                                              Error satisfies the builtin error interface

                                                                                                                                              func (StreamTapsRequest_IdentifierValidationError) ErrorName

                                                                                                                                                ErrorName returns error name.

                                                                                                                                                func (StreamTapsRequest_IdentifierValidationError) Field

                                                                                                                                                  Field function returns field value.

                                                                                                                                                  func (StreamTapsRequest_IdentifierValidationError) Key

                                                                                                                                                    Key function returns key value.

                                                                                                                                                    func (StreamTapsRequest_IdentifierValidationError) Reason

                                                                                                                                                      Reason function returns reason value.

                                                                                                                                                      type StreamTapsResponse

                                                                                                                                                      type StreamTapsResponse struct {
                                                                                                                                                      	// contains filtered or unexported fields
                                                                                                                                                      }

                                                                                                                                                      func (*StreamTapsResponse) Descriptor

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

                                                                                                                                                        Deprecated: Use StreamTapsResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                        func (*StreamTapsResponse) ProtoMessage

                                                                                                                                                        func (*StreamTapsResponse) ProtoMessage()

                                                                                                                                                        func (*StreamTapsResponse) ProtoReflect

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

                                                                                                                                                        func (*StreamTapsResponse) Reset

                                                                                                                                                        func (x *StreamTapsResponse) Reset()

                                                                                                                                                        func (*StreamTapsResponse) String

                                                                                                                                                        func (x *StreamTapsResponse) String() string

                                                                                                                                                        func (*StreamTapsResponse) Validate

                                                                                                                                                        func (m *StreamTapsResponse) Validate() error

                                                                                                                                                          Validate checks the field values on StreamTapsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                                                          type StreamTapsResponseValidationError

                                                                                                                                                          type StreamTapsResponseValidationError struct {
                                                                                                                                                          	// contains filtered or unexported fields
                                                                                                                                                          }

                                                                                                                                                            StreamTapsResponseValidationError is the validation error returned by StreamTapsResponse.Validate if the designated constraints aren't met.

                                                                                                                                                            func (StreamTapsResponseValidationError) Cause

                                                                                                                                                              Cause function returns cause value.

                                                                                                                                                              func (StreamTapsResponseValidationError) Error

                                                                                                                                                                Error satisfies the builtin error interface

                                                                                                                                                                func (StreamTapsResponseValidationError) ErrorName

                                                                                                                                                                  ErrorName returns error name.

                                                                                                                                                                  func (StreamTapsResponseValidationError) Field

                                                                                                                                                                    Field function returns field value.

                                                                                                                                                                    func (StreamTapsResponseValidationError) Key

                                                                                                                                                                      Key function returns key value.

                                                                                                                                                                      func (StreamTapsResponseValidationError) Reason

                                                                                                                                                                        Reason function returns reason value.

                                                                                                                                                                        type StreamingAdminSink

                                                                                                                                                                        type StreamingAdminSink struct {
                                                                                                                                                                        	// contains filtered or unexported fields
                                                                                                                                                                        }

                                                                                                                                                                        func (*StreamingAdminSink) Descriptor

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

                                                                                                                                                                          Deprecated: Use StreamingAdminSink.ProtoReflect.Descriptor instead.

                                                                                                                                                                          func (*StreamingAdminSink) ProtoMessage

                                                                                                                                                                          func (*StreamingAdminSink) ProtoMessage()

                                                                                                                                                                          func (*StreamingAdminSink) ProtoReflect

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

                                                                                                                                                                          func (*StreamingAdminSink) Reset

                                                                                                                                                                          func (x *StreamingAdminSink) Reset()

                                                                                                                                                                          func (*StreamingAdminSink) String

                                                                                                                                                                          func (x *StreamingAdminSink) String() string

                                                                                                                                                                          func (*StreamingAdminSink) Validate

                                                                                                                                                                          func (m *StreamingAdminSink) Validate() error

                                                                                                                                                                            Validate checks the field values on StreamingAdminSink with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                                                                            type StreamingAdminSinkValidationError

                                                                                                                                                                            type StreamingAdminSinkValidationError struct {
                                                                                                                                                                            	// contains filtered or unexported fields
                                                                                                                                                                            }

                                                                                                                                                                              StreamingAdminSinkValidationError is the validation error returned by StreamingAdminSink.Validate if the designated constraints aren't met.

                                                                                                                                                                              func (StreamingAdminSinkValidationError) Cause

                                                                                                                                                                                Cause function returns cause value.

                                                                                                                                                                                func (StreamingAdminSinkValidationError) Error

                                                                                                                                                                                  Error satisfies the builtin error interface

                                                                                                                                                                                  func (StreamingAdminSinkValidationError) ErrorName

                                                                                                                                                                                    ErrorName returns error name.

                                                                                                                                                                                    func (StreamingAdminSinkValidationError) Field

                                                                                                                                                                                      Field function returns field value.

                                                                                                                                                                                      func (StreamingAdminSinkValidationError) Key

                                                                                                                                                                                        Key function returns key value.

                                                                                                                                                                                        func (StreamingAdminSinkValidationError) Reason

                                                                                                                                                                                          Reason function returns reason value.

                                                                                                                                                                                          type StreamingGrpcSink

                                                                                                                                                                                          type StreamingGrpcSink struct {
                                                                                                                                                                                          	TapId       string            `protobuf:"bytes,1,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"`
                                                                                                                                                                                          	GrpcService *core.GrpcService `protobuf:"bytes,2,opt,name=grpc_service,json=grpcService,proto3" json:"grpc_service,omitempty"`
                                                                                                                                                                                          	// contains filtered or unexported fields
                                                                                                                                                                                          }

                                                                                                                                                                                          func (*StreamingGrpcSink) Descriptor

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

                                                                                                                                                                                            Deprecated: Use StreamingGrpcSink.ProtoReflect.Descriptor instead.

                                                                                                                                                                                            func (*StreamingGrpcSink) GetGrpcService

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

                                                                                                                                                                                            func (*StreamingGrpcSink) GetTapId

                                                                                                                                                                                            func (x *StreamingGrpcSink) GetTapId() string

                                                                                                                                                                                            func (*StreamingGrpcSink) ProtoMessage

                                                                                                                                                                                            func (*StreamingGrpcSink) ProtoMessage()

                                                                                                                                                                                            func (*StreamingGrpcSink) ProtoReflect

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

                                                                                                                                                                                            func (*StreamingGrpcSink) Reset

                                                                                                                                                                                            func (x *StreamingGrpcSink) Reset()

                                                                                                                                                                                            func (*StreamingGrpcSink) String

                                                                                                                                                                                            func (x *StreamingGrpcSink) String() string

                                                                                                                                                                                            func (*StreamingGrpcSink) Validate

                                                                                                                                                                                            func (m *StreamingGrpcSink) Validate() error

                                                                                                                                                                                              Validate checks the field values on StreamingGrpcSink with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                                                                                              type StreamingGrpcSinkValidationError

                                                                                                                                                                                              type StreamingGrpcSinkValidationError struct {
                                                                                                                                                                                              	// contains filtered or unexported fields
                                                                                                                                                                                              }

                                                                                                                                                                                                StreamingGrpcSinkValidationError is the validation error returned by StreamingGrpcSink.Validate if the designated constraints aren't met.

                                                                                                                                                                                                func (StreamingGrpcSinkValidationError) Cause

                                                                                                                                                                                                  Cause function returns cause value.

                                                                                                                                                                                                  func (StreamingGrpcSinkValidationError) Error

                                                                                                                                                                                                    Error satisfies the builtin error interface

                                                                                                                                                                                                    func (StreamingGrpcSinkValidationError) ErrorName

                                                                                                                                                                                                      ErrorName returns error name.

                                                                                                                                                                                                      func (StreamingGrpcSinkValidationError) Field

                                                                                                                                                                                                        Field function returns field value.

                                                                                                                                                                                                        func (StreamingGrpcSinkValidationError) Key

                                                                                                                                                                                                          Key function returns key value.

                                                                                                                                                                                                          func (StreamingGrpcSinkValidationError) Reason

                                                                                                                                                                                                            Reason function returns reason value.

                                                                                                                                                                                                            type TapConfig

                                                                                                                                                                                                            type TapConfig struct {
                                                                                                                                                                                                            	MatchConfig  *MatchPredicate                `protobuf:"bytes,1,opt,name=match_config,json=matchConfig,proto3" json:"match_config,omitempty"`
                                                                                                                                                                                                            	OutputConfig *OutputConfig                  `protobuf:"bytes,2,opt,name=output_config,json=outputConfig,proto3" json:"output_config,omitempty"`
                                                                                                                                                                                                            	TapEnabled   *core.RuntimeFractionalPercent `protobuf:"bytes,3,opt,name=tap_enabled,json=tapEnabled,proto3" json:"tap_enabled,omitempty"`
                                                                                                                                                                                                            	// contains filtered or unexported fields
                                                                                                                                                                                                            }

                                                                                                                                                                                                            func (*TapConfig) Descriptor

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

                                                                                                                                                                                                              Deprecated: Use TapConfig.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                              func (*TapConfig) GetMatchConfig

                                                                                                                                                                                                              func (x *TapConfig) GetMatchConfig() *MatchPredicate

                                                                                                                                                                                                              func (*TapConfig) GetOutputConfig

                                                                                                                                                                                                              func (x *TapConfig) GetOutputConfig() *OutputConfig

                                                                                                                                                                                                              func (*TapConfig) GetTapEnabled

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

                                                                                                                                                                                                              func (*TapConfig) ProtoMessage

                                                                                                                                                                                                              func (*TapConfig) ProtoMessage()

                                                                                                                                                                                                              func (*TapConfig) ProtoReflect

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

                                                                                                                                                                                                              func (*TapConfig) Reset

                                                                                                                                                                                                              func (x *TapConfig) Reset()

                                                                                                                                                                                                              func (*TapConfig) String

                                                                                                                                                                                                              func (x *TapConfig) String() string

                                                                                                                                                                                                              func (*TapConfig) Validate

                                                                                                                                                                                                              func (m *TapConfig) Validate() error

                                                                                                                                                                                                                Validate checks the field values on TapConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                                                                                                                type TapConfigValidationError

                                                                                                                                                                                                                type TapConfigValidationError struct {
                                                                                                                                                                                                                	// contains filtered or unexported fields
                                                                                                                                                                                                                }

                                                                                                                                                                                                                  TapConfigValidationError is the validation error returned by TapConfig.Validate if the designated constraints aren't met.

                                                                                                                                                                                                                  func (TapConfigValidationError) Cause

                                                                                                                                                                                                                  func (e TapConfigValidationError) Cause() error

                                                                                                                                                                                                                    Cause function returns cause value.

                                                                                                                                                                                                                    func (TapConfigValidationError) Error

                                                                                                                                                                                                                    func (e TapConfigValidationError) Error() string

                                                                                                                                                                                                                      Error satisfies the builtin error interface

                                                                                                                                                                                                                      func (TapConfigValidationError) ErrorName

                                                                                                                                                                                                                      func (e TapConfigValidationError) ErrorName() string

                                                                                                                                                                                                                        ErrorName returns error name.

                                                                                                                                                                                                                        func (TapConfigValidationError) Field

                                                                                                                                                                                                                        func (e TapConfigValidationError) Field() string

                                                                                                                                                                                                                          Field function returns field value.

                                                                                                                                                                                                                          func (TapConfigValidationError) Key

                                                                                                                                                                                                                            Key function returns key value.

                                                                                                                                                                                                                            func (TapConfigValidationError) Reason

                                                                                                                                                                                                                            func (e TapConfigValidationError) Reason() string

                                                                                                                                                                                                                              Reason function returns reason value.

                                                                                                                                                                                                                              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.

                                                                                                                                                                                                                                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 {
                                                                                                                                                                                                                                  	Name   string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
                                                                                                                                                                                                                                  	Config *TapConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
                                                                                                                                                                                                                                  	// contains filtered or unexported fields
                                                                                                                                                                                                                                  }

                                                                                                                                                                                                                                  func (*TapResource) Descriptor

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

                                                                                                                                                                                                                                    Deprecated: Use TapResource.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                    func (*TapResource) GetConfig

                                                                                                                                                                                                                                    func (x *TapResource) GetConfig() *TapConfig

                                                                                                                                                                                                                                    func (*TapResource) GetName

                                                                                                                                                                                                                                    func (x *TapResource) GetName() string

                                                                                                                                                                                                                                    func (*TapResource) ProtoMessage

                                                                                                                                                                                                                                    func (*TapResource) ProtoMessage()

                                                                                                                                                                                                                                    func (*TapResource) ProtoReflect

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

                                                                                                                                                                                                                                    func (*TapResource) Reset

                                                                                                                                                                                                                                    func (x *TapResource) Reset()

                                                                                                                                                                                                                                    func (*TapResource) String

                                                                                                                                                                                                                                    func (x *TapResource) String() string

                                                                                                                                                                                                                                    func (*TapResource) Validate

                                                                                                                                                                                                                                    func (m *TapResource) Validate() error

                                                                                                                                                                                                                                      Validate checks the field values on TapResource with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

                                                                                                                                                                                                                                      type TapResourceValidationError

                                                                                                                                                                                                                                      type TapResourceValidationError struct {
                                                                                                                                                                                                                                      	// contains filtered or unexported fields
                                                                                                                                                                                                                                      }

                                                                                                                                                                                                                                        TapResourceValidationError is the validation error returned by TapResource.Validate if the designated constraints aren't met.

                                                                                                                                                                                                                                        func (TapResourceValidationError) Cause

                                                                                                                                                                                                                                          Cause function returns cause value.

                                                                                                                                                                                                                                          func (TapResourceValidationError) Error

                                                                                                                                                                                                                                            Error satisfies the builtin error interface

                                                                                                                                                                                                                                            func (TapResourceValidationError) ErrorName

                                                                                                                                                                                                                                            func (e TapResourceValidationError) ErrorName() string

                                                                                                                                                                                                                                              ErrorName returns error name.

                                                                                                                                                                                                                                              func (TapResourceValidationError) Field

                                                                                                                                                                                                                                                Field function returns field value.

                                                                                                                                                                                                                                                func (TapResourceValidationError) Key

                                                                                                                                                                                                                                                  Key function returns key value.

                                                                                                                                                                                                                                                  func (TapResourceValidationError) Reason

                                                                                                                                                                                                                                                    Reason function returns reason value.

                                                                                                                                                                                                                                                    type TapSinkServiceClient

                                                                                                                                                                                                                                                    type TapSinkServiceClient interface {
                                                                                                                                                                                                                                                    	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.

                                                                                                                                                                                                                                                      type TapSinkServiceServer

                                                                                                                                                                                                                                                      type TapSinkServiceServer interface {
                                                                                                                                                                                                                                                      	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
                                                                                                                                                                                                                                                        }

                                                                                                                                                                                                                                                        type UnimplementedTapDiscoveryServiceServer

                                                                                                                                                                                                                                                        type UnimplementedTapDiscoveryServiceServer struct {
                                                                                                                                                                                                                                                        }

                                                                                                                                                                                                                                                          UnimplementedTapDiscoveryServiceServer can be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                          func (*UnimplementedTapDiscoveryServiceServer) DeltaTapConfigs

                                                                                                                                                                                                                                                          func (*UnimplementedTapDiscoveryServiceServer) FetchTapConfigs

                                                                                                                                                                                                                                                          func (*UnimplementedTapDiscoveryServiceServer) StreamTapConfigs

                                                                                                                                                                                                                                                          type UnimplementedTapSinkServiceServer

                                                                                                                                                                                                                                                          type UnimplementedTapSinkServiceServer struct {
                                                                                                                                                                                                                                                          }

                                                                                                                                                                                                                                                            UnimplementedTapSinkServiceServer can be embedded to have forward compatible implementations.

                                                                                                                                                                                                                                                            func (*UnimplementedTapSinkServiceServer) StreamTaps