settings

Documentation

Index

• func AddNodeToDB(db *sqlx.DB, implementation commons.Implementation, grpcAddress string, ...) (nodeConnectionDetails, error)
• func GetNodeIdByGRPC(db *sqlx.DB, grpcAddress string) (int, error)
• func InitializeManagedNodeCache(db *sqlx.DB) error
• func InitializeManagedSettingsCache(db *sqlx.DB) error
• func RegisterSettingRoutes(r *gin.RouterGroup, db *sqlx.DB, ...)
• func RegisterUnauthenticatedRoutes(r *gin.RouterGroup, db *sqlx.DB)
• func SetNodeConnectionDetails(db *sqlx.DB, ncd nodeConnectionDetails) (nodeConnectionDetails, error)
• func SetNodeConnectionDetailsByConnectionDetails(db *sqlx.DB, nodeId int, status commons.Status, grpcAddress string, ...) error
• type ConnectionDetails
  • func GetActiveNodesConnectionDetails(db *sqlx.DB) ([]ConnectionDetails, error)
  • func GetAmbossPingNodesConnectionDetails(db *sqlx.DB) ([]ConnectionDetails, error)
  • func GetConnectionDetailsById(db *sqlx.DB, nodeId int) (ConnectionDetails, error)
  • func GetVectorPingNodesConnectionDetails(db *sqlx.DB) ([]ConnectionDetails, error)
  • func (connectionDetails *ConnectionDetails) AddPingSystem(pingSystem commons.PingSystem)
  • func (connectionDetails *ConnectionDetails) HasPingSystem(pingSystem commons.PingSystem) bool
  • func (connectionDetails *ConnectionDetails) RemovePingSystem(pingSystem commons.PingSystem)

Functions

func AddNodeToDB

func AddNodeToDB(db *sqlx.DB, implementation commons.Implementation,
	grpcAddress string, tlsDataBytes []byte, macaroonDataBytes []byte) (nodeConnectionDetails, error)

func GetNodeIdByGRPC

func GetNodeIdByGRPC(db *sqlx.DB, grpcAddress string) (int, error)

func InitializeManagedNodeCache

func InitializeManagedNodeCache(db *sqlx.DB) error

func InitializeManagedSettingsCache

func InitializeManagedSettingsCache(db *sqlx.DB) error

func RegisterSettingRoutes

func RegisterSettingRoutes(r *gin.RouterGroup, db *sqlx.DB, serviceChannel chan commons.ServiceChannelMessage)

func RegisterUnauthenticatedRoutes

func RegisterUnauthenticatedRoutes(r *gin.RouterGroup, db *sqlx.DB)

func SetNodeConnectionDetails

func SetNodeConnectionDetails(db *sqlx.DB, ncd nodeConnectionDetails) (nodeConnectionDetails, error)

func SetNodeConnectionDetailsByConnectionDetails

func SetNodeConnectionDetailsByConnectionDetails(
	db *sqlx.DB,
	nodeId int,
	status commons.Status,
	grpcAddress string,
	tlsDataBytes []byte,
	macaroonDataBytes []byte) error

Types

type ConnectionDetails

type ConnectionDetails struct {
	NodeId            int
	Name              string
	GRPCAddress       string
	TLSFileBytes      []byte
	MacaroonFileBytes []byte
	Status            commons.Status
	PingSystem        commons.PingSystem
}

func GetActiveNodesConnectionDetails

func GetActiveNodesConnectionDetails(db *sqlx.DB) ([]ConnectionDetails, error)

func GetAmbossPingNodesConnectionDetails

func GetAmbossPingNodesConnectionDetails(db *sqlx.DB) ([]ConnectionDetails, error)

func GetConnectionDetailsById

func GetConnectionDetailsById(db *sqlx.DB, nodeId int) (ConnectionDetails, error)

GetConnectionDetailsById will still fetch details even if node is disabled or deleted

func GetVectorPingNodesConnectionDetails

func GetVectorPingNodesConnectionDetails(db *sqlx.DB) ([]ConnectionDetails, error)

func (*ConnectionDetails) AddPingSystem

func (connectionDetails *ConnectionDetails) AddPingSystem(pingSystem commons.PingSystem)

func (*ConnectionDetails) HasPingSystem

func (connectionDetails *ConnectionDetails) HasPingSystem(pingSystem commons.PingSystem) bool

func (*ConnectionDetails) RemovePingSystem

func (connectionDetails *ConnectionDetails) RemovePingSystem(pingSystem commons.PingSystem)