pb

Documentation

Index

• Variables
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetAggId() string
  • func (x *Event) GetAggName() string
  • func (x *Event) GetAggVersion() uint64
  • func (x *Event) GetCreatedAt() *timestamppb.Timestamp
  • func (x *Event) GetName() string
  • func (x *Event) GetPayload() *anypb.Any
  • func (x *Event) GetUuid() string
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type PublishRequest
  • func (*PublishRequest) Descriptor() ([]byte, []int)
  • func (x *PublishRequest) GetEvent() *Event
  • func (x *PublishRequest) GetTopic() string
  • func (*PublishRequest) ProtoMessage()
  • func (x *PublishRequest) ProtoReflect() protoreflect.Message
  • func (x *PublishRequest) Reset()
  • func (x *PublishRequest) String() string

Variables

var File_pb_event_proto protoreflect.FileDescriptor

Types

type Event

type Event struct {
	Name       string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                // 事件名称
	AggId      string                 `protobuf:"bytes,2,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"`                 // 聚合ID
	AggName    string                 `protobuf:"bytes,3,opt,name=agg_name,json=aggName,proto3" json:"agg_name,omitempty"`           // 聚合名称
	AggVersion uint64                 `protobuf:"varint,4,opt,name=agg_version,json=aggVersion,proto3" json:"agg_version,omitempty"` // 聚合版本
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`     // 创建时间
	Uuid       string                 `protobuf:"bytes,6,opt,name=uuid,proto3" json:"uuid,omitempty"`                                // uuid
	Payload    *anypb.Any             `protobuf:"bytes,10,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) GetAggId

func (x *Event) GetAggId() string

func (*Event) GetAggName

func (x *Event) GetAggName() string

func (*Event) GetAggVersion

func (x *Event) GetAggVersion() uint64

func (*Event) GetCreatedAt

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

func (*Event) GetName

func (x *Event) GetName() string

func (*Event) GetPayload

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

func (*Event) GetUuid

func (x *Event) GetUuid() string

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 PublishRequest

type PublishRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetEvent

func (x *PublishRequest) GetEvent() *Event

func (*PublishRequest) GetTopic

func (x *PublishRequest) GetTopic() string

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string