consumer

Documentation

Index

• type EventAdapter
• type OpenchainEventsClient
  • func NewOpenchainEventsClient(peerAddress string, adapter EventAdapter) *OpenchainEventsClient
  • func (ec *OpenchainEventsClient) Start() error
  • func (ec *OpenchainEventsClient) Stop() error

Types

type EventAdapter

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

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

type OpenchainEventsClient

type OpenchainEventsClient struct {
	// contains filtered or unexported fields
}

OpenchainEventsClient holds the stream and adapter for consumer to work with

func NewOpenchainEventsClient

func NewOpenchainEventsClient(peerAddress string, adapter EventAdapter) *OpenchainEventsClient

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

func (*OpenchainEventsClient) Start

func (ec *OpenchainEventsClient) Start() error

Start establishes connection with Event hub and registers interested events with it

func (*OpenchainEventsClient) Stop

func (ec *OpenchainEventsClient) Stop() error

Stop terminates connection with event hub