consumer

Documentation

Index

• type EventAdapter
• type EventsClient
• type RegistrationConfig

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

type RegistrationConfig

type RegistrationConfig struct {
	InterestedEvents []*ehpb.Interest
	Timestamp        *timestamp.Timestamp
	TlsCert          *x509.Certificate
}

RegistrationConfig holds the information to be used when registering for events from the eventhub