eventspb

Documentation

Index

• Variables
• type DeadletterEvent
  • func (*DeadletterEvent) Descriptor() ([]byte, []int)
  • func (x *DeadletterEvent) GetMessage() *anypb.Any
  • func (x *DeadletterEvent) GetReason() string
  • func (x *DeadletterEvent) GetReceiver() *v1.Address
  • func (x *DeadletterEvent) GetSendTime() *timestamppb.Timestamp
  • func (x *DeadletterEvent) GetSender() *v1.Address
  • func (*DeadletterEvent) ProtoMessage()
  • func (x *DeadletterEvent) ProtoReflect() protoreflect.Message
  • func (x *DeadletterEvent) Reset()
  • func (x *DeadletterEvent) String() string
• type Event
  • func (Event) Descriptor() protoreflect.EnumDescriptor
  • func (x Event) Enum() *Event
  • func (Event) EnumDescriptor() ([]byte, []int)
  • func (x Event) Number() protoreflect.EnumNumber
  • func (x Event) String() string
  • func (Event) Type() protoreflect.EnumType

Variables

var (
	Event_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "DEAD_LETTER",
	}
	Event_value = map[string]int32{
		"UNSPECIFIED": 0,
		"DEAD_LETTER": 1,
	}
)

Enum value maps for Event.

var File_events_v1_events_proto protoreflect.FileDescriptor

Types

type DeadletterEvent

type DeadletterEvent struct {

	// Specifies the sender's address
	Sender *v1.Address `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Specifies the actor address
	Receiver *v1.Address `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Specifies the message to send to the actor
	// Any proto message is allowed to be sent
	Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Specifies the message send time
	SendTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"`
	// Specifies the reason why the deadletter
	Reason string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

DeadletterEvent defines the deadletter entry

func (*DeadletterEvent) Descriptor

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

Deprecated: Use DeadletterEvent.ProtoReflect.Descriptor instead.

func (*DeadletterEvent) GetMessage

func (x *DeadletterEvent) GetMessage() *anypb.Any

func (*DeadletterEvent) GetReason

func (x *DeadletterEvent) GetReason() string

func (*DeadletterEvent) GetReceiver

func (x *DeadletterEvent) GetReceiver() *v1.Address

func (*DeadletterEvent) GetSendTime

func (x *DeadletterEvent) GetSendTime() *timestamppb.Timestamp

func (*DeadletterEvent) GetSender

func (x *DeadletterEvent) GetSender() *v1.Address

func (*DeadletterEvent) ProtoMessage

func (*DeadletterEvent) ProtoMessage()

func (*DeadletterEvent) ProtoReflect

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

func (*DeadletterEvent) Reset

func (x *DeadletterEvent) Reset()

func (*DeadletterEvent) String

func (x *DeadletterEvent) String() string

type Event

type Event int32

const (
	Event_UNSPECIFIED Event = 0
	Event_DEAD_LETTER Event = 1
)

func (Event) Descriptor

func (Event) Descriptor() protoreflect.EnumDescriptor

func (Event) Enum

func (x Event) Enum() *Event

func (Event) EnumDescriptor

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

Deprecated: Use Event.Descriptor instead.

func (Event) Number

func (x Event) Number() protoreflect.EnumNumber

func (Event) String

func (x Event) String() string

func (Event) Type

func (Event) Type() protoreflect.EnumType