consumer

Documentation

Index

• type EventsClient
  • func NewEventsClient(client fc.Client, peerAddress string, certificate string, ...) (EventsClient, error)

Types

type EventsClient

type EventsClient interface {
	RegisterAsync(ies []*ehpb.Interest) error
	UnregisterAsync(ies []*ehpb.Interest) error
	Unregister(ies []*ehpb.Interest) error
	Recv() (*ehpb.Event, error)
	Start() error
	Stop() error
}

EventsClient holds the stream and adapter for consumer to work with

func NewEventsClient

func NewEventsClient(client fc.Client, peerAddress string, certificate string, serverhostoverride string, regTimeout time.Duration, adapter consumer.EventAdapter) (EventsClient, error)

NewEventsClient Returns a new grpc.ClientConn to the configured local PEER.