events

Documentation

Index

• Variables
• type Header
  • func (*Header) Descriptor() ([]byte, []int)
  • func (x *Header) GetCorrelationId() string
  • func (x *Header) GetId() string
  • func (x *Header) GetName() string
  • func (x *Header) GetPublishedAt() *timestamppb.Timestamp
  • func (x *Header) GetPublisherName() string
  • func (*Header) ProtoMessage()
  • func (x *Header) ProtoReflect() protoreflect.Message
  • func (x *Header) Reset()
  • func (x *Header) String() string
• type MessageSent
  • func (*MessageSent) Descriptor() ([]byte, []int)
  • func (x *MessageSent) GetEndpointId() string
  • func (x *MessageSent) GetHeader() *Header
  • func (x *MessageSent) GetMessageId() string
  • func (*MessageSent) ProtoMessage()
  • func (x *MessageSent) ProtoReflect() protoreflect.Message
  • func (x *MessageSent) Reset()
  • func (x *MessageSent) String() string

Variables

var File_events_proto protoreflect.FileDescriptor

Types

type Header

type Header struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CorrelationId string                 `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	PublisherName string                 `protobuf:"bytes,4,opt,name=publisher_name,json=publisherName,proto3" json:"publisher_name,omitempty"`
	PublishedAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=published_at,json=publishedAt,proto3" json:"published_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetCorrelationId

func (x *Header) GetCorrelationId() string

func (*Header) GetId

func (x *Header) GetId() string

func (*Header) GetName

func (x *Header) GetName() string

func (*Header) GetPublishedAt

func (x *Header) GetPublishedAt() *timestamppb.Timestamp

func (*Header) GetPublisherName

func (x *Header) GetPublisherName() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) ProtoReflect

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

func (*Header) Reset

func (x *Header) Reset()

func (*Header) String

func (x *Header) String() string

type MessageSent

type MessageSent struct {
	Header     *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	MessageId  string  `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	EndpointId string  `protobuf:"bytes,3,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageSent) Descriptor

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

Deprecated: Use MessageSent.ProtoReflect.Descriptor instead.

func (*MessageSent) GetEndpointId

func (x *MessageSent) GetEndpointId() string

func (*MessageSent) GetHeader

func (x *MessageSent) GetHeader() *Header

func (*MessageSent) GetMessageId

func (x *MessageSent) GetMessageId() string

func (*MessageSent) ProtoMessage

func (*MessageSent) ProtoMessage()

func (*MessageSent) ProtoReflect

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

func (*MessageSent) Reset

func (x *MessageSent) Reset()

func (*MessageSent) String

func (x *MessageSent) String() string