subscribe

Documentation

Index

• func Start(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int, ...) error

Functions

func Start

func Start(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int, broadcaster broadcast.BroadcastServer,
	eventChannel chan interface{}, serviceChannel chan commons.ServiceChannelMessage) error

Start runs the background server. It subscribes to events, gossip and fetches data as needed and stores it in the database. It is meant to run as a background task / daemon and is the bases for all of Torqs data collection