mqueue_rpc

package
v0.51.3 Latest Latest
Warning

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

 Go to latest Published: May 9, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCMqueueStoreServiceID = "mqueue.rpc.MqueueStore"
View Source 
const SRPCQueueOpsServiceID = "mqueue.rpc.QueueOps"

Variables

This section is empty.

Functions

func NewSRPCMqueueStoreHandler 

func NewSRPCMqueueStoreHandler(impl SRPCMqueueStoreServer, serviceID string) srpc.Handler

NewSRPCMqueueStoreHandler constructs a new RPC handler. serviceID: if empty, uses default: mqueue.rpc.MqueueStore

func NewSRPCQueueOpsHandler 

func NewSRPCQueueOpsHandler(impl SRPCQueueOpsServer, serviceID string) srpc.Handler

NewSRPCQueueOpsHandler constructs a new RPC handler. serviceID: if empty, uses default: mqueue.rpc.QueueOps

func SRPCRegisterMqueueStore 

func SRPCRegisterMqueueStore(mux srpc.Mux, impl SRPCMqueueStoreServer) error

SRPCRegisterMqueueStore registers the implementation with the mux. Uses the default serviceID: mqueue.rpc.MqueueStore

func SRPCRegisterQueueOps 

func SRPCRegisterQueueOps(mux srpc.Mux, impl SRPCQueueOpsServer) error

SRPCRegisterQueueOps registers the implementation with the mux. Uses the default serviceID: mqueue.rpc.QueueOps

Types

type AckRequest 

