consumer

Documentation

Index

• type EventAdapter
• type EventsClient

Types

type EventAdapter

type EventAdapter interface {
	GetInterestedEvents() ([]*peer.Interest, error)
	Recv(msg *peer.Event) (bool, error)
	Disconnected(err error)
}

EventAdapter is the interface by which a fabric event client registers interested events and receives messages from the fabric event Server

type EventsClient

type EventsClient struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

EventsClient holds the stream and adapter for consumer to work with