proto

package
v0.0.0-...-3b31870 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EchoTestService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.EchoTestService",
	HandlerType: (*EchoTestServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Echo",
			Handler:    _EchoTestService_Echo_Handler,
		},
		{
			MethodName: "ForwardEcho",
			Handler:    _EchoTestService_ForwardEcho_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "echo.proto",
}

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

View Source 
var File_echo_proto protoreflect.FileDescriptor

Functions

func RegisterEchoTestServiceServer 

func RegisterEchoTestServiceServer(s grpc.ServiceRegistrar, srv EchoTestServiceServer)

Types

type Alpn 

type Alpn struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Alpn) Descriptor deprecated 

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

Deprecated: Use Alpn.ProtoReflect.Descriptor instead.

func (*Alpn) GetValue 

func (x *Alpn) GetValue() []string

func (*Alpn) ProtoMessage 

func (*Alpn) ProtoMessage()

func (*Alpn) ProtoReflect 

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

func (*Alpn) Reset 

func (x *Alpn) Reset()

func (*Alpn) String 

func (x *Alpn) String() string

type EchoRequest 

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

func (*EchoRequest) Descriptor deprecated 

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

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetMessage 

func (x *EchoRequest) GetMessage() 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 {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoResponse) Descriptor deprecated 

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

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetMessage 

func (x *EchoResponse) GetMessage() string

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 EchoTestServiceClient 

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

EchoTestServiceClient is the client API for EchoTestService 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.

func NewEchoTestServiceClient 

func NewEchoTestServiceClient(cc grpc.ClientConnInterface) EchoTestServiceClient

type EchoTestServiceServer 

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

EchoTestServiceServer is the server API for EchoTestService service. All implementations must embed UnimplementedEchoTestServiceServer for forward compatibility

type ForwardEchoRequest 