type AckRequest struct {

	// Id is the message id to acknowledge.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

AckRequest is a request to ack a message.

func (*AckRequest) CloneMessageVT 

func (m *AckRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*AckRequest) CloneVT 

func (m *AckRequest) CloneVT() *AckRequest

func (*AckRequest) EqualMessageVT 

func (this *AckRequest) EqualMessageVT(thatMsg any) bool

func (*AckRequest) EqualVT 

func (this *AckRequest) EqualVT(that *AckRequest) bool

func (*AckRequest) GetId 

func (x *AckRequest) GetId() uint64

func (*AckRequest) MarshalJSON 

func (x *AckRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AckRequest to JSON.

func (*AckRequest) MarshalProtoJSON 

func (x *AckRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AckRequest message to JSON.

func (*AckRequest) MarshalProtoText 

func (x *AckRequest) MarshalProtoText() string

func (*AckRequest) MarshalToSizedBufferVT 

func (m *AckRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AckRequest) MarshalToVT 

func (m *AckRequest) MarshalToVT(dAtA []byte) (int, error)

func (*AckRequest) MarshalVT 

func (m *AckRequest) MarshalVT() (dAtA []byte, err error)

func (*AckRequest) ProtoMessage 

func (*AckRequest) ProtoMessage()

func (*AckRequest) Reset 

func (x *AckRequest) Reset()

func (*AckRequest) SizeVT 

func (m *AckRequest) SizeVT() (n int)

func (*AckRequest) String 

func (x *AckRequest) String() string

func (*AckRequest) UnmarshalJSON 

func (x *AckRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AckRequest from JSON.

func (*AckRequest) UnmarshalProtoJSON 

func (x *AckRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AckRequest message from JSON.

func (*AckRequest) UnmarshalVT 

func (m *AckRequest) UnmarshalVT(dAtA []byte) error

type AckResponse 

type AckResponse struct {

	// Error is any error acknowledging the message.
	// If empty, the operation succeeded.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

AckResponse is the response to acking a message.

func (*AckResponse) CloneMessageVT 

func (m *AckResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*AckResponse) CloneVT 

func (m *AckResponse) CloneVT() *AckResponse

func (*AckResponse) EqualMessageVT 

func (this *AckResponse) EqualMessageVT(thatMsg any) bool

func (*AckResponse) EqualVT 

func (this *AckResponse) EqualVT(that *AckResponse) bool

func (*AckResponse) GetError 

func (x *AckResponse) GetError() string

func (*AckResponse) MarshalJSON 

func (x *AckResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AckResponse to JSON.

func (*AckResponse) MarshalProtoJSON 

func (x *AckResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AckResponse message to JSON.

func (*AckResponse) MarshalProtoText 

func (x *AckResponse) MarshalProtoText() string

func (*AckResponse) MarshalToSizedBufferVT 

func (m *AckResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AckResponse) MarshalToVT 

func (m *AckResponse) MarshalToVT(dAtA []byte) (int, error)

func (*AckResponse) MarshalVT 

func (m *AckResponse) MarshalVT() (dAtA []byte, err error)

func (*AckResponse) ProtoMessage 

func (*AckResponse) ProtoMessage()

func (*AckResponse) Reset 

func (x *AckResponse) Reset()

func (*AckResponse) SizeVT 

func (m *AckResponse) SizeVT() (n int)

func (*AckResponse) String 

func (x *AckResponse) String() string

func (*AckResponse) UnmarshalJSON 

func (x *AckResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AckResponse from JSON.

func (*AckResponse) UnmarshalProtoJSON 

func (x *AckResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AckResponse message from JSON.

func (*AckResponse) UnmarshalVT 

func (m *AckResponse) UnmarshalVT(dAtA []byte) error

type DeleteQueueRequest 

type DeleteQueueRequest struct {
	// contains filtered or unexported fields
}

DeleteQueueRequest is a request to delete the queue.

func (*DeleteQueueRequest) CloneMessageVT 

func (m *DeleteQueueRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DeleteQueueRequest) CloneVT 

func (m *DeleteQueueRequest) CloneVT() *DeleteQueueRequest

func (*DeleteQueueRequest) EqualMessageVT 

func (this *DeleteQueueRequest) EqualMessageVT(thatMsg any) bool

func (*DeleteQueueRequest) EqualVT 

func (this *DeleteQueueRequest) EqualVT(that *DeleteQueueRequest) bool

func (*DeleteQueueRequest) MarshalJSON 

func (x *DeleteQueueRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteQueueRequest to JSON.

func (*DeleteQueueRequest) MarshalProtoJSON 

func (x *DeleteQueueRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteQueueRequest message to JSON.

func (*DeleteQueueRequest) MarshalProtoText 

func (x *DeleteQueueRequest) MarshalProtoText() string

func (*DeleteQueueRequest) MarshalToSizedBufferVT 

func (m *DeleteQueueRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteQueueRequest) MarshalToVT 

func (m *DeleteQueueRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteQueueRequest) MarshalVT 

func (m *DeleteQueueRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteQueueRequest) ProtoMessage 

func (*DeleteQueueRequest) ProtoMessage()

func (*DeleteQueueRequest) Reset 

func (x *DeleteQueueRequest) Reset()

func (*DeleteQueueRequest) SizeVT 

func (m *DeleteQueueRequest) SizeVT() (n int)

func (*DeleteQueueRequest) String 

func (x *DeleteQueueRequest) String() string

func (*DeleteQueueRequest) UnmarshalJSON 

func (x *DeleteQueueRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteQueueRequest from JSON.

func (*DeleteQueueRequest) UnmarshalProtoJSON 

func (x *DeleteQueueRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteQueueRequest message from JSON.

func (*DeleteQueueRequest) UnmarshalVT 

func (m *DeleteQueueRequest) UnmarshalVT(dAtA []byte) error

type DeleteQueueResponse 

type DeleteQueueResponse struct {

	// Error is any error deleting the queue.
	// If empty, the operation succeeded.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

DeleteQueueResponse is the response to deleting a message queue.

func (*DeleteQueueResponse) CloneMessageVT 

func (m *DeleteQueueResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DeleteQueueResponse) CloneVT 

func (m *DeleteQueueResponse) CloneVT() *DeleteQueueResponse

func (*DeleteQueueResponse) EqualMessageVT 

func (this *DeleteQueueResponse) EqualMessageVT(thatMsg any) bool

func (*DeleteQueueResponse) EqualVT 

func (this *DeleteQueueResponse) EqualVT(that *DeleteQueueResponse) bool

func (*DeleteQueueResponse) GetError 

func (x *DeleteQueueResponse) GetError() string

func (*DeleteQueueResponse) MarshalJSON 

func (x *DeleteQueueResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteQueueResponse to JSON.

func (*DeleteQueueResponse) MarshalProtoJSON 

func (x *DeleteQueueResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteQueueResponse message to JSON.

func (*DeleteQueueResponse) MarshalProtoText 

func (x *DeleteQueueResponse) MarshalProtoText() string

func (*DeleteQueueResponse) MarshalToSizedBufferVT 

func (m *DeleteQueueResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteQueueResponse) MarshalToVT 

func (m *DeleteQueueResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteQueueResponse) MarshalVT 

func (m *DeleteQueueResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteQueueResponse) ProtoMessage 

func (*DeleteQueueResponse) ProtoMessage()

func (*DeleteQueueResponse) Reset 

func (x *DeleteQueueResponse) Reset()

func (*DeleteQueueResponse) SizeVT 

func (m *DeleteQueueResponse) SizeVT() (n int)

func (*DeleteQueueResponse) String 

func (x *DeleteQueueResponse) String() string

func (*DeleteQueueResponse) UnmarshalJSON 

func (x *DeleteQueueResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteQueueResponse from JSON.

func (*DeleteQueueResponse) UnmarshalProtoJSON 

func (x *DeleteQueueResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteQueueResponse message from JSON.

func (*DeleteQueueResponse) UnmarshalVT 

func (m *DeleteQueueResponse) UnmarshalVT(dAtA []byte) error

type ListMqueuesRequest 

type ListMqueuesRequest struct {

	// Prefix is the message queue id prefix to filter by.
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// Filled indicates to filter the IDs to only queues with a pending message.
	//
	// Note: if !filled, implementation might not return queues that are empty.
	// If filled is set, implementation must only return filled queues.
	Filled bool `protobuf:"varint,2,opt,name=filled,proto3" json:"filled,omitempty"`
	// contains filtered or unexported fields
}

ListMqueuesRequest requests to list message queues with a id prefix.

func (*ListMqueuesRequest) CloneMessageVT 

func (m *ListMqueuesRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListMqueuesRequest) CloneVT 

func (m *ListMqueuesRequest) CloneVT() *ListMqueuesRequest

func (*ListMqueuesRequest) EqualMessageVT 

func (this *ListMqueuesRequest) EqualMessageVT(thatMsg any) bool

func (*ListMqueuesRequest) EqualVT 

func (this *ListMqueuesRequest) EqualVT(that *ListMqueuesRequest) bool

func (*ListMqueuesRequest) GetFilled 

func (x *ListMqueuesRequest) GetFilled() bool

func (*ListMqueuesRequest) GetPrefix 

func (x *ListMqueuesRequest) GetPrefix() []byte

func (*ListMqueuesRequest) MarshalJSON 

func (x *ListMqueuesRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListMqueuesRequest to JSON.

func (*ListMqueuesRequest) MarshalProtoJSON 

func (x *ListMqueuesRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListMqueuesRequest message to JSON.

func (*ListMqueuesRequest) MarshalProtoText 

func (x *ListMqueuesRequest) MarshalProtoText() string

func (*ListMqueuesRequest) MarshalToSizedBufferVT 

func (m *ListMqueuesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListMqueuesRequest) MarshalToVT 

func (m *ListMqueuesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListMqueuesRequest) MarshalVT 

func (m *ListMqueuesRequest) MarshalVT() (dAtA []byte, err error)

func (*ListMqueuesRequest) ProtoMessage 

func (*ListMqueuesRequest) ProtoMessage()

func (*ListMqueuesRequest) Reset 

func (x *ListMqueuesRequest) Reset()

func (*ListMqueuesRequest) SizeVT 

func (m *ListMqueuesRequest) SizeVT() (n int)

func (*ListMqueuesRequest) String 

func (x *ListMqueuesRequest) String() string

func (*ListMqueuesRequest) UnmarshalJSON 

func (x *ListMqueuesRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListMqueuesRequest from JSON.

func (*ListMqueuesRequest) UnmarshalProtoJSON 

func (x *ListMqueuesRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListMqueuesRequest message from JSON.

func (*ListMqueuesRequest) UnmarshalVT 

func (m *ListMqueuesRequest) UnmarshalVT(dAtA []byte) error

type ListMqueuesResponse 

type ListMqueuesResponse struct {

	// Error is any error listing message queues.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// MqueueIds is the list of message queue ids.
	MqueueIds [][]byte `protobuf:"bytes,2,rep,name=mqueue_ids,json=mqueueIds,proto3" json:"mqueueIds,omitempty"`
	// contains filtered or unexported fields
}

ListMqueuesResponse is the response to listing message queues.

func (*ListMqueuesResponse) CloneMessageVT 

func (m *ListMqueuesResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListMqueuesResponse) CloneVT 

func (m *ListMqueuesResponse) CloneVT() *ListMqueuesResponse

func (*ListMqueuesResponse) EqualMessageVT 

func (this *ListMqueuesResponse) EqualMessageVT(thatMsg any) bool

func (*ListMqueuesResponse) EqualVT 

func (this *ListMqueuesResponse) EqualVT(that *ListMqueuesResponse) bool

func (*ListMqueuesResponse) GetError 

func (x *ListMqueuesResponse) GetError() string

func (*ListMqueuesResponse) GetMqueueIds 

func (x *ListMqueuesResponse) GetMqueueIds() [][]byte

func (*ListMqueuesResponse) MarshalJSON 

func (x *ListMqueuesResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListMqueuesResponse to JSON.

func (*ListMqueuesResponse) MarshalProtoJSON 

func (x *ListMqueuesResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListMqueuesResponse message to JSON.

func (*ListMqueuesResponse) MarshalProtoText 

func (x *ListMqueuesResponse) MarshalProtoText() string

func (*ListMqueuesResponse) MarshalToSizedBufferVT 

func (m *ListMqueuesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListMqueuesResponse) MarshalToVT 

func (m *ListMqueuesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListMqueuesResponse) MarshalVT 

func (m *ListMqueuesResponse) MarshalVT() (dAtA []byte, err error)

func (*ListMqueuesResponse) ProtoMessage 

func (*ListMqueuesResponse) ProtoMessage()

func (*ListMqueuesResponse) Reset 

func (x *ListMqueuesResponse) Reset()

func (*ListMqueuesResponse) SizeVT 

func (m *ListMqueuesResponse) SizeVT() (n int)

func (*ListMqueuesResponse) String 

func (x *ListMqueuesResponse) String() string

func (*ListMqueuesResponse) UnmarshalJSON 

func (x *ListMqueuesResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListMqueuesResponse from JSON.

func (*ListMqueuesResponse) UnmarshalProtoJSON 

func (x *ListMqueuesResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListMqueuesResponse message from JSON.

func (*ListMqueuesResponse) UnmarshalVT 

func (m *ListMqueuesResponse) UnmarshalVT(dAtA []byte) error

type MqueueMsg 

type MqueueMsg struct {

	// Id contains the message id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Timestamp contains the message timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Data contains the message data.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

MqueueMsg is a message with associated metadata.

func ToMqueueMsg 

func ToMqueueMsg(msg mqueue.Message) *MqueueMsg

ToMqueueMsg converts a Message to a MqueueMsg.

func (*MqueueMsg) CloneMessageVT 

func (m *MqueueMsg) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*MqueueMsg) CloneVT 

func (m *MqueueMsg) CloneVT() *MqueueMsg

func (*MqueueMsg) EqualMessageVT 

func (this *MqueueMsg) EqualMessageVT(thatMsg any) bool

func (*MqueueMsg) EqualVT 

func (this *MqueueMsg) EqualVT(that *MqueueMsg) bool

func (*MqueueMsg) GetData 

func (x *MqueueMsg) GetData() []byte

func (*MqueueMsg) GetId 

func (x *MqueueMsg) GetId() uint64

func (*MqueueMsg) GetTimestamp 

func (x *MqueueMsg) GetTimestamp() *timestamppb.Timestamp

func (*MqueueMsg) MarshalJSON 

func (x *MqueueMsg) MarshalJSON() ([]byte, error)

MarshalJSON marshals the MqueueMsg to JSON.

func (*MqueueMsg) MarshalProtoJSON 

func (x *MqueueMsg) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the MqueueMsg message to JSON.

func (*MqueueMsg) MarshalProtoText 

func (x *MqueueMsg) MarshalProtoText() string

func (*MqueueMsg) MarshalToSizedBufferVT 

func (m *MqueueMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MqueueMsg) MarshalToVT 

func (m *MqueueMsg) MarshalToVT(dAtA []byte) (int, error)

func (*MqueueMsg) MarshalVT 

func (m *MqueueMsg) MarshalVT() (dAtA []byte, err error)

func (*MqueueMsg) ProtoMessage 

func (*MqueueMsg) ProtoMessage()

func (*MqueueMsg) Reset 

func (x *MqueueMsg) Reset()

func (*MqueueMsg) SizeVT 

func (m *MqueueMsg) SizeVT() (n int)

func (*MqueueMsg) String 

func (x *MqueueMsg) String() string

func (*MqueueMsg) UnmarshalJSON 

func (x *MqueueMsg) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the MqueueMsg from JSON.

func (*MqueueMsg) UnmarshalProtoJSON 

func (x *MqueueMsg) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the MqueueMsg message from JSON.

func (*MqueueMsg) UnmarshalVT 

func (m *MqueueMsg) UnmarshalVT(dAtA []byte) error

type Msg 

type Msg struct {
	*MqueueMsg
}

Msg wraps a MqueueMsg into a mqueue.Message.

func NewMsg 

func NewMsg(msg *MqueueMsg) *Msg

NewMsg wraps a Msg into a mqueue.Message.

func (*Msg) GetTimestamp 

func (m *Msg) GetTimestamp() time.Time

GetTimestamp returns the message timestamp.

type PeekRequest 

type PeekRequest struct {
	// contains filtered or unexported fields
}

PeekRequest is a request to peek the next message.

func (*PeekRequest) CloneMessageVT 

func (m *PeekRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*PeekRequest) CloneVT 

func (m *PeekRequest) CloneVT() *PeekRequest

func (*PeekRequest) EqualMessageVT 

func (this *PeekRequest) EqualMessageVT(thatMsg any) bool

func (*PeekRequest) EqualVT 

func (this *PeekRequest) EqualVT(that *PeekRequest) bool

func (*PeekRequest) MarshalJSON 

func (x *PeekRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the PeekRequest to JSON.

func (*PeekRequest) MarshalProtoJSON 

func (x *PeekRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the PeekRequest message to JSON.

func (*PeekRequest) MarshalProtoText 

func (x *PeekRequest) MarshalProtoText() string

func (*PeekRequest) MarshalToSizedBufferVT 

func (m *PeekRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PeekRequest) MarshalToVT 

func (m *PeekRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PeekRequest) MarshalVT 

func (m *PeekRequest) MarshalVT() (dAtA []byte, err error)

func (*PeekRequest) ProtoMessage 

func (*PeekRequest) ProtoMessage()

func (*PeekRequest) Reset 

func (x *PeekRequest) Reset()

func (*PeekRequest) SizeVT 

func (m *PeekRequest) SizeVT() (n int)

func (*PeekRequest) String 

func (x *PeekRequest) String() string

func (*PeekRequest) UnmarshalJSON 

func (x *PeekRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the PeekRequest from JSON.

func (*PeekRequest) UnmarshalProtoJSON 

func (x *PeekRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the PeekRequest message from JSON.

func (*PeekRequest) UnmarshalVT 

func (m *PeekRequest) UnmarshalVT(dAtA []byte) error

type PeekResponse 

type PeekResponse struct {

	// Error is any error accessing the key.
	// Will be empty if the key was unset.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Found indicates there was a message.
	Found bool `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	// Msg contains the message, if found=true.
	Msg *MqueueMsg `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

PeekResponse responds to a request to peek the next message.

func (*PeekResponse) CloneMessageVT 

func (m *PeekResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*PeekResponse) CloneVT 

func (m *PeekResponse) CloneVT() *PeekResponse

func (*PeekResponse) EqualMessageVT 

func (this *PeekResponse) EqualMessageVT(thatMsg any) bool

func (*PeekResponse) EqualVT 

func (this *PeekResponse) EqualVT(that *PeekResponse) bool

func (*PeekResponse) GetError 

func (x *PeekResponse) GetError() string

func (*PeekResponse) GetFound 

func (x *PeekResponse) GetFound() bool

func (*PeekResponse) GetMsg 

func (x *PeekResponse) GetMsg() *MqueueMsg

func (*PeekResponse) MarshalJSON 

func (x *PeekResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the PeekResponse to JSON.

func (*PeekResponse) MarshalProtoJSON 

func (x *PeekResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the PeekResponse message to JSON.

func (*PeekResponse) MarshalProtoText 

func (x *PeekResponse) MarshalProtoText() string

func (*PeekResponse) MarshalToSizedBufferVT 

func (m *PeekResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PeekResponse) MarshalToVT 

func (m *PeekResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PeekResponse) MarshalVT 

func (m *PeekResponse) MarshalVT() (dAtA []byte, err error)

func (*PeekResponse) ProtoMessage 

func (*PeekResponse) ProtoMessage()

func (*PeekResponse) Reset 

func (x *PeekResponse) Reset()

func (*PeekResponse) SizeVT 

func (m *PeekResponse) SizeVT() (n int)

func (*PeekResponse) String 

func (x *PeekResponse) String() string

func (*PeekResponse) UnmarshalJSON 

func (x *PeekResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the PeekResponse from JSON.

func (*PeekResponse) UnmarshalProtoJSON 

func (x *PeekResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the PeekResponse message from JSON.

func (*PeekResponse) UnmarshalVT 

func (m *PeekResponse) UnmarshalVT(dAtA []byte) error

type PushRequest 

type PushRequest struct {

	// Data is the contents of the message to push.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

PushRequest is a request to push a message to the queue.

func (*PushRequest) CloneMessageVT 

func (m *PushRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*PushRequest) CloneVT 

func (m *PushRequest) CloneVT() *PushRequest

func (*PushRequest) EqualMessageVT 

func (this *PushRequest) EqualMessageVT(thatMsg any) bool

func (*PushRequest) EqualVT 

func (this *PushRequest) EqualVT(that *PushRequest) bool

func (*PushRequest) GetData 

func (x *PushRequest) GetData() []byte

func (*PushRequest) MarshalJSON 

func (x *PushRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the PushRequest to JSON.

func (*PushRequest) MarshalProtoJSON 

func (x *PushRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the PushRequest message to JSON.

func (*PushRequest) MarshalProtoText 

func (x *PushRequest) MarshalProtoText() string

func (*PushRequest) MarshalToSizedBufferVT 

func (m *PushRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PushRequest) MarshalToVT 

func (m *PushRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PushRequest) MarshalVT 

func (m *PushRequest) MarshalVT() (dAtA []byte, err error)

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset 

func (x *PushRequest) Reset()

func (*PushRequest) SizeVT 

func (m *PushRequest) SizeVT() (n int)

func (*PushRequest) String 

func (x *PushRequest) String() string

func (*PushRequest) UnmarshalJSON 

func (x *PushRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the PushRequest from JSON.

func (*PushRequest) UnmarshalProtoJSON 

func (x *PushRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the PushRequest message from JSON.

func (*PushRequest) UnmarshalVT 

func (m *PushRequest) UnmarshalVT(dAtA []byte) error

type PushResponse 

type PushResponse struct {

	// Error is any error pushing the message.
	// If empty, the operation succeeded.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Msg contains the pushed message, if error="".
	// note: the data field will be empty.
	Msg *MqueueMsg `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

PushResponse is the response to pushing a message.

func (*PushResponse) CloneMessageVT 

func (m *PushResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*PushResponse) CloneVT 

func (m *PushResponse) CloneVT() *PushResponse

func (*PushResponse) EqualMessageVT 

func (this *PushResponse) EqualMessageVT(thatMsg any) bool

func (*PushResponse) EqualVT 

func (this *PushResponse) EqualVT(that *PushResponse) bool

func (*PushResponse) GetError 

func (x *PushResponse) GetError() string

func (*PushResponse) GetMsg 

func (x *PushResponse) GetMsg() *MqueueMsg

func (*PushResponse) MarshalJSON 

func (x *PushResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the PushResponse to JSON.

func (*PushResponse) MarshalProtoJSON 

func (x *PushResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the PushResponse message to JSON.

func (*PushResponse) MarshalProtoText 

func (x *PushResponse) MarshalProtoText() string

func (*PushResponse) MarshalToSizedBufferVT 

func (m *PushResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PushResponse) MarshalToVT 

func (m *PushResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PushResponse) MarshalVT 

func (m *PushResponse) MarshalVT() (dAtA []byte, err error)

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset 

func (x *PushResponse) Reset()

func (*PushResponse) SizeVT 

func (m *PushResponse) SizeVT() (n int)

func (*PushResponse) String 

func (x *PushResponse) String() string

func (*PushResponse) UnmarshalJSON 

func (x *PushResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the PushResponse from JSON.

func (*PushResponse) UnmarshalProtoJSON 

func (x *PushResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the PushResponse message from JSON.

func (*PushResponse) UnmarshalVT 

func (m *PushResponse) UnmarshalVT(dAtA []byte) error

type RmMqueueRequest 

type RmMqueueRequest struct {

	// MqueueId is the message queue to remove.
	MqueueId []byte `protobuf:"bytes,1,opt,name=mqueue_id,json=mqueueId,proto3" json:"mqueueId,omitempty"`
	// contains filtered or unexported fields
}

RmMqueueRequest requests to remove a message queue and its contents.

func (*RmMqueueRequest) CloneMessageVT 

func (m *RmMqueueRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RmMqueueRequest) CloneVT 

func (m *RmMqueueRequest) CloneVT() *RmMqueueRequest

func (*RmMqueueRequest) EqualMessageVT 

func (this *RmMqueueRequest) EqualMessageVT(thatMsg any) bool

func (*RmMqueueRequest) EqualVT 

func (this *RmMqueueRequest) EqualVT(that *RmMqueueRequest) bool

func (*RmMqueueRequest) GetMqueueId 

func (x *RmMqueueRequest) GetMqueueId() []byte

func (*RmMqueueRequest) MarshalJSON 

func (x *RmMqueueRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RmMqueueRequest to JSON.

func (*RmMqueueRequest) MarshalProtoJSON 

func (x *RmMqueueRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RmMqueueRequest message to JSON.

func (*RmMqueueRequest) MarshalProtoText 

func (x *RmMqueueRequest) MarshalProtoText() string

func (*RmMqueueRequest) MarshalToSizedBufferVT 

func (m *RmMqueueRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RmMqueueRequest) MarshalToVT 

func (m *RmMqueueRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RmMqueueRequest) MarshalVT 

func (m *RmMqueueRequest) MarshalVT() (dAtA []byte, err error)

func (*RmMqueueRequest) ProtoMessage 

func (*RmMqueueRequest) ProtoMessage()

func (*RmMqueueRequest) Reset 

func (x *RmMqueueRequest) Reset()

func (*RmMqueueRequest) SizeVT 

func (m *RmMqueueRequest) SizeVT() (n int)

func (*RmMqueueRequest) String 

func (x *RmMqueueRequest) String() string

func (*RmMqueueRequest) UnmarshalJSON 

func (x *RmMqueueRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RmMqueueRequest from JSON.

func (*RmMqueueRequest) UnmarshalProtoJSON 

func (x *RmMqueueRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RmMqueueRequest message from JSON.

func (*RmMqueueRequest) UnmarshalVT 

func (m *RmMqueueRequest) UnmarshalVT(dAtA []byte) error

type RmMqueueResponse 

type RmMqueueResponse struct {

	// Error is any error removing the message queue.
	// Will be empty if the queue did not exist.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

RmMqueueResponse is the response to removing a message queue.

func (*RmMqueueResponse) CloneMessageVT 

func (m *RmMqueueResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RmMqueueResponse) CloneVT 

func (m *RmMqueueResponse) CloneVT() *RmMqueueResponse

func (*RmMqueueResponse) EqualMessageVT 

func (this *RmMqueueResponse) EqualMessageVT(thatMsg any) bool

func (*RmMqueueResponse) EqualVT 

func (this *RmMqueueResponse) EqualVT(that *RmMqueueResponse) bool

func (*RmMqueueResponse) GetError 

func (x *RmMqueueResponse) GetError() string

func (*RmMqueueResponse) MarshalJSON 

func (x *RmMqueueResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RmMqueueResponse to JSON.

func (*RmMqueueResponse) MarshalProtoJSON 

func (x *RmMqueueResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RmMqueueResponse message to JSON.

func (*RmMqueueResponse) MarshalProtoText 

func (x *RmMqueueResponse) MarshalProtoText() string

func (*RmMqueueResponse) MarshalToSizedBufferVT 

func (m *RmMqueueResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RmMqueueResponse) MarshalToVT 

func (m *RmMqueueResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RmMqueueResponse) MarshalVT 

func (m *RmMqueueResponse) MarshalVT() (dAtA []byte, err error)

func (*RmMqueueResponse) ProtoMessage 

func (*RmMqueueResponse) ProtoMessage()

func (*RmMqueueResponse) Reset 

func (x *RmMqueueResponse) Reset()

func (*RmMqueueResponse) SizeVT 

func (m *RmMqueueResponse) SizeVT() (n int)

func (*RmMqueueResponse) String 

func (x *RmMqueueResponse) String() string

func (*RmMqueueResponse) UnmarshalJSON 

func (x *RmMqueueResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RmMqueueResponse from JSON.

func (*RmMqueueResponse) UnmarshalProtoJSON 

func (x *RmMqueueResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RmMqueueResponse message from JSON.

func (*RmMqueueResponse) UnmarshalVT 

func (m *RmMqueueResponse) UnmarshalVT(dAtA []byte) error

type SRPCMqueueStoreClient 

type SRPCMqueueStoreClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// MqueueRpc is a rpc request for a MessageQueue by ID.
	// Exposes service: rpc.mqueue.QueueOps
	// Component ID: message queue id.
	MqueueRpc(ctx context.Context) (SRPCMqueueStore_MqueueRpcClient, error)
	// ListMqueues lists message queues with the given ID prefix.
	//
	// Note: if !filled, implementation might not return queues that are empty.
	// If filled is set, implementation must only return filled queues.
	ListMqueues(ctx context.Context, in *ListMqueuesRequest) (*ListMqueuesResponse, error)
	// RmMqueue deletes the message queue and all contents by ID.
	RmMqueue(ctx context.Context, in *RmMqueueRequest) (*RmMqueueResponse, error)
}

func NewSRPCMqueueStoreClient 

func NewSRPCMqueueStoreClient(cc srpc.Client) SRPCMqueueStoreClient

func NewSRPCMqueueStoreClientWithServiceID 

func NewSRPCMqueueStoreClientWithServiceID(cc srpc.Client, serviceID string) SRPCMqueueStoreClient

type SRPCMqueueStoreHandler 

type SRPCMqueueStoreHandler struct {
	// contains filtered or unexported fields
}

func (SRPCMqueueStoreHandler) GetMethodIDs 

func (SRPCMqueueStoreHandler) GetMethodIDs() []string

func (*SRPCMqueueStoreHandler) GetServiceID 

func (d *SRPCMqueueStoreHandler) GetServiceID() string

func (*SRPCMqueueStoreHandler) InvokeMethod 

func (d *SRPCMqueueStoreHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCMqueueStoreHandler) InvokeMethod_ListMqueues 

func (SRPCMqueueStoreHandler) InvokeMethod_ListMqueues(impl SRPCMqueueStoreServer, strm srpc.Stream) error

func (SRPCMqueueStoreHandler) InvokeMethod_MqueueRpc 

func (SRPCMqueueStoreHandler) InvokeMethod_MqueueRpc(impl SRPCMqueueStoreServer, strm srpc.Stream) error

func (SRPCMqueueStoreHandler) InvokeMethod_RmMqueue 

func (SRPCMqueueStoreHandler) InvokeMethod_RmMqueue(impl SRPCMqueueStoreServer, strm srpc.Stream) error

type SRPCMqueueStoreServer 

type SRPCMqueueStoreServer interface {
	// MqueueRpc is a rpc request for a MessageQueue by ID.
	// Exposes service: rpc.mqueue.QueueOps
	// Component ID: message queue id.
	MqueueRpc(SRPCMqueueStore_MqueueRpcStream) error
	// ListMqueues lists message queues with the given ID prefix.
	//
	// Note: if !filled, implementation might not return queues that are empty.
	// If filled is set, implementation must only return filled queues.
	ListMqueues(context.Context, *ListMqueuesRequest) (*ListMqueuesResponse, error)
	// RmMqueue deletes the message queue and all contents by ID.
	RmMqueue(context.Context, *RmMqueueRequest) (*RmMqueueResponse, error)
}

type SRPCMqueueStore_ListMqueuesStream 

type SRPCMqueueStore_ListMqueuesStream interface {
	srpc.Stream
}

type SRPCMqueueStore_MqueueRpcClient 

type SRPCMqueueStore_MqueueRpcClient interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCMqueueStore_MqueueRpcStream 

type SRPCMqueueStore_MqueueRpcStream interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	SendAndClose(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCMqueueStore_RmMqueueStream 

type SRPCMqueueStore_RmMqueueStream interface {
	srpc.Stream
}

type SRPCQueueOpsClient 

type SRPCQueueOpsClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// Peek returns the next message, if any.
	Peek(ctx context.Context, in *PeekRequest) (*PeekResponse, error)
	// Ack acknowledges the message with the given ID.
	// If the latest message is not the one with the ID, does nothing.
	Ack(ctx context.Context, in *AckRequest) (*AckResponse, error)
	// Push pushes a message to the queue.
	Push(ctx context.Context, in *PushRequest) (*PushResponse, error)
	// Wait waits for the next message, or call cancellation.
	Wait(ctx context.Context, in *WaitRequest) (*WaitResponse, error)
	// DeleteQueue deletes the messages and metadata for the queue.
	DeleteQueue(ctx context.Context, in *DeleteQueueRequest) (*DeleteQueueResponse, error)
}

func NewSRPCQueueOpsClient 

func NewSRPCQueueOpsClient(cc srpc.Client) SRPCQueueOpsClient

func NewSRPCQueueOpsClientWithServiceID 

func NewSRPCQueueOpsClientWithServiceID(cc srpc.Client, serviceID string) SRPCQueueOpsClient

type SRPCQueueOpsHandler 

type SRPCQueueOpsHandler struct {
	// contains filtered or unexported fields
}

func (SRPCQueueOpsHandler) GetMethodIDs 

func (SRPCQueueOpsHandler) GetMethodIDs() []string

func (*SRPCQueueOpsHandler) GetServiceID 

func (d *SRPCQueueOpsHandler) GetServiceID() string

func (*SRPCQueueOpsHandler) InvokeMethod 

func (d *SRPCQueueOpsHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCQueueOpsHandler) InvokeMethod_Ack 

func (SRPCQueueOpsHandler) InvokeMethod_Ack(impl SRPCQueueOpsServer, strm srpc.Stream) error

func (SRPCQueueOpsHandler) InvokeMethod_DeleteQueue 

func (SRPCQueueOpsHandler) InvokeMethod_DeleteQueue(impl SRPCQueueOpsServer, strm srpc.Stream) error

func (SRPCQueueOpsHandler) InvokeMethod_Peek 

func (SRPCQueueOpsHandler) InvokeMethod_Peek(impl SRPCQueueOpsServer, strm srpc.Stream) error

func (SRPCQueueOpsHandler) InvokeMethod_Push 

func (SRPCQueueOpsHandler) InvokeMethod_Push(impl SRPCQueueOpsServer, strm srpc.Stream) error

func (SRPCQueueOpsHandler) InvokeMethod_Wait 

func (SRPCQueueOpsHandler) InvokeMethod_Wait(impl SRPCQueueOpsServer, strm srpc.Stream) error

type SRPCQueueOpsServer 

type SRPCQueueOpsServer interface {
	// Peek returns the next message, if any.
	Peek(context.Context, *PeekRequest) (*PeekResponse, error)
	// Ack acknowledges the message with the given ID.
	// If the latest message is not the one with the ID, does nothing.
	Ack(context.Context, *AckRequest) (*AckResponse, error)
	// Push pushes a message to the queue.
	Push(context.Context, *PushRequest) (*PushResponse, error)
	// Wait waits for the next message, or call cancellation.
	Wait(context.Context, *WaitRequest) (*WaitResponse, error)
	// DeleteQueue deletes the messages and metadata for the queue.
	DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueResponse, error)
}

type SRPCQueueOps_AckStream 

type SRPCQueueOps_AckStream interface {
	srpc.Stream
}

type SRPCQueueOps_DeleteQueueStream 

type SRPCQueueOps_DeleteQueueStream interface {
	srpc.Stream
}

type SRPCQueueOps_PeekStream 

type SRPCQueueOps_PeekStream interface {
	srpc.Stream
}

type SRPCQueueOps_PushStream 

type SRPCQueueOps_PushStream interface {
	srpc.Stream
}

type SRPCQueueOps_WaitStream 

type SRPCQueueOps_WaitStream interface {
	srpc.Stream
}

type WaitRequest 

type WaitRequest struct {

	// Ack indicates to ack the message when returning it.
	// Note: message may be dropped in transit.
	// You may want to ack with a second call instead.
	Ack bool `protobuf:"varint,1,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

WaitRequest is a request to wait for the next message.

func (*WaitRequest) CloneMessageVT 

func (m *WaitRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WaitRequest) CloneVT 

func (m *WaitRequest) CloneVT() *WaitRequest

func (*WaitRequest) EqualMessageVT 

func (this *WaitRequest) EqualMessageVT(thatMsg any) bool

func (*WaitRequest) EqualVT 

func (this *WaitRequest) EqualVT(that *WaitRequest) bool

func (*WaitRequest) GetAck 

func (x *WaitRequest) GetAck() bool

func (*WaitRequest) MarshalJSON 

func (x *WaitRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WaitRequest to JSON.

func (*WaitRequest) MarshalProtoJSON 

func (x *WaitRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WaitRequest message to JSON.

func (*WaitRequest) MarshalProtoText 

func (x *WaitRequest) MarshalProtoText() string

func (*WaitRequest) MarshalToSizedBufferVT 

func (m *WaitRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitRequest) MarshalToVT 

func (m *WaitRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WaitRequest) MarshalVT 

func (m *WaitRequest) MarshalVT() (dAtA []byte, err error)

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) Reset 

func (x *WaitRequest) Reset()

func (*WaitRequest) SizeVT 

func (m *WaitRequest) SizeVT() (n int)

func (*WaitRequest) String 

func (x *WaitRequest) String() string

func (*WaitRequest) UnmarshalJSON 

func (x *WaitRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WaitRequest from JSON.

func (*WaitRequest) UnmarshalProtoJSON 

func (x *WaitRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WaitRequest message from JSON.

func (*WaitRequest) UnmarshalVT 

func (m *WaitRequest) UnmarshalVT(dAtA []byte) error

type WaitResponse 

type WaitResponse struct {

	// Msg contains the message.
	Msg *MqueueMsg `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

WaitResponse is the response to waiting for a message.

func (*WaitResponse) CloneMessageVT 

func (m *WaitResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WaitResponse) CloneVT 

func (m *WaitResponse) CloneVT() *WaitResponse

func (*WaitResponse) EqualMessageVT 

func (this *WaitResponse) EqualMessageVT(thatMsg any) bool

func (*WaitResponse) EqualVT 

func (this *WaitResponse) EqualVT(that *WaitResponse) bool

func (*WaitResponse) GetMsg 

func (x *WaitResponse) GetMsg() *MqueueMsg

func (*WaitResponse) MarshalJSON 

func (x *WaitResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WaitResponse to JSON.

func (*WaitResponse) MarshalProtoJSON 

func (x *WaitResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WaitResponse message to JSON.

func (*WaitResponse) MarshalProtoText 

func (x *WaitResponse) MarshalProtoText() string

func (*WaitResponse) MarshalToSizedBufferVT 

func (m *WaitResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WaitResponse) MarshalToVT 

func (m *WaitResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WaitResponse) MarshalVT 

func (m *WaitResponse) MarshalVT() (dAtA []byte, err error)

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) Reset 

func (x *WaitResponse) Reset()

func (*WaitResponse) SizeVT 

func (m *WaitResponse) SizeVT() (n int)

func (*WaitResponse) String 

func (x *WaitResponse) String() string

func (*WaitResponse) UnmarshalJSON 

func (x *WaitResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WaitResponse from JSON.

func (*WaitResponse) UnmarshalProtoJSON 

func (x *WaitResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WaitResponse message from JSON.

func (*WaitResponse) UnmarshalVT 

func (m *WaitResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.