tally

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

type Settings struct {
	RedisUrl     string
	RedisChannel string
}

type SubscriberSettings struct {
	RedisUrl       string
	RedisChannel   string
	MaxQueueLength int
}

type Tally interface {
	Channel() chan<- *Event
	Start()
	Stop()
	Close()
}

type TallySubscriber interface {
	Channel() <-chan interface{}
	Start()
	Queue(queue string, inbound <-chan interface{})
	Stop()
	Close()
}