v1

package
v0.0.0-...-d3cd587 Latest Latest
Warning

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

Go to latest
Published: Jun 10, 2026 License: MIT Imports: 13 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 (
	PayloadShape_name = map[int32]string{
		0: "PAYLOAD_SHAPE_UNSPECIFIED",
		1: "PAYLOAD_SHAPE_STRING",
		2: "PAYLOAD_SHAPE_BYTES",
		3: "PAYLOAD_SHAPE_EMBEDDING_FLOAT",
		4: "PAYLOAD_SHAPE_EMBEDDING_BYTES",
		5: "PAYLOAD_SHAPE_MIXED",
	}
	PayloadShape_value = map[string]int32{
		"PAYLOAD_SHAPE_UNSPECIFIED":     0,
		"PAYLOAD_SHAPE_STRING":          1,
		"PAYLOAD_SHAPE_BYTES":           2,
		"PAYLOAD_SHAPE_EMBEDDING_FLOAT": 3,
		"PAYLOAD_SHAPE_EMBEDDING_BYTES": 4,
		"PAYLOAD_SHAPE_MIXED":           5,
	}
)

Enum value maps for PayloadShape.

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"`
	Shape PayloadShape `protobuf:"varint,2,opt,name=shape,proto3,enum=pkg.echo.v1.PayloadShape" json:"shape,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*EchoRequest_StringPayload
	//	*EchoRequest_BytesPayload
	//	*EchoRequest_EmbeddingFloat
	//	*EchoRequest_EmbeddingBytes
	//	*EchoRequest_Mixed
	Payload isEchoRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*EchoRequest) Descriptor deprecated

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

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetBytesPayload

func (x *EchoRequest) GetBytesPayload() []byte

func (*EchoRequest) GetEmbeddingBytes

func (x *EchoRequest) GetEmbeddingBytes() []byte

func (*EchoRequest) GetEmbeddingFloat

func (x *EchoRequest) GetEmbeddingFloat() *EmbeddingFloat

func (*EchoRequest) GetMixed

func (x *EchoRequest) GetMixed() *MixedPayload

func (*EchoRequest) GetPayload

func (x *EchoRequest) GetPayload() isEchoRequest_Payload

func (*EchoRequest) GetQuery

func (x *EchoRequest) GetQuery() string

func (*EchoRequest) GetShape

func (x *EchoRequest) GetShape() PayloadShape

func (*EchoRequest) GetStringPayload

func (x *EchoRequest) GetStringPayload() 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 EchoRequest_BytesPayload

type EchoRequest_BytesPayload struct {
	BytesPayload []byte `protobuf:"bytes,11,opt,name=bytes_payload,json=bytesPayload,proto3,oneof"`
}

type EchoRequest_EmbeddingBytes

type EchoRequest_EmbeddingBytes struct {
	EmbeddingBytes []byte `protobuf:"bytes,13,opt,name=embedding_bytes,json=embeddingBytes,proto3,oneof"`
}

type EchoRequest_EmbeddingFloat

type EchoRequest_EmbeddingFloat struct {
	EmbeddingFloat *EmbeddingFloat `protobuf:"bytes,12,opt,name=embedding_float,json=embeddingFloat,proto3,oneof"`
}

type EchoRequest_Mixed

type EchoRequest_Mixed struct {
	Mixed *MixedPayload `protobuf:"bytes,14,opt,name=mixed,proto3,oneof"`
}

type EchoRequest_StringPayload

type EchoRequest_StringPayload struct {
	StringPayload string `protobuf:"bytes,10,opt,name=string_payload,json=stringPayload,proto3,oneof"`
}

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"`
	ServerDurationNs   int64           `protobuf:"varint,6,opt,name=server_duration_ns,json=serverDurationNs,proto3" json:"server_duration_ns,omitempty"`
	ReceivedAtUnixNano int64           `protobuf:"varint,7,opt,name=received_at_unix_nano,json=receivedAtUnixNano,proto3" json:"received_at_unix_nano,omitempty"`
	SentAtUnixNano     int64           `protobuf:"varint,8,opt,name=sent_at_unix_nano,json=sentAtUnixNano,proto3" json:"sent_at_unix_nano,omitempty"`
	Shape              PayloadShape    `protobuf:"varint,9,opt,name=shape,proto3,enum=pkg.echo.v1.PayloadShape" json:"shape,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*EchoResponse_StringPayload
	//	*EchoResponse_BytesPayload
	//	*EchoResponse_EmbeddingFloat
	//	*EchoResponse_EmbeddingBytes
	//	*EchoResponse_Mixed
	Payload isEchoResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*EchoResponse) Descriptor deprecated

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

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetBytesPayload

func (x *EchoResponse) GetBytesPayload() []byte

func (*EchoResponse) GetEmbeddingBytes

func (x *EchoResponse) GetEmbeddingBytes() []byte

func (*EchoResponse) GetEmbeddingFloat

func (x *EchoResponse) GetEmbeddingFloat() *EmbeddingFloat

func (*EchoResponse) GetExtensions

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

func (*EchoResponse) GetKubernetes

func (x *EchoResponse) GetKubernetes() *KubernetesInfo

func (*EchoResponse) GetMixed

func (x *EchoResponse) GetMixed() *MixedPayload

func (*EchoResponse) GetPayload

func (x *EchoResponse) GetPayload() isEchoResponse_Payload

func (*EchoResponse) GetQuery

func (x *EchoResponse) GetQuery() string

func (*EchoResponse) GetReceivedAtUnixNano

func (x *EchoResponse) GetReceivedAtUnixNano() int64

func (*EchoResponse) GetRequest

func (x *EchoResponse) GetRequest() *RequestInfo

func (*EchoResponse) GetRuntime

func (x *EchoResponse) GetRuntime() *RuntimeInfo

func (*EchoResponse) GetSentAtUnixNano

func (x *EchoResponse) GetSentAtUnixNano() int64

func (*EchoResponse) GetServerDurationNs

func (x *EchoResponse) GetServerDurationNs() int64

func (*EchoResponse) GetShape

func (x *EchoResponse) GetShape() PayloadShape

func (*EchoResponse) GetStringPayload

func (x *EchoResponse) GetStringPayload() 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 EchoResponse_BytesPayload

type EchoResponse_BytesPayload struct {
	BytesPayload []byte `protobuf:"bytes,11,opt,name=bytes_payload,json=bytesPayload,proto3,oneof"`
}

type EchoResponse_EmbeddingBytes

type EchoResponse_EmbeddingBytes struct {
	EmbeddingBytes []byte `protobuf:"bytes,13,opt,name=embedding_bytes,json=embeddingBytes,proto3,oneof"`
}

type EchoResponse_EmbeddingFloat

type EchoResponse_EmbeddingFloat struct {
	EmbeddingFloat *EmbeddingFloat `protobuf:"bytes,12,opt,name=embedding_float,json=embeddingFloat,proto3,oneof"`
}

type EchoResponse_Mixed

type EchoResponse_Mixed struct {
	Mixed *MixedPayload `protobuf:"bytes,14,opt,name=mixed,proto3,oneof"`
}

type EchoResponse_StringPayload

type EchoResponse_StringPayload struct {
	StringPayload string `protobuf:"bytes,10,opt,name=string_payload,json=stringPayload,proto3,oneof"`
}

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 EmbeddingFloat

type EmbeddingFloat struct {
	Values []float32 `protobuf:"fixed32,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*EmbeddingFloat) Descriptor deprecated

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

