consumer

Jul 11, 2017

Changes in this version

+ type EventAdapter interface

+ Disconnected func(err error)

+ GetInterestedEvents func() ([]*peer.Interest, error)

+ Recv func(msg *peer.Event) (bool, error)

+ type EventsClient struct

+ func NewEventsClient(peerAddress string, regTimeout time.Duration, adapter EventAdapter) (*EventsClient, error)

+ func (ec *EventsClient) Recv() (*ehpb.Event, error)

+ func (ec *EventsClient) RegisterAsync(ies []*ehpb.Interest) error

+ func (ec *EventsClient) Start() error

+ func (ec *EventsClient) Stop() error

+ func (ec *EventsClient) UnregisterAsync(ies []*ehpb.Interest) error