dynrpc

package
v0.8.2 Latest Latest
Warning

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

Go to latest
Published: Mar 20, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

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