Deprecated: Use EmbeddingFloat.ProtoReflect.Descriptor instead.

func (*EmbeddingFloat) GetValues

func (x *EmbeddingFloat) GetValues() []float32

func (*EmbeddingFloat) ProtoMessage

func (*EmbeddingFloat) ProtoMessage()

func (*EmbeddingFloat) ProtoReflect

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

func (*EmbeddingFloat) Reset

func (x *EmbeddingFloat) Reset()

func (*EmbeddingFloat) String

func (x *EmbeddingFloat) String() string

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 MixedPayload

type MixedPayload struct {
	Id      int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Count   int32             `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	Ratio   float64           `protobuf:"fixed64,4,opt,name=ratio,proto3" json:"ratio,omitempty"`
	Enabled bool              `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Tags    []string          `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	Numbers []int32           `protobuf:"varint,7,rep,packed,name=numbers,proto3" json:"numbers,omitempty"`
	Attrs   map[string]string `` /* 137-byte string literal not displayed */
	Blob    []byte            `protobuf:"bytes,9,opt,name=blob,proto3" json:"blob,omitempty"`
	Extra   *KeyMultivalue    `protobuf:"bytes,10,opt,name=extra,proto3" json:"extra,omitempty"`
	// contains filtered or unexported fields
}

func (*MixedPayload) Descriptor deprecated

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

Deprecated: Use MixedPayload.ProtoReflect.Descriptor instead.

func (*MixedPayload) GetAttrs

func (x *MixedPayload) GetAttrs() map[string]string

func (*MixedPayload) GetBlob

func (x *MixedPayload) GetBlob() []byte

func (*MixedPayload) GetCount

func (x *MixedPayload) GetCount() int32

func (*MixedPayload) GetEnabled

func (x *MixedPayload) GetEnabled() bool

func (*MixedPayload) GetExtra

func (x *MixedPayload) GetExtra() *KeyMultivalue

func (*MixedPayload) GetId

func (x *MixedPayload) GetId() int64

func (*MixedPayload) GetName

func (x *MixedPayload) GetName() string

func (*MixedPayload) GetNumbers

func (x *MixedPayload) GetNumbers() []int32

func (*MixedPayload) GetRatio

func (x *MixedPayload) GetRatio() float64

func (*MixedPayload) GetTags

func (x *MixedPayload) GetTags() []string

func (*MixedPayload) ProtoMessage

func (*MixedPayload) ProtoMessage()

func (*MixedPayload) ProtoReflect

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

func (*MixedPayload) Reset

func (x *MixedPayload) Reset()

func (*MixedPayload) String

func (x *MixedPayload) 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 PayloadShape

type PayloadShape int32
const (
	PayloadShape_PAYLOAD_SHAPE_UNSPECIFIED     PayloadShape = 0
	PayloadShape_PAYLOAD_SHAPE_STRING          PayloadShape = 1
	PayloadShape_PAYLOAD_SHAPE_BYTES           PayloadShape = 2
	PayloadShape_PAYLOAD_SHAPE_EMBEDDING_FLOAT PayloadShape = 3
	PayloadShape_PAYLOAD_SHAPE_EMBEDDING_BYTES PayloadShape = 4
	PayloadShape_PAYLOAD_SHAPE_MIXED           PayloadShape = 5
)

func (PayloadShape) Descriptor

func (PayloadShape) Enum

func (x PayloadShape) Enum() *PayloadShape

func (PayloadShape) EnumDescriptor deprecated

func (PayloadShape) EnumDescriptor() ([]byte, []int)

Deprecated: Use PayloadShape.Descriptor instead.

func (PayloadShape) Number

func (PayloadShape) String

func (x PayloadShape) String() string

func (PayloadShape) Type

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) Status

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL