dantev1

package
v1.34.1-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 (
	MessageStatus_name = map[int32]string{
		0: "MESSAGE_STATUS_UNSPECIFIED",
		1: "MESSAGE_STATUS_CREATED",
		2: "MESSAGE_STATUS_UPDATED",
		3: "MESSAGE_STATUS_REPLAYED",
		4: "MESSAGE_STATUS_REJECTED",
	}
	MessageStatus_value = map[string]int32{
		"MESSAGE_STATUS_UNSPECIFIED": 0,
		"MESSAGE_STATUS_CREATED":     1,
		"MESSAGE_STATUS_UPDATED":     2,
		"MESSAGE_STATUS_REPLAYED":    3,
		"MESSAGE_STATUS_REJECTED":    4,
	}
)

Enum value maps for MessageStatus.

View Source
var (
	Urgency_name = map[int32]string{
		0: "URGENCY_UNSPECIFIED",
		1: "URGENCY_LOW",
		2: "URGENCY_MEDIUM",
		3: "URGENCY_HIGH",
	}
	Urgency_value = map[string]int32{
		"URGENCY_UNSPECIFIED": 0,
		"URGENCY_LOW":         1,
		"URGENCY_MEDIUM":      2,
		"URGENCY_HIGH":        3,
	}
)

Enum value maps for Urgency.

View Source
var File_o5_dante_v1_dead_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Any

type Any struct {
	Proto *anypb.Any `protobuf:"bytes,1,opt,name=proto,proto3" json:"proto,omitempty"`
	Json  string     `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"`
	// contains filtered or unexported fields
}

Any wraps the well-known any, but encodes messages as JSON in addition

func (*Any) Descriptor deprecated

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

Deprecated: Use Any.ProtoReflect.Descriptor instead.

func (*Any) GetJson

func (x *Any) GetJson() string

func (*Any) GetProto

func (x *Any) GetProto() *anypb.Any

func (*Any) ProtoMessage

func (*Any) ProtoMessage()

func (*Any) ProtoReflect

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

func (*Any) Reset

func (x *Any) Reset()

func (*Any) String

func (x *Any) String() string

type DeadMessageEvent

