observer

Documentation

Overview

Package observer launches a service attached to the sharding node that simply observes activity across the sharded Ethereum network.

Index

• type Observer
  • func NewObserver(p2p *p2p.Server, dbService *database.ShardDB, shardID int, sync *syncer.Syncer, ...) (*Observer, error)
  • func (o *Observer) Start()
  • func (o *Observer) Stop() error

Types

type Observer

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

Observer holds functionality required to run an observer service in a sharded system. Must satisfy the Service interface defined in sharding/service.go.

func NewObserver

func NewObserver(p2p *p2p.Server, dbService *database.ShardDB, shardID int, sync *syncer.Syncer, client *mainchain.VRCClient) (*Observer, error)

NewObserver creates a struct instance of a observer service, it will have access to a p2p server and a shardChainDB.

func (*Observer) Start

func (o *Observer) Start()

Start the main loop for observer service.

func (*Observer) Stop

func (o *Observer) Stop() error

Stop the main loop for observer service.