Documentation
¶
Overview ¶
Package tally is a generated protocol buffer package.
It is generated from these files:
tally.proto
It has these top-level messages:
Content Attribute Location Event
Index ¶
- func Init(settings Settings) *tallyImpl
- func InitSubscriber(settings SubscriberSettings) (impl *tallySubscriberImpl, err error)
- type Attribute
- func (m *Attribute) GetBoolValue() bool
- func (m *Attribute) GetContentValue() *Content
- func (m *Attribute) GetDoubleValue() float64
- func (m *Attribute) GetIntValue() int64
- func (m *Attribute) GetKey() string
- func (m *Attribute) GetStringValue() string
- func (*Attribute) ProtoMessage()
- func (m *Attribute) Reset()
- func (m *Attribute) String() string
- type Content
- type Event
- func (m *Event) GetAppKey() string
- func (m *Event) GetAttributes() []*Attribute
- func (m *Event) GetContext() string
- func (m *Event) GetLocation() *Location
- func (m *Event) GetSource() string
- func (m *Event) GetTimestamp() float64
- func (m *Event) GetType() string
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (this *Event) SetAttribute(key, value string)
- func (this *Event) SetAttributeBool(key string, value bool)
- func (this *Event) SetAttributeInt(key string, value int)
- func (m *Event) String() string
- func (this *Event) ToJSON(indent bool) (bytes []byte, err error)
- type Location
- type Settings
- type SubscriberSettings
- type Tally
- type TallySubscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitSubscriber ¶
func InitSubscriber(settings SubscriberSettings) (impl *tallySubscriberImpl, err error)
Types ¶
type Attribute ¶
type Attribute struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` StringValue *string `protobuf:"bytes,2,opt,name=string_value" json:"string_value,omitempty"` IntValue *int64 `protobuf:"varint,3,opt,name=int_value" json:"int_value,omitempty"` DoubleValue *float64 `protobuf:"fixed64,4,opt,name=double_value" json:"double_value,omitempty"` BoolValue *bool `protobuf:"varint,5,opt,name=bool_value" json:"bool_value,omitempty"` ContentValue *Content `protobuf:"bytes,6,opt,name=content_value" json:"content_value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Attribute) GetBoolValue ¶
func (*Attribute) GetContentValue ¶
func (*Attribute) GetDoubleValue ¶
func (*Attribute) GetIntValue ¶
func (*Attribute) GetStringValue ¶
func (*Attribute) ProtoMessage ¶
func (*Attribute) ProtoMessage()
type Content ¶
type Content struct { Mime *string `protobuf:"bytes,1,req,name=mime" json:"mime,omitempty"` Data []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"` XXX_unrecognized []byte `json:"-"` }
Generalized event schema for indexing in ElasticSearch
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
type Event ¶
type Event struct { AppKey *string `protobuf:"bytes,1,req,name=appKey" json:"appKey,omitempty"` Timestamp *float64 `protobuf:"fixed64,2,req,name=timestamp" json:"timestamp,omitempty"` Type *string `protobuf:"bytes,3,req,name=type" json:"type,omitempty"` Source *string `protobuf:"bytes,4,req,name=source" json:"source,omitempty"` Context *string `protobuf:"bytes,5,opt,name=context" json:"context,omitempty"` Location *Location `protobuf:"bytes,6,opt,name=location" json:"location,omitempty"` Attributes []*Attribute `protobuf:"bytes,7,rep,name=attributes" json:"attributes,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Event) GetAttributes ¶
func (*Event) GetContext ¶
func (*Event) GetLocation ¶
func (*Event) GetTimestamp ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) SetAttribute ¶
func (*Event) SetAttributeBool ¶
func (*Event) SetAttributeInt ¶
type Location ¶
type Location struct { Lon *float64 `protobuf:"fixed64,1,req,name=lon" json:"lon,omitempty"` Lat *float64 `protobuf:"fixed64,2,req,name=lat" json:"lat,omitempty"` XXX_unrecognized []byte `json:"-"` }
To be transformed to GeoJson - ex) {"location" : [-71.34, 41.12]} See http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/mapping-geo-point-type.html
func (*Location) ProtoMessage ¶
func (*Location) ProtoMessage()
type SubscriberSettings ¶
type TallySubscriber ¶
type TallySubscriber interface { Channel() <-chan interface{} Start() Queue(queue string, inbound <-chan interface{}) Stop() Close() }
Click to show internal directories.
Click to hide internal directories.