v1

package
v0.0.0-...-9fbac25 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Echoer_Echo_FullMethodName   = "/pkg.echo.v1.Echoer/Echo"
	Echoer_Status_FullMethodName = "/pkg.echo.v1.Echoer/Status"
)

Variables

View Source 
var Echoer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pkg.echo.v1.Echoer",
	HandlerType: (*EchoerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Echo",
			Handler:    _Echoer_Echo_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Echoer_Status_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/echo/v1/echo.proto",
}

Echoer_ServiceDesc is the grpc.ServiceDesc for Echoer 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_pkg_echo_v1_echo_proto protoreflect.FileDescriptor

Functions

func RegisterEchoerServer 

func RegisterEchoerServer(s grpc.ServiceRegistrar, srv EchoerServer)

Types

type EchoRequest 

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

func (*EchoRequest) Descriptor deprecated 

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

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetQuery 

func (x *EchoRequest) GetQuery() 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 {
	Query      string          `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Kubernetes *KubernetesInfo `protobuf:"bytes,2,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`
	Request    *RequestInfo    `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	Runtime    *RuntimeInfo    `protobuf:"bytes,4,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Extensions []*ExtendedInfo `protobuf:"bytes,5,rep,name=extensions,proto3" json:"extensions,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoResponse) Descriptor deprecated 

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

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetExtensions 

func (x *EchoResponse) GetExtensions() []*ExtendedInfo

func (*EchoResponse) GetKubernetes 

func (x *EchoResponse) GetKubernetes() *KubernetesInfo

func (*EchoResponse) GetQuery 

func (x *EchoResponse) GetQuery() string

func (*EchoResponse) GetRequest 

func (x *EchoResponse) GetRequest() *RequestInfo

func (*EchoResponse) GetRuntime 

func (x *EchoResponse) GetRuntime() *RuntimeInfo

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 EchoerClient 

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

EchoerClient is the client API for Echoer 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 NewEchoerClient 

func NewEchoerClient(cc grpc.ClientConnInterface) EchoerClient

type EchoerServer 

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

EchoerServer is the server API for Echoer service. All implementations must embed UnimplementedEchoerServer for forward compatibility

type ExtendedInfo 

type ExtendedInfo struct {
	Name string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Info *KeyMultivalue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendedInfo) Descriptor deprecated 

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

Deprecated: Use ExtendedInfo.ProtoReflect.Descriptor instead.

func (*ExtendedInfo) GetInfo 

func (x *ExtendedInfo) GetInfo() *KeyMultivalue

func (*ExtendedInfo) GetName 

func (x *ExtendedInfo) GetName() string

func (*ExtendedInfo) ProtoMessage 

func (*ExtendedInfo) ProtoMessage()

func (*ExtendedInfo) ProtoReflect 

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

func (*ExtendedInfo) Reset 

func (x *ExtendedInfo) Reset()

func (*ExtendedInfo) String 

func (x *ExtendedInfo) String() string

type KeyMultivalue 

type KeyMultivalue struct {
	Key    string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyMultivalue) Descriptor deprecated 

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

Deprecated: Use KeyMultivalue.ProtoReflect.Descriptor instead.

func (*KeyMultivalue) GetKey 

func (x *KeyMultivalue) GetKey() string

func (*KeyMultivalue) GetValues 

func (x *KeyMultivalue) GetValues() []string

func (*KeyMultivalue) ProtoMessage 

func (*KeyMultivalue) ProtoMessage()

func (*KeyMultivalue) ProtoReflect 

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

func (*KeyMultivalue) Reset 

func (x *KeyMultivalue) Reset()

func (*KeyMultivalue) String 

func (x *KeyMultivalue) String() string

type KubernetesInfo 

