Versions in this module Expand all Collapse all v0 v0.9.82 Jan 31, 2021 Changes in this version + var File_envoy_service_tap_v3_tap_proto protoreflect.FileDescriptor + func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer) + type StreamTapsRequest struct + Identifier *StreamTapsRequest_Identifier + Trace *v3.TraceWrapper + TraceId uint64 + func (*StreamTapsRequest) Descriptor() ([]byte, []int) + func (*StreamTapsRequest) ProtoMessage() + func (m *StreamTapsRequest) Validate() error + func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier + func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper + func (x *StreamTapsRequest) GetTraceId() uint64 + func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message + func (x *StreamTapsRequest) Reset() + func (x *StreamTapsRequest) String() string + type StreamTapsRequestValidationError struct + func (e StreamTapsRequestValidationError) Cause() error + func (e StreamTapsRequestValidationError) Error() string + func (e StreamTapsRequestValidationError) ErrorName() string + func (e StreamTapsRequestValidationError) Field() string + func (e StreamTapsRequestValidationError) Key() bool + func (e StreamTapsRequestValidationError) Reason() string + type StreamTapsRequest_Identifier struct + Node *v31.Node + TapId string + func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int) + func (*StreamTapsRequest_Identifier) ProtoMessage() + func (m *StreamTapsRequest_Identifier) Validate() error + func (x *StreamTapsRequest_Identifier) GetNode() *v31.Node + func (x *StreamTapsRequest_Identifier) GetTapId() string + func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message + func (x *StreamTapsRequest_Identifier) Reset() + func (x *StreamTapsRequest_Identifier) String() string + type StreamTapsRequest_IdentifierValidationError struct + func (e StreamTapsRequest_IdentifierValidationError) Cause() error + func (e StreamTapsRequest_IdentifierValidationError) Error() string + func (e StreamTapsRequest_IdentifierValidationError) ErrorName() string + func (e StreamTapsRequest_IdentifierValidationError) Field() string + func (e StreamTapsRequest_IdentifierValidationError) Key() bool + func (e StreamTapsRequest_IdentifierValidationError) Reason() string + type StreamTapsResponse struct + func (*StreamTapsResponse) Descriptor() ([]byte, []int) + func (*StreamTapsResponse) ProtoMessage() + func (m *StreamTapsResponse) Validate() error + func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message + func (x *StreamTapsResponse) Reset() + func (x *StreamTapsResponse) String() string + type StreamTapsResponseValidationError struct + func (e StreamTapsResponseValidationError) Cause() error + func (e StreamTapsResponseValidationError) Error() string + func (e StreamTapsResponseValidationError) ErrorName() string + func (e StreamTapsResponseValidationError) Field() string + func (e StreamTapsResponseValidationError) Key() bool + func (e StreamTapsResponseValidationError) Reason() string + type TapSinkServiceClient interface + StreamTaps func(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error) + func NewTapSinkServiceClient(cc grpc.ClientConnInterface) TapSinkServiceClient + type TapSinkServiceServer interface + StreamTaps func(TapSinkService_StreamTapsServer) error + type TapSinkService_StreamTapsClient interface + CloseAndRecv func() (*StreamTapsResponse, error) + Send func(*StreamTapsRequest) error + type TapSinkService_StreamTapsServer interface + Recv func() (*StreamTapsRequest, error) + SendAndClose func(*StreamTapsResponse) error + type UnimplementedTapSinkServiceServer struct + func (*UnimplementedTapSinkServiceServer) StreamTaps(TapSinkService_StreamTapsServer) error