queueitem

Documentation

Index

• Variables
• type QueueItem
  • func (*QueueItem) Descriptor() ([]byte, []int)
  • func (x *QueueItem) GetMethod() string
  • func (x *QueueItem) GetPayload() *anypb.Any
  • func (x *QueueItem) GetService() string
  • func (*QueueItem) ProtoMessage()
  • func (x *QueueItem) ProtoReflect() protoreflect.Message
  • func (x *QueueItem) Reset()
  • func (x *QueueItem) String() string

Variables

var File_proto_queueitem_queue_item_proto protoreflect.FileDescriptor

Types

type QueueItem

type QueueItem struct {

	// service is the fully-qualified service name (e.g., "pkg.MyService")
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// method is the method name (e.g., "MyMethod")
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// payload contains the request message packed as google.protobuf.Any
	Payload *anypb.Any `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

QueueItem represents a queued gRPC call with its service, method, and payload.

func (*QueueItem) Descriptor

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

Deprecated: Use QueueItem.ProtoReflect.Descriptor instead.

func (*QueueItem) GetMethod

func (x *QueueItem) GetMethod() string

func (*QueueItem) GetPayload

func (x *QueueItem) GetPayload() *anypb.Any

func (*QueueItem) GetService

func (x *QueueItem) GetService() string

func (*QueueItem) ProtoMessage

func (*QueueItem) ProtoMessage()

func (*QueueItem) ProtoReflect

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

func (*QueueItem) Reset

func (x *QueueItem) Reset()

func (*QueueItem) String

func (x *QueueItem) String() string