type ForwardEchoRequest struct {
	Count         int32     `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Qps           int32     `protobuf:"varint,2,opt,name=qps,proto3" json:"qps,omitempty"`
	TimeoutMicros int64     `protobuf:"varint,3,opt,name=timeout_micros,json=timeoutMicros,proto3" json:"timeout_micros,omitempty"`
	Url           string    `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	Headers       []*Header `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	Message       string    `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	// Method for the request. Valid only for HTTP
	Method string `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"`
	// If true, requests will be sent using h2c prior knowledge
	Http2 bool `protobuf:"varint,7,opt,name=http2,proto3" json:"http2,omitempty"`
	// If true, requests will be sent using http3
	Http3 bool `protobuf:"varint,15,opt,name=http3,proto3" json:"http3,omitempty"`
	// If true, requests will not be sent until magic string is received
	ServerFirst bool `protobuf:"varint,8,opt,name=serverFirst,proto3" json:"serverFirst,omitempty"`
	// If true, 301 redirects will be followed
	FollowRedirects bool `protobuf:"varint,14,opt,name=followRedirects,proto3" json:"followRedirects,omitempty"`
	// If non-empty, make the request with the corresponding cert and key.
	Cert string `protobuf:"bytes,10,opt,name=cert,proto3" json:"cert,omitempty"`
	Key  string `protobuf:"bytes,11,opt,name=key,proto3" json:"key,omitempty"`
	// If non-empty, verify the server CA
	CaCert string `protobuf:"bytes,12,opt,name=caCert,proto3" json:"caCert,omitempty"`
	// If non-empty, make the request with the corresponding cert and key file.
	CertFile string `protobuf:"bytes,16,opt,name=certFile,proto3" json:"certFile,omitempty"`
	KeyFile  string `protobuf:"bytes,17,opt,name=keyFile,proto3" json:"keyFile,omitempty"`
	// If non-empty, verify the server CA with the ca cert file.
	CaCertFile string `protobuf:"bytes,18,opt,name=caCertFile,proto3" json:"caCertFile,omitempty"`
	// Skip verifying peer's certificate.
	InsecureSkipVerify bool `protobuf:"varint,19,opt,name=insecureSkipVerify,proto3" json:"insecureSkipVerify,omitempty"`
	// List of ALPNs to present. If not set, this will be automatically be set based on the protocol
	Alpn *Alpn `protobuf:"bytes,13,opt,name=alpn,proto3" json:"alpn,omitempty"`
	// Server name (SNI) to present in TLS connections. If not set, Host will be used for http requests.
	ServerName string `protobuf:"bytes,20,opt,name=serverName,proto3" json:"serverName,omitempty"`
	// Expected response determines what string to look for in the response to validate TCP requests succeeded.
	// If not set, defaults to "StatusCode=200"
	ExpectedResponse *wrappers.StringValue `protobuf:"bytes,21,opt,name=expectedResponse,proto3" json:"expectedResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardEchoRequest) Descriptor deprecated 

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

Deprecated: Use ForwardEchoRequest.ProtoReflect.Descriptor instead.

func (*ForwardEchoRequest) GetAlpn 

func (x *ForwardEchoRequest) GetAlpn() *Alpn

func (*ForwardEchoRequest) GetCaCert 

func (x *ForwardEchoRequest) GetCaCert() string

func (*ForwardEchoRequest) GetCaCertFile 

func (x *ForwardEchoRequest) GetCaCertFile() string

func (*ForwardEchoRequest) GetCert 

func (x *ForwardEchoRequest) GetCert() string

func (*ForwardEchoRequest) GetCertFile 

func (x *ForwardEchoRequest) GetCertFile() string

func (*ForwardEchoRequest) GetCount 

func (x *ForwardEchoRequest) GetCount() int32

func (*ForwardEchoRequest) GetExpectedResponse 

func (x *ForwardEchoRequest) GetExpectedResponse() *wrappers.StringValue

func (*ForwardEchoRequest) GetFollowRedirects 

func (x *ForwardEchoRequest) GetFollowRedirects() bool

func (*ForwardEchoRequest) GetHeaders 

func (x *ForwardEchoRequest) GetHeaders() []*Header

func (*ForwardEchoRequest) GetHttp2 

func (x *ForwardEchoRequest) GetHttp2() bool

func (*ForwardEchoRequest) GetHttp3 

func (x *ForwardEchoRequest) GetHttp3() bool

func (*ForwardEchoRequest) GetInsecureSkipVerify 

func (x *ForwardEchoRequest) GetInsecureSkipVerify() bool

func (*ForwardEchoRequest) GetKey 

func (x *ForwardEchoRequest) GetKey() string

func (*ForwardEchoRequest) GetKeyFile 

func (x *ForwardEchoRequest) GetKeyFile() string

func (*ForwardEchoRequest) GetMessage 

func (x *ForwardEchoRequest) GetMessage() string

func (*ForwardEchoRequest) GetMethod 

func (x *ForwardEchoRequest) GetMethod() string

func (*ForwardEchoRequest) GetQps 

func (x *ForwardEchoRequest) GetQps() int32

func (*ForwardEchoRequest) GetServerFirst 

func (x *ForwardEchoRequest) GetServerFirst() bool

func (*ForwardEchoRequest) GetServerName 

func (x *ForwardEchoRequest) GetServerName() string

func (*ForwardEchoRequest) GetTimeoutMicros 

func (x *ForwardEchoRequest) GetTimeoutMicros() int64

func (*ForwardEchoRequest) GetUrl 

func (x *ForwardEchoRequest) GetUrl() string

func (*ForwardEchoRequest) ProtoMessage 

func (*ForwardEchoRequest) ProtoMessage()

func (*ForwardEchoRequest) ProtoReflect 

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

func (*ForwardEchoRequest) Reset 

func (x *ForwardEchoRequest) Reset()

func (*ForwardEchoRequest) String 

func (x *ForwardEchoRequest) String() string

type ForwardEchoResponse 

type ForwardEchoResponse struct {
	Output []string `protobuf:"bytes,1,rep,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardEchoResponse) Descriptor deprecated 

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

Deprecated: Use ForwardEchoResponse.ProtoReflect.Descriptor instead.

func (*ForwardEchoResponse) GetOutput 

func (x *ForwardEchoResponse) GetOutput() []string

func (*ForwardEchoResponse) ProtoMessage 

func (*ForwardEchoResponse) ProtoMessage()

func (*ForwardEchoResponse) ProtoReflect 

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

func (*ForwardEchoResponse) Reset 

func (x *ForwardEchoResponse) Reset()

func (*ForwardEchoResponse) String 

func (x *ForwardEchoResponse) String() string
type Header struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetKey 

func (x *Header) GetKey() string

func (*Header) GetValue 

func (x *Header) GetValue() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type UnimplementedEchoTestServiceServer 

type UnimplementedEchoTestServiceServer struct {
}

UnimplementedEchoTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEchoTestServiceServer) Echo 

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

func (UnimplementedEchoTestServiceServer) ForwardEcho 

func (UnimplementedEchoTestServiceServer) ForwardEcho(context.Context, *ForwardEchoRequest) (*ForwardEchoResponse, error)

type UnsafeEchoTestServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.