type DeadMessageEvent struct {
	Metadata  *Metadata             `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	MessageId string                `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Event     *DeadMessageEventType `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*DeadMessageEvent) Descriptor deprecated

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

Deprecated: Use DeadMessageEvent.ProtoReflect.Descriptor instead.

func (*DeadMessageEvent) GetEvent

func (x *DeadMessageEvent) GetEvent() *DeadMessageEventType

func (*DeadMessageEvent) GetMessageId

func (x *DeadMessageEvent) GetMessageId() string

func (*DeadMessageEvent) GetMetadata

func (x *DeadMessageEvent) GetMetadata() *Metadata

func (*DeadMessageEvent) ProtoMessage

func (*DeadMessageEvent) ProtoMessage()

func (*DeadMessageEvent) ProtoReflect

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

func (*DeadMessageEvent) Reset

func (x *DeadMessageEvent) Reset()

func (*DeadMessageEvent) String

func (x *DeadMessageEvent) String() string

type DeadMessageEventType

type DeadMessageEventType struct {

	// Types that are assignable to Type:
	//
	//	*DeadMessageEventType_Created_
	//	*DeadMessageEventType_Updated_
	//	*DeadMessageEventType_Replayed_
	//	*DeadMessageEventType_Rejected_
	Type isDeadMessageEventType_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*DeadMessageEventType) Descriptor deprecated

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

Deprecated: Use DeadMessageEventType.ProtoReflect.Descriptor instead.

func (*DeadMessageEventType) GetCreated

func (*DeadMessageEventType) GetRejected

func (*DeadMessageEventType) GetReplayed

func (*DeadMessageEventType) GetType

func (m *DeadMessageEventType) GetType() isDeadMessageEventType_Type

func (*DeadMessageEventType) GetUpdated

func (*DeadMessageEventType) ProtoMessage

func (*DeadMessageEventType) ProtoMessage()

func (*DeadMessageEventType) ProtoReflect

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

func (*DeadMessageEventType) Reset

func (x *DeadMessageEventType) Reset()

func (*DeadMessageEventType) String

func (x *DeadMessageEventType) String() string

type DeadMessageEventType_Created

type DeadMessageEventType_Created struct {
	Spec *DeadMessageSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*DeadMessageEventType_Created) Descriptor deprecated

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

Deprecated: Use DeadMessageEventType_Created.ProtoReflect.Descriptor instead.

func (*DeadMessageEventType_Created) GetSpec

func (*DeadMessageEventType_Created) ProtoMessage

func (*DeadMessageEventType_Created) ProtoMessage()

func (*DeadMessageEventType_Created) ProtoReflect

func (*DeadMessageEventType_Created) Reset

func (x *DeadMessageEventType_Created) Reset()

func (*DeadMessageEventType_Created) String

type DeadMessageEventType_Created_

type DeadMessageEventType_Created_ struct {
	Created *DeadMessageEventType_Created `protobuf:"bytes,1,opt,name=created,proto3,oneof"`
}

type DeadMessageEventType_Rejected

type DeadMessageEventType_Rejected struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*DeadMessageEventType_Rejected) Descriptor deprecated

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

Deprecated: Use DeadMessageEventType_Rejected.ProtoReflect.Descriptor instead.

func (*DeadMessageEventType_Rejected) GetReason

func (x *DeadMessageEventType_Rejected) GetReason() string

func (*DeadMessageEventType_Rejected) ProtoMessage

func (*DeadMessageEventType_Rejected) ProtoMessage()

func (*DeadMessageEventType_Rejected) ProtoReflect

func (*DeadMessageEventType_Rejected) Reset

func (x *DeadMessageEventType_Rejected) Reset()

func (*DeadMessageEventType_Rejected) String

type DeadMessageEventType_Rejected_

type DeadMessageEventType_Rejected_ struct {
	Rejected *DeadMessageEventType_Rejected `protobuf:"bytes,4,opt,name=rejected,proto3,oneof"`
}

type DeadMessageEventType_Replayed

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

func (*DeadMessageEventType_Replayed) Descriptor deprecated

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

Deprecated: Use DeadMessageEventType_Replayed.ProtoReflect.Descriptor instead.

func (*DeadMessageEventType_Replayed) ProtoMessage

func (*DeadMessageEventType_Replayed) ProtoMessage()

func (*DeadMessageEventType_Replayed) ProtoReflect

func (*DeadMessageEventType_Replayed) Reset

func (x *DeadMessageEventType_Replayed) Reset()

func (*DeadMessageEventType_Replayed) String

type DeadMessageEventType_Replayed_

type DeadMessageEventType_Replayed_ struct {
	Replayed *DeadMessageEventType_Replayed `protobuf:"bytes,3,opt,name=replayed,proto3,oneof"`
}

type DeadMessageEventType_Updated

type DeadMessageEventType_Updated struct {
	Spec *DeadMessageSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*DeadMessageEventType_Updated) Descriptor deprecated

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

Deprecated: Use DeadMessageEventType_Updated.ProtoReflect.Descriptor instead.

func (*DeadMessageEventType_Updated) GetSpec

func (*DeadMessageEventType_Updated) ProtoMessage

func (*DeadMessageEventType_Updated) ProtoMessage()

func (*DeadMessageEventType_Updated) ProtoReflect

func (*DeadMessageEventType_Updated) Reset

func (x *DeadMessageEventType_Updated) Reset()

func (*DeadMessageEventType_Updated) String

type DeadMessageEventType_Updated_

type DeadMessageEventType_Updated_ struct {
	Updated *DeadMessageEventType_Updated `protobuf:"bytes,2,opt,name=updated,proto3,oneof"`
}

type DeadMessageSpec

type DeadMessageSpec struct {
	VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// The ID used by the underlying messaging infra, can be any format
	InfraMessageId string                 `protobuf:"bytes,2,opt,name=infra_message_id,json=infraMessageId,proto3" json:"infra_message_id,omitempty"`
	QueueName      string                 `protobuf:"bytes,3,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	GrpcName       string                 `protobuf:"bytes,4,opt,name=grpc_name,json=grpcName,proto3" json:"grpc_name,omitempty"`
	CreatedAt      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Payload        *Any                   `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	Problem        *Problem               `protobuf:"bytes,8,opt,name=problem,proto3" json:"problem,omitempty"`
	// contains filtered or unexported fields
}

func (*DeadMessageSpec) Descriptor deprecated

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

Deprecated: Use DeadMessageSpec.ProtoReflect.Descriptor instead.

func (*DeadMessageSpec) GetCreatedAt

func (x *DeadMessageSpec) GetCreatedAt() *timestamppb.Timestamp

func (*DeadMessageSpec) GetGrpcName

func (x *DeadMessageSpec) GetGrpcName() string

func (*DeadMessageSpec) GetInfraMessageId

func (x *DeadMessageSpec) GetInfraMessageId() string

func (*DeadMessageSpec) GetPayload

func (x *DeadMessageSpec) GetPayload() *Any

func (*DeadMessageSpec) GetProblem

func (x *DeadMessageSpec) GetProblem() *Problem

func (*DeadMessageSpec) GetQueueName

func (x *DeadMessageSpec) GetQueueName() string

func (*DeadMessageSpec) GetVersionId

func (x *DeadMessageSpec) GetVersionId() string

func (*DeadMessageSpec) ProtoMessage

func (*DeadMessageSpec) ProtoMessage()

func (*DeadMessageSpec) ProtoReflect

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

func (*DeadMessageSpec) Reset

func (x *DeadMessageSpec) Reset()

func (*DeadMessageSpec) String

func (x *DeadMessageSpec) String() string

type DeadMessageState

type DeadMessageState struct {
	MessageId   string           `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Status      MessageStatus    `protobuf:"varint,2,opt,name=status,proto3,enum=o5.dante.v1.MessageStatus" json:"status,omitempty"`
	CurrentSpec *DeadMessageSpec `protobuf:"bytes,3,opt,name=current_spec,json=currentSpec,proto3" json:"current_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*DeadMessageState) Descriptor deprecated

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

Deprecated: Use DeadMessageState.ProtoReflect.Descriptor instead.

func (*DeadMessageState) GetCurrentSpec

func (x *DeadMessageState) GetCurrentSpec() *DeadMessageSpec

func (*DeadMessageState) GetMessageId

func (x *DeadMessageState) GetMessageId() string

func (*DeadMessageState) GetStatus

func (x *DeadMessageState) GetStatus() MessageStatus

func (*DeadMessageState) ProtoMessage

func (*DeadMessageState) ProtoMessage()

func (*DeadMessageState) ProtoReflect

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

func (*DeadMessageState) Reset

func (x *DeadMessageState) Reset()

func (*DeadMessageState) String

func (x *DeadMessageState) String() string

type InvariantViolation

type InvariantViolation struct {
	Description string  `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Error       *Any    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Urgency     Urgency `protobuf:"varint,3,opt,name=urgency,proto3,enum=o5.dante.v1.Urgency" json:"urgency,omitempty"`
	// contains filtered or unexported fields
}

