...

Package kat

import "github.com/datawire/ambassador/v2/pkg/api/kat"
Overview
Index

Overview ▾

Index ▾

Variables
func RegisterEchoServiceServer(s grpc.ServiceRegistrar, srv EchoServiceServer)
type EchoRequest
    func (*EchoRequest) Descriptor() ([]byte, []int)
    func (x *EchoRequest) GetData() string
    func (*EchoRequest) ProtoMessage()
    func (x *EchoRequest) ProtoReflect() protoreflect.Message
    func (x *EchoRequest) Reset()
    func (x *EchoRequest) String() string
type EchoResponse
    func (*EchoResponse) Descriptor() ([]byte, []int)
    func (x *EchoResponse) GetBackend() string
    func (x *EchoResponse) GetRequest() *Request
    func (x *EchoResponse) GetResponse() *Response
    func (*EchoResponse) ProtoMessage()
    func (x *EchoResponse) ProtoReflect() protoreflect.Message
    func (x *EchoResponse) Reset()
    func (x *EchoResponse) String() string
type EchoServiceClient
    func NewEchoServiceClient(cc grpc.ClientConnInterface) EchoServiceClient
type EchoServiceServer
type Request
    func (*Request) Descriptor() ([]byte, []int)
    func (x *Request) GetHeaders() map[string]string
    func (x *Request) GetTls() *TLS
    func (*Request) ProtoMessage()
    func (x *Request) ProtoReflect() protoreflect.Message
    func (x *Request) Reset()
    func (x *Request) String() string
type Response
    func (*Response) Descriptor() ([]byte, []int)
    func (x *Response) GetHeaders() map[string]string
    func (*Response) ProtoMessage()
    func (x *Response) ProtoReflect() protoreflect.Message
    func (x *Response) Reset()
    func (x *Response) String() string
type TLS
    func (*TLS) Descriptor() ([]byte, []int)
    func (x *TLS) GetEnabled() bool
    func (*TLS) ProtoMessage()
    func (x *TLS) ProtoReflect() protoreflect.Message
    func (x *TLS) Reset()
    func (x *TLS) String() string
type UnimplementedEchoServiceServer
    func (UnimplementedEchoServiceServer) Echo(context.Context, *EchoRequest) (*EchoResponse, error)
type UnsafeEchoServiceServer

Package files

echo.pb.go echo_grpc.pb.go

Variables

EchoService_ServiceDesc is the grpc.ServiceDesc for EchoService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var EchoService_ServiceDesc = grpc.ServiceDesc{
    ServiceName: "echo.EchoService",
    HandlerType: (*EchoServiceServer)(nil),
    Methods: []grpc.MethodDesc{
        {
            MethodName: "Echo",
            Handler:    _EchoService_Echo_Handler,
        },
    },
    Streams:  []grpc.StreamDesc{},
    Metadata: "kat/echo.proto",
}
var File_kat_echo_proto protoreflect.FileDescriptor

func RegisterEchoServiceServer

func RegisterEchoServiceServer(s grpc.ServiceRegistrar, srv EchoServiceServer)

type EchoRequest

type EchoRequest struct {
    Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
    // contains filtered or unexported fields
}

func (*EchoRequest) Descriptor

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

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetData

func (x *EchoRequest) GetData() string

func (*EchoRequest) ProtoMessage

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) ProtoReflect

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

func (*EchoRequest) Reset

func (x *EchoRequest) Reset()

func (*EchoRequest) String

func (x *EchoRequest) String() string

type EchoResponse

type EchoResponse struct {
    Backend  string    `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
    Request  *Request  `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
    Response *Response `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
    // contains filtered or unexported fields
}

func (*EchoResponse) Descriptor

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

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetBackend

func (x *EchoResponse) GetBackend() string

func (*EchoResponse) GetRequest

func (x *EchoResponse) GetRequest() *Request

func (*EchoResponse) GetResponse

func (x *EchoResponse) GetResponse() *Response

func (*EchoResponse) ProtoMessage

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) ProtoReflect

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

func (*EchoResponse) Reset

func (x *EchoResponse) Reset()

func (*EchoResponse) String

func (x *EchoResponse) String() string

type EchoServiceClient

EchoServiceClient is the client API for EchoService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type EchoServiceClient interface {
    Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
}

func NewEchoServiceClient

func NewEchoServiceClient(cc grpc.ClientConnInterface) EchoServiceClient

type EchoServiceServer

EchoServiceServer is the server API for EchoService service. All implementations must embed UnimplementedEchoServiceServer for forward compatibility

type EchoServiceServer interface {
    Echo(context.Context, *EchoRequest) (*EchoResponse, error)
    // contains filtered or unexported methods
}

type Request

type Request struct {
    Headers map[string]string `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Tls     *TLS              `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"`
    // contains filtered or unexported fields
}

func (*Request) Descriptor

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetHeaders

func (x *Request) GetHeaders() map[string]string

func (*Request) GetTls

func (x *Request) GetTls() *TLS

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Response

type Response struct {
    Headers map[string]string `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // contains filtered or unexported fields
}

func (*Response) Descriptor

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetHeaders

func (x *Response) GetHeaders() map[string]string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

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

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

type TLS

type TLS struct {
    Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
    // contains filtered or unexported fields
}

func (*TLS) Descriptor

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

Deprecated: Use TLS.ProtoReflect.Descriptor instead.

func (*TLS) GetEnabled

func (x *TLS) GetEnabled() bool

func (*TLS) ProtoMessage

func (*TLS) ProtoMessage()

func (*TLS) ProtoReflect

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

func (*TLS) Reset

func (x *TLS) Reset()

func (*TLS) String

func (x *TLS) String() string

type UnimplementedEchoServiceServer

UnimplementedEchoServiceServer must be embedded to have forward compatible implementations.

type UnimplementedEchoServiceServer struct {
}

func (UnimplementedEchoServiceServer) Echo

func (UnimplementedEchoServiceServer) Echo(context.Context, *EchoRequest) (*EchoResponse, error)

type UnsafeEchoServiceServer

UnsafeEchoServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EchoServiceServer will result in compilation errors.

type UnsafeEchoServiceServer interface {
    // contains filtered or unexported methods
}