type KubernetesInfo struct {
	Hostname     string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	PodName      string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	PodNamespace string `protobuf:"bytes,3,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	PodNode      string `protobuf:"bytes,4,opt,name=pod_node,json=podNode,proto3" json:"pod_node,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesInfo) Descriptor deprecated 

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

Deprecated: Use KubernetesInfo.ProtoReflect.Descriptor instead.

func (*KubernetesInfo) GetHostname 

func (x *KubernetesInfo) GetHostname() string

func (*KubernetesInfo) GetPodName 

func (x *KubernetesInfo) GetPodName() string

func (*KubernetesInfo) GetPodNamespace 

func (x *KubernetesInfo) GetPodNamespace() string

func (*KubernetesInfo) GetPodNode 

func (x *KubernetesInfo) GetPodNode() string

func (*KubernetesInfo) ProtoMessage 

func (*KubernetesInfo) ProtoMessage()

func (*KubernetesInfo) ProtoReflect 

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

func (*KubernetesInfo) Reset 

func (x *KubernetesInfo) Reset()

func (*KubernetesInfo) String 

func (x *KubernetesInfo) String() string

type ParsedURL 

type ParsedURL struct {
	Scheme   string           `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"`
	Host     string           `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Path     string           `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	RawPath  string           `protobuf:"bytes,4,opt,name=raw_path,json=rawPath,proto3" json:"raw_path,omitempty"`
	RawQuery string           `protobuf:"bytes,5,opt,name=raw_query,json=rawQuery,proto3" json:"raw_query,omitempty"`
	Query    []*KeyMultivalue `protobuf:"bytes,6,rep,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*ParsedURL) Descriptor deprecated 

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

Deprecated: Use ParsedURL.ProtoReflect.Descriptor instead.

func (*ParsedURL) GetHost 

func (x *ParsedURL) GetHost() string

func (*ParsedURL) GetPath 

func (x *ParsedURL) GetPath() string

func (*ParsedURL) GetQuery 

func (x *ParsedURL) GetQuery() []*KeyMultivalue

func (*ParsedURL) GetRawPath 

func (x *ParsedURL) GetRawPath() string

func (*ParsedURL) GetRawQuery 

func (x *ParsedURL) GetRawQuery() string

func (*ParsedURL) GetScheme 

func (x *ParsedURL) GetScheme() string

func (*ParsedURL) ProtoMessage 

func (*ParsedURL) ProtoMessage()

func (*ParsedURL) ProtoReflect 

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

func (*ParsedURL) Reset 

func (x *ParsedURL) Reset()

func (*ParsedURL) String 

func (x *ParsedURL) String() string

type RequestInfo 

type RequestInfo struct {
	Protocol   string           `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	RemoteAddr string           `protobuf:"bytes,2,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	Method     string           `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Uri        string           `protobuf:"bytes,4,opt,name=uri,proto3" json:"uri,omitempty"`
	ParsedUrl  *ParsedURL       `protobuf:"bytes,5,opt,name=parsed_url,json=parsedUrl,proto3" json:"parsed_url,omitempty"`
	Header     []*KeyMultivalue `protobuf:"bytes,6,rep,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestInfo) Descriptor deprecated 

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

Deprecated: Use RequestInfo.ProtoReflect.Descriptor instead.

func (*RequestInfo) GetHeader 

func (x *RequestInfo) GetHeader() []*KeyMultivalue

func (*RequestInfo) GetMethod 

func (x *RequestInfo) GetMethod() string

func (*RequestInfo) GetParsedUrl 

func (x *RequestInfo) GetParsedUrl() *ParsedURL

func (*RequestInfo) GetProtocol 

func (x *RequestInfo) GetProtocol() string

func (*RequestInfo) GetRemoteAddr 

func (x *RequestInfo) GetRemoteAddr() string

func (*RequestInfo) GetUri 

func (x *RequestInfo) GetUri() string

func (*RequestInfo) ProtoMessage 

func (*RequestInfo) ProtoMessage()

func (*RequestInfo) ProtoReflect 

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

func (*RequestInfo) Reset 

func (x *RequestInfo) Reset()

func (*RequestInfo) String 

func (x *RequestInfo) String() string

type RuntimeInfo 

type RuntimeInfo struct {
	GoVersion     string `protobuf:"bytes,1,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	GoArch        string `protobuf:"bytes,2,opt,name=go_arch,json=goArch,proto3" json:"go_arch,omitempty"`
	GoOs          string `protobuf:"bytes,3,opt,name=go_os,json=goOs,proto3" json:"go_os,omitempty"`
	NumCpus       int64  `protobuf:"varint,4,opt,name=num_cpus,json=numCpus,proto3" json:"num_cpus,omitempty"`
	NumGoroutines int64  `protobuf:"varint,5,opt,name=num_goroutines,json=numGoroutines,proto3" json:"num_goroutines,omitempty"`
	MainModule    string `protobuf:"bytes,6,opt,name=main_module,json=mainModule,proto3" json:"main_module,omitempty"`
	MainPath      string `protobuf:"bytes,7,opt,name=main_path,json=mainPath,proto3" json:"main_path,omitempty"`
	MainVersion   string `protobuf:"bytes,8,opt,name=main_version,json=mainVersion,proto3" json:"main_version,omitempty"`
	// contains filtered or unexported fields
}

func (*RuntimeInfo) Descriptor deprecated 

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

Deprecated: Use RuntimeInfo.ProtoReflect.Descriptor instead.

func (*RuntimeInfo) GetGoArch 

func (x *RuntimeInfo) GetGoArch() string

func (*RuntimeInfo) GetGoOs 

func (x *RuntimeInfo) GetGoOs() string

func (*RuntimeInfo) GetGoVersion 

func (x *RuntimeInfo) GetGoVersion() string

func (*RuntimeInfo) GetMainModule 

func (x *RuntimeInfo) GetMainModule() string

func (*RuntimeInfo) GetMainPath 

func (x *RuntimeInfo) GetMainPath() string

func (*RuntimeInfo) GetMainVersion 

func (x *RuntimeInfo) GetMainVersion() string

func (*RuntimeInfo) GetNumCpus 

func (x *RuntimeInfo) GetNumCpus() int64

func (*RuntimeInfo) GetNumGoroutines 

func (x *RuntimeInfo) GetNumGoroutines() int64

func (*RuntimeInfo) ProtoMessage 

func (*RuntimeInfo) ProtoMessage()

func (*RuntimeInfo) ProtoReflect 

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

func (*RuntimeInfo) Reset 

func (x *RuntimeInfo) Reset()

func (*RuntimeInfo) String 

func (x *RuntimeInfo) String() string

type Server 

type Server struct {
	UnimplementedEchoerServer
}

func (*Server) Echo 

func (s *Server) Echo(ctx context.Context, req *EchoRequest) (*EchoResponse, error)

func (*Server) Status 

func (s *Server) Status(_ context.Context, req *StatusRequest) (*StatusResponse, error)

type StatusRequest 

type StatusRequest struct {

	// force_grpc_status forces a status response conforming to the standard
	// gRPC Core status codes: https://grpc.github.io/grpc/core/md_doc_statuscodes.html
	// Following those standard status codes, a value of zero (or unset) will
	// return OK.
	ForceGrpcStatus uint32 `protobuf:"varint,1,opt,name=force_grpc_status,json=forceGrpcStatus,proto3" json:"force_grpc_status,omitempty"`
	// message is an optional string returned alongside the code.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

StatusRequest determines the error (if any) to return to the caller, representing on-wire status that the caller expects from the server.

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetForceGrpcStatus 

func (x *StatusRequest) GetForceGrpcStatus() uint32

func (*StatusRequest) GetMessage 

func (x *StatusRequest) GetMessage() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

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

StatusResponse is a (currently) empty gRPC message.

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type UnimplementedEchoerServer 

type UnimplementedEchoerServer struct {
}

UnimplementedEchoerServer must be embedded to have forward compatible implementations.

func (UnimplementedEchoerServer) Echo 

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

func (UnimplementedEchoerServer) Status 

func (UnimplementedEchoerServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeEchoerServer 

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

UnsafeEchoerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EchoerServer 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.