events

Documentation

Index

• type LogEventManager
  • func NewLogEventManager(serviceLocator logSubsServiceLocator, logger gethlog.Logger) *LogEventManager
  • func (l *LogEventManager) HealthStatus(context.Context) host.HealthStatus
  • func (l *LogEventManager) SendLogsToSubscribers(result *common.EncryptedSubscriptionLogs)
  • func (l *LogEventManager) Start() error
  • func (l *LogEventManager) Stop() error
  • func (l *LogEventManager) Subscribe(id rpc.ID, encryptedLogSubscription common.EncryptedParamsLogSubscription, ...) error
  • func (l *LogEventManager) Unsubscribe(id rpc.ID)

Types

type LogEventManager

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

LogEventManager manages the routing of logs back to their subscribers. todo (@matt) currently, this operates as a service but maybe it would make more sense to be owned by enclave service?

func NewLogEventManager

func NewLogEventManager(serviceLocator logSubsServiceLocator, logger gethlog.Logger) *LogEventManager

func (*LogEventManager) HealthStatus

func (l *LogEventManager) HealthStatus(context.Context) host.HealthStatus

func (*LogEventManager) SendLogsToSubscribers

func (l *LogEventManager) SendLogsToSubscribers(result *common.EncryptedSubscriptionLogs)

SendLogsToSubscribers distributes logs to subscribed clients.

func (*LogEventManager) Start

func (l *LogEventManager) Start() error

func (*LogEventManager) Stop

func (l *LogEventManager) Stop() error

func (*LogEventManager) Subscribe

func (l *LogEventManager) Subscribe(id rpc.ID, encryptedLogSubscription common.EncryptedParamsLogSubscription, matchedLogsCh chan []byte) error

func (*LogEventManager) Unsubscribe

func (l *LogEventManager) Unsubscribe(id rpc.ID)