service

Jul 23, 2021

Changes in this version

+ func NewBlockConsumer(chainID string, projection *sqlsol.Projection, opt sqlsol.SpecOpt, ...) func(block chain.Block) error

+ type AbiProvider struct

+ func NewAbiProvider(paths []string, chain chain.Chain, logger *logging.Logger) (provider *AbiProvider, err error)

+ func (p *AbiProvider) GetEventAbi(eventID abi.EventID, address crypto.Address) (*abi.EventSpec, error)

type Consumer

+ Chain chain.Chain

+ Done chan struct{}

+ LastProcessedHeight uint64

+ Logger *logging.Logger

+ func (c *Consumer) StatusMessage(ctx context.Context) []interface{}

+ type EventSpecGetter func(abi.EventID, crypto.Address) (*abi.EventSpec, error)

Feb 27, 2019

Changes in this version

+ func UTF8StringFromBytes(bs []byte) (string, error)

+ type Consumer struct

+ Closing bool

+ Config *config.VentConfig

+ DB *sqldb.SQLDB

+ EventsChannel chan types.EventData

+ GRPCConnection *grpc.ClientConn

+ Log *logger.Logger

+ func NewConsumer(cfg *config.VentConfig, log *logger.Logger, eventChannel chan types.EventData) *Consumer

+ func (c *Consumer) Health() error

+ func (c *Consumer) Run(projection *sqlsol.Projection, abiSpec *abi.AbiSpec, stream bool) error

+ func (c *Consumer) Shutdown()

+ type Server struct

+ Config *config.VentConfig

+ Consumer *Consumer

+ Log *logger.Logger

+ func NewServer(cfg *config.VentConfig, log *logger.Logger, consumer *Consumer) *Server

+ func (s *Server) Run()

+ func (s *Server) ServeHTTP(resp http.ResponseWriter, req *http.Request)

+ func (s *Server) Shutdown()