Documentation ¶
Index ¶
- Variables
- type KeyedEvent
- func (*KeyedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *KeyedEvent) GetAttributes() map[string]string
- func (x *KeyedEvent) GetKey() string
- func (x *KeyedEvent) GetPayload() []byte
- func (*KeyedEvent) ProtoMessage()
- func (x *KeyedEvent) ProtoReflect() protoreflect.Message
- func (x *KeyedEvent) Reset()
- func (x *KeyedEvent) String() string
- type RpcRequest
- func (*RpcRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RpcRequest) GetKey() string
- func (x *RpcRequest) GetRequest() *structpb.Value
- func (x *RpcRequest) GetSenderAssumes() int32
- func (*RpcRequest) ProtoMessage()
- func (x *RpcRequest) ProtoReflect() protoreflect.Message
- func (x *RpcRequest) Reset()
- func (x *RpcRequest) String() string
- type RpcResponse
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proto_dynrpc_dynrpc_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type KeyedEvent ¶
type KeyedEvent struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` Attributes map[string]string `` /* 162-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KeyedEvent) Descriptor
deprecated
func (*KeyedEvent) Descriptor() ([]byte, []int)
Deprecated: Use KeyedEvent.ProtoReflect.Descriptor instead.
func (*KeyedEvent) GetAttributes ¶
func (x *KeyedEvent) GetAttributes() map[string]string
func (*KeyedEvent) GetKey ¶
func (x *KeyedEvent) GetKey() string
func (*KeyedEvent) GetPayload ¶
func (x *KeyedEvent) GetPayload() []byte
func (*KeyedEvent) ProtoMessage ¶
func (*KeyedEvent) ProtoMessage()
func (*KeyedEvent) ProtoReflect ¶
func (x *KeyedEvent) ProtoReflect() protoreflect.Message
func (*KeyedEvent) Reset ¶
func (x *KeyedEvent) Reset()
func (*KeyedEvent) String ¶
func (x *KeyedEvent) String() string
type RpcRequest ¶
type RpcRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Request *structpb.Value `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` // internal: see src/utils/assumptions.ts SenderAssumes int32 `protobuf:"varint,101,opt,name=sender_assumes,json=senderAssumes,proto3" json:"sender_assumes,omitempty"` // contains filtered or unexported fields }
func (*RpcRequest) Descriptor
deprecated
func (*RpcRequest) Descriptor() ([]byte, []int)
Deprecated: Use RpcRequest.ProtoReflect.Descriptor instead.
func (*RpcRequest) GetKey ¶
func (x *RpcRequest) GetKey() string
func (*RpcRequest) GetRequest ¶
func (x *RpcRequest) GetRequest() *structpb.Value
func (*RpcRequest) GetSenderAssumes ¶
func (x *RpcRequest) GetSenderAssumes() int32
func (*RpcRequest) ProtoMessage ¶
func (*RpcRequest) ProtoMessage()
func (*RpcRequest) ProtoReflect ¶
func (x *RpcRequest) ProtoReflect() protoreflect.Message
func (*RpcRequest) Reset ¶
func (x *RpcRequest) Reset()
func (*RpcRequest) String ¶
func (x *RpcRequest) String() string
type RpcResponse ¶
type RpcResponse struct { Response *structpb.Value `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
func (*RpcResponse) Descriptor
deprecated
func (*RpcResponse) Descriptor() ([]byte, []int)
Deprecated: Use RpcResponse.ProtoReflect.Descriptor instead.
func (*RpcResponse) GetResponse ¶
func (x *RpcResponse) GetResponse() *structpb.Value
func (*RpcResponse) ProtoMessage ¶
func (*RpcResponse) ProtoMessage()
func (*RpcResponse) ProtoReflect ¶
func (x *RpcResponse) ProtoReflect() protoreflect.Message
func (*RpcResponse) Reset ¶
func (x *RpcResponse) Reset()
func (*RpcResponse) String ¶
func (x *RpcResponse) String() string
Click to show internal directories.
Click to hide internal directories.