go-control-plane: github.com/envoyproxy/go-control-plane/envoy/service/tap/v4alpha Index | Files

package envoy_service_tap_v4alpha

import "github.com/envoyproxy/go-control-plane/envoy/service/tap/v4alpha"

Index

Package Files

tap.pb.go tap.pb.validate.go

Variables

var File_envoy_service_tap_v4alpha_tap_proto protoreflect.FileDescriptor

func RegisterTapSinkServiceServer Uses

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

type StreamTapsRequest Uses

type StreamTapsRequest struct {

    // Identifier data effectively is a structured metadata. As a performance optimization this will
    // only be sent in the first message on the stream.
    Identifier *StreamTapsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
    // The trace id. this can be used to merge together a streaming trace. Note that the trace_id
    // is not guaranteed to be spatially or temporally unique.
    TraceId uint64 `protobuf:"varint,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
    // The trace data.
    Trace *v3.TraceWrapper `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"`
    // contains filtered or unexported fields
}

[#not-implemented-hide:] Stream message for the Tap API. Envoy will open a stream to the server and stream taps without ever expecting a response.

func (*StreamTapsRequest) Descriptor Uses

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

Deprecated: Use StreamTapsRequest.ProtoReflect.Descriptor instead.

func (*StreamTapsRequest) GetIdentifier Uses

func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier

func (*StreamTapsRequest) GetTrace Uses

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

func (*StreamTapsRequest) GetTraceId Uses

func (x *StreamTapsRequest) GetTraceId() uint64

func (*StreamTapsRequest) ProtoMessage Uses

func (*StreamTapsRequest) ProtoMessage()

func (*StreamTapsRequest) ProtoReflect Uses

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

func (*StreamTapsRequest) Reset Uses

func (x *StreamTapsRequest) Reset()

func (*StreamTapsRequest) String Uses

func (x *StreamTapsRequest) String() string

func (*StreamTapsRequest) Validate Uses

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 Uses

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 Uses

func (e StreamTapsRequestValidationError) Cause() error

Cause function returns cause value.

func (StreamTapsRequestValidationError) Error Uses

func (e StreamTapsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StreamTapsRequestValidationError) ErrorName Uses

func (e StreamTapsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StreamTapsRequestValidationError) Field Uses

func (e StreamTapsRequestValidationError) Field() string

Field function returns field value.

func (StreamTapsRequestValidationError) Key Uses

func (e StreamTapsRequestValidationError) Key() bool

Key function returns key value.

func (StreamTapsRequestValidationError) Reason Uses

func (e StreamTapsRequestValidationError) Reason() string

Reason function returns reason value.

type StreamTapsRequest_Identifier Uses

type StreamTapsRequest_Identifier struct {

    // The node sending taps over the stream.
    Node *v4alpha.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
    // The opaque identifier that was set in the :ref:`output config
    // <envoy_api_field_config.tap.v4alpha.StreamingGrpcSink.tap_id>`.
    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 Uses

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

Deprecated: Use StreamTapsRequest_Identifier.ProtoReflect.Descriptor instead.

func (*StreamTapsRequest_Identifier) GetNode Uses

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

func (*StreamTapsRequest_Identifier) GetTapId Uses

func (x *StreamTapsRequest_Identifier) GetTapId() string

func (*StreamTapsRequest_Identifier) ProtoMessage Uses

func (*StreamTapsRequest_Identifier) ProtoMessage()

func (*StreamTapsRequest_Identifier) ProtoReflect Uses

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

func (*StreamTapsRequest_Identifier) Reset Uses

func (x *StreamTapsRequest_Identifier) Reset()

func (*StreamTapsRequest_Identifier) String Uses

func (x *StreamTapsRequest_Identifier) String() string

func (*StreamTapsRequest_Identifier) Validate Uses

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 Uses

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 Uses

func (e StreamTapsRequest_IdentifierValidationError) Cause() error

Cause function returns cause value.

func (StreamTapsRequest_IdentifierValidationError) Error Uses

func (e StreamTapsRequest_IdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (StreamTapsRequest_IdentifierValidationError) ErrorName Uses

func (e StreamTapsRequest_IdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (StreamTapsRequest_IdentifierValidationError) Field Uses

func (e StreamTapsRequest_IdentifierValidationError) Field() string

Field function returns field value.

func (StreamTapsRequest_IdentifierValidationError) Key Uses

func (e StreamTapsRequest_IdentifierValidationError) Key() bool

Key function returns key value.

func (StreamTapsRequest_IdentifierValidationError) Reason Uses

func (e StreamTapsRequest_IdentifierValidationError) Reason() string

Reason function returns reason value.

type StreamTapsResponse Uses

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

[#not-implemented-hide:]

func (*StreamTapsResponse) Descriptor Uses

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

Deprecated: Use StreamTapsResponse.ProtoReflect.Descriptor instead.

func (*StreamTapsResponse) ProtoMessage Uses

func (*StreamTapsResponse) ProtoMessage()

func (*StreamTapsResponse) ProtoReflect Uses

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

func (*StreamTapsResponse) Reset Uses

func (x *StreamTapsResponse) Reset()

func (*StreamTapsResponse) String Uses

func (x *StreamTapsResponse) String() string

func (*StreamTapsResponse) Validate Uses

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 Uses

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 Uses

func (e StreamTapsResponseValidationError) Cause() error

Cause function returns cause value.

func (StreamTapsResponseValidationError) Error Uses

func (e StreamTapsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StreamTapsResponseValidationError) ErrorName Uses

func (e StreamTapsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StreamTapsResponseValidationError) Field Uses

func (e StreamTapsResponseValidationError) Field() string

Field function returns field value.

func (StreamTapsResponseValidationError) Key Uses

func (e StreamTapsResponseValidationError) Key() bool

Key function returns key value.

func (StreamTapsResponseValidationError) Reason Uses

func (e StreamTapsResponseValidationError) Reason() string

Reason function returns reason value.

type TapSinkServiceClient Uses

type TapSinkServiceClient interface {
    // Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
    // response to be sent as nothing would be done in the case of failure. The server should
    // disconnect if it expects Envoy to reconnect.
    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.

func NewTapSinkServiceClient Uses

func NewTapSinkServiceClient(cc grpc.ClientConnInterface) TapSinkServiceClient

type TapSinkServiceServer Uses

type TapSinkServiceServer interface {
    // Envoy will connect and send StreamTapsRequest messages forever. It does not expect any
    // response to be sent as nothing would be done in the case of failure. The server should
    // disconnect if it expects Envoy to reconnect.
    StreamTaps(TapSinkService_StreamTapsServer) error
}

TapSinkServiceServer is the server API for TapSinkService service.

type TapSinkService_StreamTapsClient Uses

type TapSinkService_StreamTapsClient interface {
    Send(*StreamTapsRequest) error
    CloseAndRecv() (*StreamTapsResponse, error)
    grpc.ClientStream
}

type TapSinkService_StreamTapsServer Uses

type TapSinkService_StreamTapsServer interface {
    SendAndClose(*StreamTapsResponse) error
    Recv() (*StreamTapsRequest, error)
    grpc.ServerStream
}

type UnimplementedTapSinkServiceServer Uses

type UnimplementedTapSinkServiceServer struct {
}

UnimplementedTapSinkServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTapSinkServiceServer) StreamTaps Uses

func (*UnimplementedTapSinkServiceServer) StreamTaps(TapSinkService_StreamTapsServer) error

Package envoy_service_tap_v4alpha imports 24 packages (graph) and is imported by 6 packages. Updated 2021-01-08. Refresh now. Tools for package owners.