func (*InvariantViolation) Descriptor deprecated

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

Deprecated: Use InvariantViolation.ProtoReflect.Descriptor instead.

func (*InvariantViolation) GetDescription

func (x *InvariantViolation) GetDescription() string

func (*InvariantViolation) GetError

func (x *InvariantViolation) GetError() *Any

func (*InvariantViolation) GetUrgency

func (x *InvariantViolation) GetUrgency() Urgency

func (*InvariantViolation) ProtoMessage

func (*InvariantViolation) ProtoMessage()

func (*InvariantViolation) ProtoReflect

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

func (*InvariantViolation) Reset

func (x *InvariantViolation) Reset()

func (*InvariantViolation) String

func (x *InvariantViolation) String() string

type MessageStatus

type MessageStatus int32
const (
	MessageStatus_MESSAGE_STATUS_UNSPECIFIED MessageStatus = 0
	MessageStatus_MESSAGE_STATUS_CREATED     MessageStatus = 1
	MessageStatus_MESSAGE_STATUS_UPDATED     MessageStatus = 2
	MessageStatus_MESSAGE_STATUS_REPLAYED    MessageStatus = 3
	MessageStatus_MESSAGE_STATUS_REJECTED    MessageStatus = 4
)

func (MessageStatus) Descriptor

