eda: github.com/chop-dbhi/eda/internal/pb Index | Files

package pb

import "github.com/chop-dbhi/eda/internal/pb"

Package pb is a generated protocol buffer package.

It is generated from these files:

event.proto

It has these top-level messages:

Event

Index

Package Files

event.pb.go

type Event Uses

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 `protobuf:"bytes,10,rep,name=meta" json:"meta,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    // Key of the "aggregate" that this event is about.
    Aggregate string `protobuf:"bytes,12,opt,name=aggregate" json:"aggregate,omitempty"`
}

func (*Event) Descriptor Uses

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

func (*Event) GetAckTime Uses

func (m *Event) GetAckTime() int64

func (*Event) GetAggregate Uses

func (m *Event) GetAggregate() string

func (*Event) GetCause Uses

func (m *Event) GetCause() string

func (*Event) GetClient Uses

func (m *Event) GetClient() string

func (*Event) GetData Uses

func (m *Event) GetData() []byte

func (*Event) GetEncoding Uses

func (m *Event) GetEncoding() string

func (*Event) GetId Uses

func (m *Event) GetId() string

func (*Event) GetMeta Uses

func (m *Event) GetMeta() map[string]string

func (*Event) GetSchema Uses

func (m *Event) GetSchema() string

func (*Event) GetTime Uses

func (m *Event) GetTime() int64

func (*Event) GetType Uses

func (m *Event) GetType() string

func (*Event) ProtoMessage Uses

func (*Event) ProtoMessage()

func (*Event) Reset Uses

func (m *Event) Reset()

func (*Event) String Uses

func (m *Event) String() string

Package pb imports 3 packages (graph) and is imported by 1 packages. Updated 2017-12-04. Refresh now. Tools for package owners.