settings

Documentation

Index

• 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 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)
• type NodeConnectionDetails
  • func AddNodeToDB(db *sqlx.DB, implementation commons.Implementation, grpcAddress string, ...) (NodeConnectionDetails, error)
  • func SetNodeConnectionDetails(db *sqlx.DB, ncd NodeConnectionDetails) (NodeConnectionDetails, error)
  • func (ncd *NodeConnectionDetails) AddNotificationType(pingSystem commons.PingSystem)
  • func (ncd *NodeConnectionDetails) HasNotificationType(pingSystem commons.PingSystem) bool
  • func (ncd *NodeConnectionDetails) RemoveNotificationType(pingSystem commons.PingSystem)

Functions

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 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)

type NodeConnectionDetails

type NodeConnectionDetails struct {
	NodeId            int                    `json:"nodeId" form:"nodeId" db:"node_id"`
	Name              string                 `json:"name" form:"name" db:"name"`
	Implementation    commons.Implementation `json:"implementation" form:"implementation" db:"implementation"`
	GRPCAddress       *string                `json:"grpcAddress" form:"grpcAddress" db:"grpc_address"`
	TLSFileName       *string                `json:"tlsFileName" db:"tls_file_name"`
	TLSDataBytes      []byte                 `db:"tls_data"`
	TLSFile           *multipart.FileHeader  `form:"tlsFile"`
	MacaroonFileName  *string                `json:"macaroonFileName" db:"macaroon_file_name"`
	MacaroonDataBytes []byte                 `db:"macaroon_data"`
	MacaroonFile      *multipart.FileHeader  `form:"macaroonFile"`
	Status            commons.Status         `json:"status" db:"status_id"`
	PingSystem        commons.PingSystem     `json:"pingSystem" db:"ping_system"`
	CreateOn          time.Time              `json:"createdOn" db:"created_on"`
	UpdatedOn         *time.Time             `json:"updatedOn"  db:"updated_on"`
}

func AddNodeToDB

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

func SetNodeConnectionDetails

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

func (*NodeConnectionDetails) AddNotificationType

func (ncd *NodeConnectionDetails) AddNotificationType(pingSystem commons.PingSystem)

func (*NodeConnectionDetails) HasNotificationType

func (ncd *NodeConnectionDetails) HasNotificationType(pingSystem commons.PingSystem) bool

func (*NodeConnectionDetails) RemoveNotificationType

func (ncd *NodeConnectionDetails) RemoveNotificationType(pingSystem commons.PingSystem)