service

package
v1.29.0-20240507215828... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_o5_dante_v1_service_dead_message_command_proto protoreflect.FileDescriptor
View Source 
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

Source Files

View all Source files

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.