event

Jul 24, 2018

Changes in this version

+ func GenSubID() string

Jun 26, 2018

Changes in this version

+ const AddressKey

+ const CalleeKey

+ const CallerKey

+ const EventTypeKey

+ const ExceptionKey

+ const GasKey

+ const HeightKey

+ const IndexKey

+ const LogNKeyPrefix

+ const NameKey

+ const OriginKey

+ const PermissionKey

+ const SubscribeCallbackTimeout

+ const ValueKey

+ func LogNKey(topic int) string

+ func LogNTextKey(topic int) string

type Cache

+ func NewCache() *Cache

+ func (evc *Cache) Reset()

+ func (evc *Cache) Sync(publisher Publisher) error

+ type CombinedTags []Tags

+ func (ct CombinedTags) Get(key string) (value string, ok bool)

+ func (ct CombinedTags) Keys() []string

+ func (ct CombinedTags) Len() (length int)

+ func (ct CombinedTags) Map() map[string]interface{}

+ type Indexable interface

+ ProvideIndex func(index uint64)

+ type PublisherFunc func(ctx context.Context, message interface{}, tags Tags) error

+ func (pf PublisherFunc) Publish(ctx context.Context, message interface{}, tags Tags) error

+ type TagMap map[string]interface

+ func (ts TagMap) Get(key string) (value string, ok bool)

+ func (ts TagMap) Keys() []string

+ func (ts TagMap) Len() int

+ func (ts TagMap) Map() map[string]interface{}

+ type Tags interface

+ Keys func() []string

May 8, 2018

Changes in this version

+ const DefaultEventBufferCapacity

+ const EventIDKey

+ const MessageTypeKey

+ const StackDepthKey

+ const TxHashKey

+ const TxTypeKey

+ func GenerateSubscriptionID() (string, error)

+ func PublishAll(ctx context.Context, subscribable Subscribable, subscriber string, ...) error

+ func PublishWithEventID(publisher Publisher, eventID string, eventData interface{}, ...) error

+ func SubscribeCallback(ctx context.Context, subscribable Subscribable, subscriber string, ...) error

+ type Cache struct

+ func NewEventCache(publisher Publisher) *Cache

+ func (evc *Cache) Flush() error

+ func (evc *Cache) Publish(ctx context.Context, message interface{}, tags map[string]interface{}) error

+ type Emitter interface

+ func NewEmitter(logger *logging.Logger) Emitter

+ type Publisher interface

+ Publish func(ctx context.Context, message interface{}, tags map[string]interface{}) error

+ func NewNoOpPublisher() Publisher

+ type Query struct

+ func WrapQuery(qry pubsub.Query) Query

+ func (q Query) Query() (pubsub.Query, error)

+ type QueryBuilder struct

+ func NewQueryBuilder(queries ...string) *QueryBuilder

+ func QueryForEventID(eventID string) *QueryBuilder

+ func (qb *QueryBuilder) And(queryBuilders ...*QueryBuilder) *QueryBuilder

+ func (qb *QueryBuilder) AndContains(tag string, operand interface{}) *QueryBuilder

+ func (qb *QueryBuilder) AndEquals(tag string, operand interface{}) *QueryBuilder

+ func (qb *QueryBuilder) AndGreaterThanOrEqual(tag string, operand interface{}) *QueryBuilder

+ func (qb *QueryBuilder) AndLessThanOrEqual(tag string, operand interface{}) *QueryBuilder

+ func (qb *QueryBuilder) AndStrictlyGreaterThan(tag string, operand interface{}) *QueryBuilder

+ func (qb *QueryBuilder) AndStrictlyLessThan(tag string, operand interface{}) *QueryBuilder

+ func (qb *QueryBuilder) Query() (pubsub.Query, error)

+ func (qb *QueryBuilder) String() string

+ type QueryString string

+ func (qs QueryString) Query() (pubsub.Query, error)

+ type Queryable interface

+ Query func() (pubsub.Query, error)

+ func MatchAllQueryable() Queryable

+ type Subscribable interface

+ Subscribe func(ctx context.Context, subscriber string, query Queryable, ...) error

+ Unsubscribe func(ctx context.Context, subscriber string, query Queryable) error

+ UnsubscribeAll func(ctx context.Context, subscriber string) error

Nov 14, 2016

Changes in this version

+ func GenerateSubId() (string, error)

+ func GetRangeFilter(op, fName string) (func(a, b int64) bool, error)

+ func GetStringFilter(op, fName string) (func(s0, s1 string) bool, error)

+ func Multiplex(events ...EventEmitter) *multiplexedEvents

+ func NewEvents(eventSwitch *go_events.EventSwitch) *events

+ func ParseNumberValue(value string) (int64, error)

+ type CompositeFilter struct

+ func (this *CompositeFilter) Match(v interface{}) bool

+ func (this *CompositeFilter) SetData(filters []Filter)

+ type ConfigurableFilter interface

+ Configure func(*FilterData) error

+ type EventCache struct

+ type EventEmitter interface

+ Subscribe func(subId, event string, callback func(txs.EventData)) error

+ Unsubscribe func(subId string) error

+ type EventSub struct

+ SubId string

+ type EventSubscriptions struct

+ func NewEventSubscriptions(eventEmitter EventEmitter) *EventSubscriptions

+ func (this *EventSubscriptions) Add(eventId string) (string, error)

+ func (this *EventSubscriptions) Poll(subId string) ([]interface{}, error)

+ func (this *EventSubscriptions) Remove(subId string) error

+ type EventUnsub struct

+ Result bool

+ type Filter interface

+ Match func(v interface{}) bool

+ type FilterData struct

+ Field string

+ Op string

+ Value string

+ type FilterFactory struct

+ func NewFilterFactory() *FilterFactory

+ func (this *FilterFactory) NewFilter(fdArr []*FilterData) (Filter, error)

+ func (this *FilterFactory) RegisterFilterPool(fieldName string, pool *sync.Pool)

+ type MatchAllFilter struct

+ func (this *MatchAllFilter) Match(v interface{}) bool

+ type PollResponse struct

+ Events []interface{}