services

Documentation

Index

• func Start(ctx context.Context, db *sqlx.DB, lightningRequestChannel chan interface{}, ...) error
• func StartCronService(ctx context.Context, db *sqlx.DB) error
• func StartLightningCommunicationService(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int, ...) error
• func StartMaintenanceService(ctx context.Context, db *sqlx.DB, vectorUrl string, ...) error
• func StartRebalanceService(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int, ...) error

Functions

func Start

func Start(ctx context.Context, db *sqlx.DB,
	lightningRequestChannel chan interface{},
	rebalanceRequestChannel chan commons.RebalanceRequest,
	broadcaster broadcast.BroadcastServer) error

func StartCronService

func StartCronService(ctx context.Context, db *sqlx.DB) error

func StartLightningCommunicationService

func StartLightningCommunicationService(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int,
	broadcaster broadcast.BroadcastServer) error

func StartMaintenanceService

func StartMaintenanceService(ctx context.Context, db *sqlx.DB, vectorUrl string, lightningRequestChannel chan interface{}) error

func StartRebalanceService

func StartRebalanceService(ctx context.Context, conn *grpc.ClientConn, db *sqlx.DB, nodeId int,
	broadcaster broadcast.BroadcastServer) error