Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterEchoerServer(s grpc.ServiceRegistrar, srv EchoerServer)
- type EchoRequest
- func (*EchoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EchoRequest) GetBytesPayload() []byte
- func (x *EchoRequest) GetEmbeddingBytes() []byte
- func (x *EchoRequest) GetEmbeddingFloat() *EmbeddingFloat
- func (x *EchoRequest) GetMixed() *MixedPayload
- func (x *EchoRequest) GetPayload() isEchoRequest_Payload
- func (x *EchoRequest) GetQuery() string
- func (x *EchoRequest) GetShape() PayloadShape
- func (x *EchoRequest) GetStringPayload() string
- func (*EchoRequest) ProtoMessage()
- func (x *EchoRequest) ProtoReflect() protoreflect.Message
- func (x *EchoRequest) Reset()
- func (x *EchoRequest) String() string
- type EchoRequest_BytesPayload
- type EchoRequest_EmbeddingBytes
- type EchoRequest_EmbeddingFloat
- type EchoRequest_Mixed
- type EchoRequest_StringPayload
- type EchoResponse
- func (*EchoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EchoResponse) GetBytesPayload() []byte
- func (x *EchoResponse) GetEmbeddingBytes() []byte
- func (x *EchoResponse) GetEmbeddingFloat() *EmbeddingFloat
- func (x *EchoResponse) GetExtensions() []*ExtendedInfo
- func (x *EchoResponse) GetKubernetes() *KubernetesInfo
- func (x *EchoResponse) GetMixed() *MixedPayload
- func (x *EchoResponse) GetPayload() isEchoResponse_Payload
- func (x *EchoResponse) GetQuery() string
- func (x *EchoResponse) GetReceivedAtUnixNano() int64
- func (x *EchoResponse) GetRequest() *RequestInfo
- func (x *EchoResponse) GetRuntime() *RuntimeInfo
- func (x *EchoResponse) GetSentAtUnixNano() int64
- func (x *EchoResponse) GetServerDurationNs() int64
- func (x *EchoResponse) GetShape() PayloadShape
- func (x *EchoResponse) GetStringPayload() string
- func (*EchoResponse) ProtoMessage()
- func (x *EchoResponse) ProtoReflect() protoreflect.Message
- func (x *EchoResponse) Reset()
- func (x *EchoResponse) String() string
- type EchoResponse_BytesPayload
- type EchoResponse_EmbeddingBytes
- type EchoResponse_EmbeddingFloat
- type EchoResponse_Mixed
- type EchoResponse_StringPayload
- type EchoerClient
- type EchoerServer
- type EmbeddingFloat
- type ExtendedInfo
- func (*ExtendedInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ExtendedInfo) GetInfo() *KeyMultivalue
- func (x *ExtendedInfo) GetName() string
- func (*ExtendedInfo) ProtoMessage()
- func (x *ExtendedInfo) ProtoReflect() protoreflect.Message
- func (x *ExtendedInfo) Reset()
- func (x *ExtendedInfo) String() string
- type KeyMultivalue
- func (*KeyMultivalue) Descriptor() ([]byte, []int)deprecated
- func (x *KeyMultivalue) GetKey() string
- func (x *KeyMultivalue) GetValues() []string
- func (*KeyMultivalue) ProtoMessage()
- func (x *KeyMultivalue) ProtoReflect() protoreflect.Message
- func (x *KeyMultivalue) Reset()
- func (x *KeyMultivalue) String() string
- type KubernetesInfo
- func (*KubernetesInfo) Descriptor() ([]byte, []int)deprecated
- func (x *KubernetesInfo) GetHostname() string
- func (x *KubernetesInfo) GetPodName() string
- func (x *KubernetesInfo) GetPodNamespace() string
- func (x *KubernetesInfo) GetPodNode() string
- func (*KubernetesInfo) ProtoMessage()
- func (x *KubernetesInfo) ProtoReflect() protoreflect.Message
- func (x *KubernetesInfo) Reset()
- func (x *KubernetesInfo) String() string
- type MixedPayload
- func (*MixedPayload) Descriptor() ([]byte, []int)deprecated
- func (x *MixedPayload) GetAttrs() map[string]string
- func (x *MixedPayload) GetBlob() []byte
- func (x *MixedPayload) GetCount() int32
- func (x *MixedPayload) GetEnabled() bool
- func (x *MixedPayload) GetExtra() *KeyMultivalue
- func (x *MixedPayload) GetId() int64
- func (x *MixedPayload) GetName() string
- func (x *MixedPayload) GetNumbers() []int32
- func (x *MixedPayload) GetRatio() float64
- func (x *MixedPayload) GetTags() []string
- func (*MixedPayload) ProtoMessage()
- func (x *MixedPayload) ProtoReflect() protoreflect.Message
- func (x *MixedPayload) Reset()
- func (x *MixedPayload) String() string
- type ParsedURL
- func (*ParsedURL) Descriptor() ([]byte, []int)deprecated
- func (x *ParsedURL) GetHost() string
- func (x *ParsedURL) GetPath() string
- func (x *ParsedURL) GetQuery() []*KeyMultivalue
- func (x *ParsedURL) GetRawPath() string
- func (x *ParsedURL) GetRawQuery() string
- func (x *ParsedURL) GetScheme() string
- func (*ParsedURL) ProtoMessage()
- func (x *ParsedURL) ProtoReflect() protoreflect.Message
- func (x *ParsedURL) Reset()
- func (x *ParsedURL) String() string
- type PayloadShape
- func (PayloadShape) Descriptor() protoreflect.EnumDescriptor
- func (x PayloadShape) Enum() *PayloadShape
- func (PayloadShape) EnumDescriptor() ([]byte, []int)deprecated
- func (x PayloadShape) Number() protoreflect.EnumNumber
- func (x PayloadShape) String() string
- func (PayloadShape) Type() protoreflect.EnumType
- type RequestInfo
- func (*RequestInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RequestInfo) GetHeader() []*KeyMultivalue
- func (x *RequestInfo) GetMethod() string
- func (x *RequestInfo) GetParsedUrl() *ParsedURL
- func (x *RequestInfo) GetProtocol() string
- func (x *RequestInfo) GetRemoteAddr() string
- func (x *RequestInfo) GetUri() string
- func (*RequestInfo) ProtoMessage()
- func (x *RequestInfo) ProtoReflect() protoreflect.Message
- func (x *RequestInfo) Reset()
- func (x *RequestInfo) String() string
- type RuntimeInfo
- func (*RuntimeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RuntimeInfo) GetGoArch() string
- func (x *RuntimeInfo) GetGoOs() string
- func (x *RuntimeInfo) GetGoVersion() string
- func (x *RuntimeInfo) GetMainModule() string
- func (x *RuntimeInfo) GetMainPath() string
- func (x *RuntimeInfo) GetMainVersion() string
- func (x *RuntimeInfo) GetNumCpus() int64
- func (x *RuntimeInfo) GetNumGoroutines() int64
- func (*RuntimeInfo) ProtoMessage()
- func (x *RuntimeInfo) ProtoReflect() protoreflect.Message
- func (x *RuntimeInfo) Reset()
- func (x *RuntimeInfo) String() string
- type Server
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusRequest) GetForceGrpcStatus() uint32
- func (x *StatusRequest) GetMessage() string
- func (*StatusRequest) ProtoMessage()
- func (x *StatusRequest) ProtoReflect() protoreflect.Message
- func (x *StatusRequest) Reset()
- func (x *StatusRequest) String() string
- type StatusResponse
- type UnimplementedEchoerServer
- type UnsafeEchoerServer
Constants ¶
const ( Echoer_Echo_FullMethodName = "/pkg.echo.v1.Echoer/Echo" Echoer_Status_FullMethodName = "/pkg.echo.v1.Echoer/Status" )
Variables ¶
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.
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)
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) GetQuery ¶
func (x *ParsedURL) GetQuery() []*KeyMultivalue
func (*ParsedURL) GetRawPath ¶
func (*ParsedURL) GetRawQuery ¶
func (*ParsedURL) ProtoMessage ¶
func (*ParsedURL) ProtoMessage()
func (*ParsedURL) ProtoReflect ¶
func (x *ParsedURL) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
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 (x PayloadShape) Number() protoreflect.EnumNumber
func (PayloadShape) String ¶
func (x PayloadShape) String() string
func (PayloadShape) Type ¶
func (PayloadShape) Type() protoreflect.EnumType
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.