eventpb

Documentation

Index

• Variables
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetHeader() *Header
  • func (x *Event) GetPayload() []byte
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type Header
  • func (*Header) Descriptor() ([]byte, []int)
  • func (x *Header) GetEventId() string
  • func (x *Header) GetEventType() string
  • func (x *Header) GetPubId() string
  • func (x *Header) GetPubTime() int64
  • func (x *Header) GetToken() string
  • func (*Header) ProtoMessage()
  • func (x *Header) ProtoReflect() protoreflect.Message
  • func (x *Header) Reset()
  • func (x *Header) String() string

Variables

var File_event_proto protoreflect.FileDescriptor

Types

type Event

type Event struct {
	Header  *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload []byte  `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetHeader

func (x *Event) GetHeader() *Header

func (*Event) GetPayload

func (x *Event) GetPayload() []byte

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Header

type Header struct {
	EventType string `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` // event type
	PubId     string `protobuf:"bytes,2,opt,name=pub_id,json=pubId,proto3" json:"pub_id,omitempty"`             // the unique identifier for publisher
	Token     string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`                          // for validation message
	PubTime   int64  `protobuf:"varint,4,opt,name=pub_time,json=pubTime,proto3" json:"pub_time,omitempty"`      // event pub timestamp
	EventId   string `protobuf:"bytes,5,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`       // event id for tracing
	// contains filtered or unexported fields
}

func (*Header) Descriptor

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetEventId

func (x *Header) GetEventId() string

func (*Header) GetEventType

func (x *Header) GetEventType() string

func (*Header) GetPubId

func (x *Header) GetPubId() string

func (*Header) GetPubTime

func (x *Header) GetPubTime() int64

func (*Header) GetToken

func (x *Header) GetToken() 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