Documentation ¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
event.proto
It has these top-level messages:
Event
Index ¶
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetAckTime() int64
- func (m *Event) GetAggregate() string
- func (m *Event) GetCause() string
- func (m *Event) GetClient() string
- func (m *Event) GetData() []byte
- func (m *Event) GetEncoding() string
- func (m *Event) GetId() string
- func (m *Event) GetMeta() map[string]string
- func (m *Event) GetSchema() string
- func (m *Event) GetTime() int64
- func (m *Event) GetType() string
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct { // Unique ID of the event. Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` // The time given by the source producer of the event. // This can be manually set in code, otherwise it will be // set by the client producing the event. Time int64 `protobuf:"varint,2,opt,name=time" json:"time,omitempty"` // Acknowledged timestamp of the event. This is provided by the backend, // but a field is here if the event is republished as-is. AckTime int64 `protobuf:"varint,11,opt,name=ack_time,json=ackTime" json:"ack_time,omitempty"` // The event type. Type string `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"` // An optional event ID that is the cause of this event. Cause string `protobuf:"bytes,5,opt,name=cause" json:"cause,omitempty"` // The client that produced this event. Client string `protobuf:"bytes,6,opt,name=client" json:"client,omitempty"` // Schema is the name of the schema of the encoded data. // This will likely be a name and optionally a version suffix. Schema string `protobuf:"bytes,4,opt,name=schema" json:"schema,omitempty"` // Encoding of the event data. Encoding string `protobuf:"bytes,8,opt,name=encoding" json:"encoding,omitempty"` // Encoded event data. Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"` // Arbitrary metadata as a set of key-value pairs. This can be used // for adding upstream user/client info, authorization tokens, etc. Meta map[string]string `` /* 129-byte string literal not displayed */ // Key of the "aggregate" that this event is about. Aggregate string `protobuf:"bytes,12,opt,name=aggregate" json:"aggregate,omitempty"` }
func (*Event) Descriptor ¶
func (*Event) GetAckTime ¶
func (*Event) GetAggregate ¶
func (*Event) GetEncoding ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.