Documentation ¶
Index ¶
- Variables
- type GetDeadMessageRequest
- func (*GetDeadMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeadMessageRequest) GetMessageId() string
- func (*GetDeadMessageRequest) ProtoMessage()
- func (x *GetDeadMessageRequest) ProtoReflect() protoreflect.Message
- func (x *GetDeadMessageRequest) Reset()
- func (x *GetDeadMessageRequest) String() string
- type GetDeadMessageResponse
- func (*GetDeadMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeadMessageResponse) GetEvents() []*v1.DeadMessageEvent
- func (x *GetDeadMessageResponse) GetMessage() *v1.DeadMessageState
- func (*GetDeadMessageResponse) ProtoMessage()
- func (x *GetDeadMessageResponse) ProtoReflect() protoreflect.Message
- func (x *GetDeadMessageResponse) Reset()
- func (x *GetDeadMessageResponse) String() string
- type ListDeadMessageEventsRequest
- func (*ListDeadMessageEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDeadMessageEventsRequest) GetMessageId() string
- func (x *ListDeadMessageEventsRequest) GetPage() *v11.PageRequest
- func (x *ListDeadMessageEventsRequest) GetQuery() *v11.QueryRequest
- func (*ListDeadMessageEventsRequest) ProtoMessage()
- func (x *ListDeadMessageEventsRequest) ProtoReflect() protoreflect.Message
- func (x *ListDeadMessageEventsRequest) Reset()
- func (x *ListDeadMessageEventsRequest) String() string
- type ListDeadMessageEventsResponse
- func (*ListDeadMessageEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDeadMessageEventsResponse) GetEvents() []*v1.DeadMessageEvent
- func (x *ListDeadMessageEventsResponse) GetPage() *v11.PageResponse
- func (*ListDeadMessageEventsResponse) ProtoMessage()
- func (x *ListDeadMessageEventsResponse) ProtoReflect() protoreflect.Message
- func (x *ListDeadMessageEventsResponse) Reset()
- func (x *ListDeadMessageEventsResponse) String() string
- type ListDeadMessagesRequest
- func (*ListDeadMessagesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDeadMessagesRequest) GetPage() *v11.PageRequest
- func (x *ListDeadMessagesRequest) GetQuery() *v11.QueryRequest
- func (*ListDeadMessagesRequest) ProtoMessage()
- func (x *ListDeadMessagesRequest) ProtoReflect() protoreflect.Message
- func (x *ListDeadMessagesRequest) Reset()
- func (x *ListDeadMessagesRequest) String() string
- type ListDeadMessagesResponse
- func (*ListDeadMessagesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDeadMessagesResponse) GetMessages() []*v1.DeadMessageState
- func (x *ListDeadMessagesResponse) GetPage() *v11.PageResponse
- func (*ListDeadMessagesResponse) ProtoMessage()
- func (x *ListDeadMessagesResponse) ProtoReflect() protoreflect.Message
- func (x *ListDeadMessagesResponse) Reset()
- func (x *ListDeadMessagesResponse) String() string
- type RejectDeadMessageRequest
- func (*RejectDeadMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RejectDeadMessageRequest) GetMessageId() string
- func (x *RejectDeadMessageRequest) GetReason() string
- func (*RejectDeadMessageRequest) ProtoMessage()
- func (x *RejectDeadMessageRequest) ProtoReflect() protoreflect.Message
- func (x *RejectDeadMessageRequest) Reset()
- func (x *RejectDeadMessageRequest) String() string
- type RejectDeadMessageResponse
- func (*RejectDeadMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RejectDeadMessageResponse) GetMessage() *v1.DeadMessageState
- func (*RejectDeadMessageResponse) ProtoMessage()
- func (x *RejectDeadMessageResponse) ProtoReflect() protoreflect.Message
- func (x *RejectDeadMessageResponse) Reset()
- func (x *RejectDeadMessageResponse) String() string
- type ReplayDeadMessageRequest
- func (*ReplayDeadMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReplayDeadMessageRequest) GetMessageId() string
- func (*ReplayDeadMessageRequest) ProtoMessage()
- func (x *ReplayDeadMessageRequest) ProtoReflect() protoreflect.Message
- func (x *ReplayDeadMessageRequest) Reset()
- func (x *ReplayDeadMessageRequest) String() string
- type ReplayDeadMessageResponse
- func (*ReplayDeadMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReplayDeadMessageResponse) GetMessage() *v1.DeadMessageState
- func (*ReplayDeadMessageResponse) ProtoMessage()
- func (x *ReplayDeadMessageResponse) ProtoReflect() protoreflect.Message
- func (x *ReplayDeadMessageResponse) Reset()
- func (x *ReplayDeadMessageResponse) String() string
- type UpdateDeadMessageRequest
- func (*UpdateDeadMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeadMessageRequest) GetMessage() *v1.DeadMessageSpec
- func (x *UpdateDeadMessageRequest) GetMessageId() string
- func (x *UpdateDeadMessageRequest) GetReplacesVersionId() string
- func (x *UpdateDeadMessageRequest) GetVersionId() string
- func (*UpdateDeadMessageRequest) ProtoMessage()
- func (x *UpdateDeadMessageRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDeadMessageRequest) Reset()
- func (x *UpdateDeadMessageRequest) String() string
- type UpdateDeadMessageResponse
- func (*UpdateDeadMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeadMessageResponse) GetMessage() *v1.DeadMessageState
- func (*UpdateDeadMessageResponse) ProtoMessage()
- func (x *UpdateDeadMessageResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDeadMessageResponse) Reset()
- func (x *UpdateDeadMessageResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_o5_dante_v1_service_dead_message_command_proto protoreflect.FileDescriptor
var File_o5_dante_v1_service_dead_message_query_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type GetDeadMessageRequest ¶
type GetDeadMessageRequest struct { // when not set, returns the next unhandled message MessageId *string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3,oneof" json:"message_id,omitempty"` // contains filtered or unexported fields }
func (*GetDeadMessageRequest) Descriptor
deprecated
func (*GetDeadMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDeadMessageRequest.ProtoReflect.Descriptor instead.
func (*GetDeadMessageRequest) GetMessageId ¶
func (x *GetDeadMessageRequest) GetMessageId() string
func (*GetDeadMessageRequest) ProtoMessage ¶
func (*GetDeadMessageRequest) ProtoMessage()
func (*GetDeadMessageRequest) ProtoReflect ¶
func (x *GetDeadMessageRequest) ProtoReflect() protoreflect.Message
func (*GetDeadMessageRequest) Reset ¶
func (x *GetDeadMessageRequest) Reset()
func (*GetDeadMessageRequest) String ¶
func (x *GetDeadMessageRequest) String() string
type GetDeadMessageResponse ¶
type GetDeadMessageResponse struct { Message *v1.DeadMessageState `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Events []*v1.DeadMessageEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*GetDeadMessageResponse) Descriptor
deprecated
func (*GetDeadMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDeadMessageResponse.ProtoReflect.Descriptor instead.
func (*GetDeadMessageResponse) GetEvents ¶
func (x *GetDeadMessageResponse) GetEvents() []*v1.DeadMessageEvent
func (*GetDeadMessageResponse) GetMessage ¶
func (x *GetDeadMessageResponse) GetMessage() *v1.DeadMessageState
func (*GetDeadMessageResponse) ProtoMessage ¶
func (*GetDeadMessageResponse) ProtoMessage()
func (*GetDeadMessageResponse) ProtoReflect ¶
func (x *GetDeadMessageResponse) ProtoReflect() protoreflect.Message
func (*GetDeadMessageResponse) Reset ¶
func (x *GetDeadMessageResponse) Reset()
func (*GetDeadMessageResponse) String ¶
func (x *GetDeadMessageResponse) String() string
type ListDeadMessageEventsRequest ¶
type ListDeadMessageEventsRequest struct { MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` Page *v11.PageRequest `protobuf:"bytes,100,opt,name=page,proto3" json:"page,omitempty"` Query *v11.QueryRequest `protobuf:"bytes,101,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*ListDeadMessageEventsRequest) Descriptor
deprecated
func (*ListDeadMessageEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDeadMessageEventsRequest.ProtoReflect.Descriptor instead.
func (*ListDeadMessageEventsRequest) GetMessageId ¶
func (x *ListDeadMessageEventsRequest) GetMessageId() string
func (*ListDeadMessageEventsRequest) GetPage ¶
func (x *ListDeadMessageEventsRequest) GetPage() *v11.PageRequest
func (*ListDeadMessageEventsRequest) GetQuery ¶
func (x *ListDeadMessageEventsRequest) GetQuery() *v11.QueryRequest
func (*ListDeadMessageEventsRequest) ProtoMessage ¶
func (*ListDeadMessageEventsRequest) ProtoMessage()
func (*ListDeadMessageEventsRequest) ProtoReflect ¶
func (x *ListDeadMessageEventsRequest) ProtoReflect() protoreflect.Message
func (*ListDeadMessageEventsRequest) Reset ¶
func (x *ListDeadMessageEventsRequest) Reset()
func (*ListDeadMessageEventsRequest) String ¶
func (x *ListDeadMessageEventsRequest) String() string
type ListDeadMessageEventsResponse ¶
type ListDeadMessageEventsResponse struct { Events []*v1.DeadMessageEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` Page *v11.PageResponse `protobuf:"bytes,100,opt,name=page,proto3" json:"page,omitempty"` // contains filtered or unexported fields }
func (*ListDeadMessageEventsResponse) Descriptor
deprecated
func (*ListDeadMessageEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDeadMessageEventsResponse.ProtoReflect.Descriptor instead.
func (*ListDeadMessageEventsResponse) GetEvents ¶
func (x *ListDeadMessageEventsResponse) GetEvents() []*v1.DeadMessageEvent
func (*ListDeadMessageEventsResponse) GetPage ¶
func (x *ListDeadMessageEventsResponse) GetPage() *v11.PageResponse
func (*ListDeadMessageEventsResponse) ProtoMessage ¶
func (*ListDeadMessageEventsResponse) ProtoMessage()
func (*ListDeadMessageEventsResponse) ProtoReflect ¶
func (x *ListDeadMessageEventsResponse) ProtoReflect() protoreflect.Message
func (*ListDeadMessageEventsResponse) Reset ¶
func (x *ListDeadMessageEventsResponse) Reset()
func (*ListDeadMessageEventsResponse) String ¶
func (x *ListDeadMessageEventsResponse) String() string
type ListDeadMessagesRequest ¶
type ListDeadMessagesRequest struct { Page *v11.PageRequest `protobuf:"bytes,100,opt,name=page,proto3" json:"page,omitempty"` Query *v11.QueryRequest `protobuf:"bytes,101,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*ListDeadMessagesRequest) Descriptor
deprecated
func (*ListDeadMessagesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDeadMessagesRequest.ProtoReflect.Descriptor instead.
func (*ListDeadMessagesRequest) GetPage ¶
func (x *ListDeadMessagesRequest) GetPage() *v11.PageRequest
func (*ListDeadMessagesRequest) GetQuery ¶
func (x *ListDeadMessagesRequest) GetQuery() *v11.QueryRequest
func (*ListDeadMessagesRequest) ProtoMessage ¶
func (*ListDeadMessagesRequest) ProtoMessage()
func (*ListDeadMessagesRequest) ProtoReflect ¶
func (x *ListDeadMessagesRequest) ProtoReflect() protoreflect.Message
func (*ListDeadMessagesRequest) Reset ¶
func (x *ListDeadMessagesRequest) Reset()
func (*ListDeadMessagesRequest) String ¶
func (x *ListDeadMessagesRequest) String() string
type ListDeadMessagesResponse ¶
type ListDeadMessagesResponse struct { Messages []*v1.DeadMessageState `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"` Page *v11.PageResponse `protobuf:"bytes,100,opt,name=page,proto3" json:"page,omitempty"` // contains filtered or unexported fields }
func (*ListDeadMessagesResponse) Descriptor
deprecated
func (*ListDeadMessagesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDeadMessagesResponse.ProtoReflect.Descriptor instead.
func (*ListDeadMessagesResponse) GetMessages ¶
func (x *ListDeadMessagesResponse) GetMessages() []*v1.DeadMessageState
func (*ListDeadMessagesResponse) GetPage ¶
func (x *ListDeadMessagesResponse) GetPage() *v11.PageResponse
func (*ListDeadMessagesResponse) ProtoMessage ¶
func (*ListDeadMessagesResponse) ProtoMessage()
func (*ListDeadMessagesResponse) ProtoReflect ¶
func (x *ListDeadMessagesResponse) ProtoReflect() protoreflect.Message
func (*ListDeadMessagesResponse) Reset ¶
func (x *ListDeadMessagesResponse) Reset()
func (*ListDeadMessagesResponse) String ¶
func (x *ListDeadMessagesResponse) String() string
type RejectDeadMessageRequest ¶
type RejectDeadMessageRequest struct { MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*RejectDeadMessageRequest) Descriptor
deprecated
func (*RejectDeadMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use RejectDeadMessageRequest.ProtoReflect.Descriptor instead.
func (*RejectDeadMessageRequest) GetMessageId ¶
func (x *RejectDeadMessageRequest) GetMessageId() string
func (*RejectDeadMessageRequest) GetReason ¶
func (x *RejectDeadMessageRequest) GetReason() string
func (*RejectDeadMessageRequest) ProtoMessage ¶
func (*RejectDeadMessageRequest) ProtoMessage()
func (*RejectDeadMessageRequest) ProtoReflect ¶
func (x *RejectDeadMessageRequest) ProtoReflect() protoreflect.Message
func (*RejectDeadMessageRequest) Reset ¶
func (x *RejectDeadMessageRequest) Reset()
func (*RejectDeadMessageRequest) String ¶
func (x *RejectDeadMessageRequest) String() string
type RejectDeadMessageResponse ¶
type RejectDeadMessageResponse struct { Message *v1.DeadMessageState `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*RejectDeadMessageResponse) Descriptor
deprecated
func (*RejectDeadMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use RejectDeadMessageResponse.ProtoReflect.Descriptor instead.
func (*RejectDeadMessageResponse) GetMessage ¶
func (x *RejectDeadMessageResponse) GetMessage() *v1.DeadMessageState
func (*RejectDeadMessageResponse) ProtoMessage ¶
func (*RejectDeadMessageResponse) ProtoMessage()
func (*RejectDeadMessageResponse) ProtoReflect ¶
func (x *RejectDeadMessageResponse) ProtoReflect() protoreflect.Message
func (*RejectDeadMessageResponse) Reset ¶
func (x *RejectDeadMessageResponse) Reset()
func (*RejectDeadMessageResponse) String ¶
func (x *RejectDeadMessageResponse) String() string
type ReplayDeadMessageRequest ¶
type ReplayDeadMessageRequest struct { MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // contains filtered or unexported fields }
func (*ReplayDeadMessageRequest) Descriptor
deprecated
func (*ReplayDeadMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReplayDeadMessageRequest.ProtoReflect.Descriptor instead.
func (*ReplayDeadMessageRequest) GetMessageId ¶
func (x *ReplayDeadMessageRequest) GetMessageId() string
func (*ReplayDeadMessageRequest) ProtoMessage ¶
func (*ReplayDeadMessageRequest) ProtoMessage()
func (*ReplayDeadMessageRequest) ProtoReflect ¶
func (x *ReplayDeadMessageRequest) ProtoReflect() protoreflect.Message
func (*ReplayDeadMessageRequest) Reset ¶
func (x *ReplayDeadMessageRequest) Reset()
func (*ReplayDeadMessageRequest) String ¶
func (x *ReplayDeadMessageRequest) String() string
type ReplayDeadMessageResponse ¶
type ReplayDeadMessageResponse struct { Message *v1.DeadMessageState `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ReplayDeadMessageResponse) Descriptor
deprecated
func (*ReplayDeadMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReplayDeadMessageResponse.ProtoReflect.Descriptor instead.
func (*ReplayDeadMessageResponse) GetMessage ¶
func (x *ReplayDeadMessageResponse) GetMessage() *v1.DeadMessageState
func (*ReplayDeadMessageResponse) ProtoMessage ¶
func (*ReplayDeadMessageResponse) ProtoMessage()
func (*ReplayDeadMessageResponse) ProtoReflect ¶
func (x *ReplayDeadMessageResponse) ProtoReflect() protoreflect.Message
func (*ReplayDeadMessageResponse) Reset ¶
func (x *ReplayDeadMessageResponse) Reset()
func (*ReplayDeadMessageResponse) String ¶
func (x *ReplayDeadMessageResponse) String() string
type UpdateDeadMessageRequest ¶
type UpdateDeadMessageRequest struct { MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` ReplacesVersionId string `protobuf:"bytes,2,opt,name=replaces_version_id,json=replacesVersionId,proto3" json:"replaces_version_id,omitempty"` VersionId *string `protobuf:"bytes,3,opt,name=version_id,json=versionId,proto3,oneof" json:"version_id,omitempty"` Message *v1.DeadMessageSpec `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*UpdateDeadMessageRequest) Descriptor
deprecated
func (*UpdateDeadMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDeadMessageRequest.ProtoReflect.Descriptor instead.
func (*UpdateDeadMessageRequest) GetMessage ¶
func (x *UpdateDeadMessageRequest) GetMessage() *v1.DeadMessageSpec
func (*UpdateDeadMessageRequest) GetMessageId ¶
func (x *UpdateDeadMessageRequest) GetMessageId() string
func (*UpdateDeadMessageRequest) GetReplacesVersionId ¶
func (x *UpdateDeadMessageRequest) GetReplacesVersionId() string
func (*UpdateDeadMessageRequest) GetVersionId ¶
func (x *UpdateDeadMessageRequest) GetVersionId() string
func (*UpdateDeadMessageRequest) ProtoMessage ¶
func (*UpdateDeadMessageRequest) ProtoMessage()
func (*UpdateDeadMessageRequest) ProtoReflect ¶
func (x *UpdateDeadMessageRequest) ProtoReflect() protoreflect.Message
func (*UpdateDeadMessageRequest) Reset ¶
func (x *UpdateDeadMessageRequest) Reset()
func (*UpdateDeadMessageRequest) String ¶
func (x *UpdateDeadMessageRequest) String() string
type UpdateDeadMessageResponse ¶
type UpdateDeadMessageResponse struct { Message *v1.DeadMessageState `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*UpdateDeadMessageResponse) Descriptor
deprecated
func (*UpdateDeadMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDeadMessageResponse.ProtoReflect.Descriptor instead.
func (*UpdateDeadMessageResponse) GetMessage ¶
func (x *UpdateDeadMessageResponse) GetMessage() *v1.DeadMessageState
func (*UpdateDeadMessageResponse) ProtoMessage ¶
func (*UpdateDeadMessageResponse) ProtoMessage()
func (*UpdateDeadMessageResponse) ProtoReflect ¶
func (x *UpdateDeadMessageResponse) ProtoReflect() protoreflect.Message
func (*UpdateDeadMessageResponse) Reset ¶
func (x *UpdateDeadMessageResponse) Reset()
func (*UpdateDeadMessageResponse) String ¶
func (x *UpdateDeadMessageResponse) String() string