func (MessageStatus) Enum

func (x MessageStatus) Enum() *MessageStatus

func (MessageStatus) EnumDescriptor deprecated

func (MessageStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use MessageStatus.Descriptor instead.

func (MessageStatus) Number

func (MessageStatus) String

func (x MessageStatus) String() string

func (MessageStatus) Type

type Metadata

type Metadata struct {
	EventId   string                 `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Actor     *v1.AuthenticatedActor `protobuf:"bytes,3,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetActor

func (x *Metadata) GetActor() *v1.AuthenticatedActor

func (*Metadata) GetEventId

func (x *Metadata) GetEventId() string

func (*Metadata) GetTimestamp

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

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

type Problem

type Problem struct {

	// Types that are assignable to Type:
	//
	//	*Problem_InvariantViolation
	//	*Problem_UnhandledError
	Type isProblem_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Problem) Descriptor deprecated

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

Deprecated: Use Problem.ProtoReflect.Descriptor instead.

func (*Problem) GetInvariantViolation

func (x *Problem) GetInvariantViolation() *InvariantViolation

func (*Problem) GetType

func (m *Problem) GetType() isProblem_Type

func (*Problem) GetUnhandledError

func (x *Problem) GetUnhandledError() *UnhandledError

func (*Problem) ProtoMessage

func (*Problem) ProtoMessage()

func (*Problem) ProtoReflect

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

func (*Problem) Reset

func (x *Problem) Reset()

func (*Problem) String

func (x *Problem) String() string

type Problem_InvariantViolation

type Problem_InvariantViolation struct {
	InvariantViolation *InvariantViolation `protobuf:"bytes,1,opt,name=invariant_violation,json=invariantViolation,proto3,oneof"`
}

type Problem_UnhandledError

type Problem_UnhandledError struct {
	UnhandledError *UnhandledError `protobuf:"bytes,2,opt,name=unhandled_error,json=unhandledError,proto3,oneof"`
}

type UnhandledError

type UnhandledError struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UnhandledError) Descriptor deprecated

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

Deprecated: Use UnhandledError.ProtoReflect.Descriptor instead.

func (*UnhandledError) GetError

func (x *UnhandledError) GetError() string

func (*UnhandledError) ProtoMessage

func (*UnhandledError) ProtoMessage()

func (*UnhandledError) ProtoReflect

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

func (*UnhandledError) Reset

func (x *UnhandledError) Reset()

func (*UnhandledError) String

func (x *UnhandledError) String() string

type Urgency

type Urgency int32
const (
	Urgency_URGENCY_UNSPECIFIED Urgency = 0
	Urgency_URGENCY_LOW         Urgency = 1
	Urgency_URGENCY_MEDIUM      Urgency = 2
	Urgency_URGENCY_HIGH        Urgency = 3
)

func (Urgency) Descriptor

func (Urgency) Descriptor() protoreflect.EnumDescriptor

func (Urgency) Enum

func (x Urgency) Enum() *Urgency

func (Urgency) EnumDescriptor deprecated

func (Urgency) EnumDescriptor() ([]byte, []int)

Deprecated: Use Urgency.Descriptor instead.

func (Urgency) Number

func (x Urgency) Number() protoreflect.EnumNumber

func (Urgency) String

func (x Urgency) String() string

func (Urgency) Type

func (Urgency) Type() protoreflect.EnumType

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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