pb

Documentation

Index

• Variables
• type BaseEvent
  • func (*BaseEvent) Descriptor() ([]byte, []int)
  • func (x *BaseEvent) GetId() string
  • func (x *BaseEvent) GetPayload() *anypb.Any
  • func (x *BaseEvent) GetTimestamp() *timestamppb.Timestamp
  • func (x *BaseEvent) GetType() string
  • func (*BaseEvent) ProtoMessage()
  • func (x *BaseEvent) ProtoReflect() protoreflect.Message
  • func (x *BaseEvent) Reset()
  • func (x *BaseEvent) String() string

Variables

var File_proto_messages_proto protoreflect.FileDescriptor

Types

type BaseEvent

type BaseEvent struct {

	// Id is generated on the on
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Type must be exact the same as the subject name, eg. "user.created"
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Timestamp to identify when message was created, helps when it needs to how long message was waiting to be processed
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Payload is any proto message you assume it to be
	Payload *anypb.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

BaseEvent represents the common structure for all events

func (*BaseEvent) Descriptor

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

Deprecated: Use BaseEvent.ProtoReflect.Descriptor instead.

func (*BaseEvent) GetId

func (x *BaseEvent) GetId() string

func (*BaseEvent) GetPayload

func (x *BaseEvent) GetPayload() *anypb.Any

func (*BaseEvent) GetTimestamp

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

func (*BaseEvent) GetType

func (x *BaseEvent) GetType() string

func (*BaseEvent) ProtoMessage

func (*BaseEvent) ProtoMessage()

func (*BaseEvent) ProtoReflect

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

func (*BaseEvent) Reset

func (x *BaseEvent) Reset()

func (*BaseEvent) String

func (x *BaseEvent) String() string