storage

package

Go to main page

Versions in this module

v0

v0.3.1

Nov 23, 2023

v0.3.0

Nov 22, 2023

Changes in this version

+ const PREFIX_CLIENT_CONFIG

+ const REGEX_DB_URL

+ var CheckPoolColumn = ...

+ var CheckoutCluster = ...

+ var CreateAnyTable = ...

+ var CreateAuditTable = ...

+ var CreateClientsTable = ...

+ var CreateClustersTable = ...

+ var CreateContainersTable = ...

+ var CreateHostsTable = ...

+ var CreateMonitorTable = ...

+ var CreatePlaygroundTable = ...

+ var CreateVersionTable = ...

+ var DeleteAnyItem = `DELETE from any WHERE id = ?`

+ var DeleteClient = `DELETE from clients WHERE id = ?`

+ var DeleteCluster = `DELETE from clusters WHERE name = ?`

+ var DeleteMonitor = `DELETE FROM monitors WHERE cluster_id = ?`

+ var DeletePlayground = `DELETE from playgrounds WHERE name = ?`

+ var DropOldClustersTable = `DROP TABLE clusters_old`

+ var ErrInvalidDBUrl = fmt.Errorf("invalid database url")

+ var GetCurrentCluster = `SELECT * FROM clusters WHERE current = 1`

+ var InsertAnyItem = `INSERT INTO any(id, data) VALUES(?, ?)`

+ var InsertAuditLog = ...

+ var InsertClient = `INSERT INTO clients(id, kind, host, container_id, aux_info) VALUES(?, ?, ?, ?, ?)`

+ var InsertCluster = ...

+ var InsertClustersFromOldTable = ...

+ var InsertHosts = `INSERT INTO hosts(data, lastmodified_time) VALUES(?, datetime('now','localtime'))`

+ var InsertMonitor = `INSERT INTO monitors(cluster_id, monitor) VALUES(?, ?)`

+ var InsertPlayground = ...

+ var InsertService = `INSERT INTO containers(id, cluster_id, container_id) VALUES(?, ?, ?)`

+ var InsertVersion = `INSERT INTO version(version, lastconfirm) VALUES(?, "")`

+ var RenameClustersTable = `ALTER TABLE clusters RENAME TO clusters_old`

+ var ReplaceMonitor = `REPLACE INTO monitors (cluster_id, monitor) VALUES(?, ?)`

+ var SelectAnyItem = `SELECT * FROM any WHERE id = ?`

+ var SelectAuditLog = `SELECT * FROM audit`

+ var SelectAuditLogById = `SELECT * FROM audit WHERE id = ?`

+ var SelectClientById = `SELECT * FROM clients WHERE id = ?`

+ var SelectClients = `SELECT * FROM clients`

+ var SelectCluster = `SELECT * FROM clusters WHERE name LIKE ?`

+ var SelectHosts = `SELECT * FROM hosts`

+ var SelectMonitor = `SELECT monitor FROM monitors WHERE cluster_id = ?`

+ var SelectPlayground = `SELECT * FROM playgrounds WHERE name LIKE ?`

+ var SelectPlaygroundById = `SELECT * FROM playgrounds WHERE id = ?`

+ var SelectService = `SELECT * FROM containers WHERE id = ?`

+ var SelectServicesInCluster = `SELECT * FROM containers WHERE cluster_id = ?`

+ var SelectVersion = `SELECT * FROM version`

+ var SetAnyItem = `UPDATE any SET data = ? WHERE id = ?`

+ var SetAuditLogStatus = `UPDATE audit SET status = ?, error_code = ? WHERE id = ?`

+ var SetClientAuxInfo = `UPDATE clients SET aux_info = ? WHERE id = ?`

+ var SetClusterPool = `UPDATE clusters SET topology = ?, pool = ? WHERE id = ?`

+ var SetClusterTopology = `UPDATE clusters SET topology = ? WHERE id = ?`

+ var SetContainerId = `UPDATE containers SET container_id = ? WHERE id = ?`

+ var SetHosts = `UPDATE hosts SET data = ?, lastmodified_time = datetime('now','localtime') WHERE id = ?`

+ var SetPlaygroundStatus = `UPDATE playgrounds SET status = ? WHERE name = ?`

+ var SetVersion = `UPDATE version SET version = ?, lastconfirm = ? WHERE id = ?`

+ var UpdateMonitor = `UPDATE monitors SET monitor = ? WHERE cluster_id = ?`

+ type Any struct

+ Data string

+ Id string

type Hosts

+ LastModifiedTime time.Time

+ type Monitor struct

+ ClusterId int

+ Monitor string

type Storage

+ func (s *Storage) DeleteClientConfig(id string) error

+ func (s *Storage) DeleteMonitor(clusterId int) error

+ func (s *Storage) GetClientConfig(id string) ([]Any, error)

+ func (s *Storage) GetMonitor(clusterId int) (Monitor, error)

+ func (s *Storage) InsertClientConfig(id, data string) error

+ func (s *Storage) InsertMonitor(m Monitor) error

+ func (s *Storage) ReplaceMonitor(m Monitor) error

+ func (s *Storage) SetClientAuxInfo(id, auxInfo string) error

+ func (s *Storage) UpdateMonitor(m Monitor) error

v0.2.1

Nov 22, 2023

v0.2.0

Feb 22, 2023

Changes in this version

+ var CREATE_VERSION_TABLE = ...

+ var INSERT_VERSION = `INSERT INTO version(version, lastconfirm) VALUES(?, "")`

+ var SELECT_PLAYGROUND_BY_ID = `SELECT * FROM playgrounds WHERE id = ?`

+ var SELECT_VERSION = `SELECT * FROM version`

+ var SET_VERSION = `UPDATE version SET version = ?, lastconfirm = ? WHERE id = ?`

type Storage

+ func (s *Storage) GetPlaygroundById(id string) ([]Playground, error)

+ func (s *Storage) GetVersions() ([]Version, error)

+ func (s *Storage) SetVersion(version, lastConfirm string) error

+ type Version struct

+ Id int

+ LastConfirm string

+ Version string

v0.1.0

Aug 16, 2022

Changes in this version

+ var CREATE_CLIENTS_TABLE = ...

+ var CREATE_HOSTS_TABLE = ...

+ var DELETE_CLIENT = `DELETE from clients WHERE id = ?`

+ var INSERT_CLIENT = `INSERT INTO clients(id, kind, host, container_id, aux_info) VALUES(?, ?, ?, ?, ?)`

+ var INSERT_HOSTS = `INSERT INTO hosts(data, lastmodified_time) VALUES(?, datetime('now','localtime'))`

+ var SELECT_AUDIT_LOG_BY_ID = `SELECT * FROM audit WHERE id = ?`

+ var SELECT_CLIENTS = `SELECT * FROM clients`

+ var SELECT_CLIENT_BY_ID = `SELECT * FROM clients WHERE id = ?`

+ var SELECT_HOSTS = `SELECT * FROM hosts`

+ var SET_AUDIT_LOG_STATUS = `UPDATE audit SET status = ?, error_code = ? WHERE id = ?`

+ var SET_HOSTS = `UPDATE hosts SET data = ?, lastmodified_time = datetime('now','localtime') WHERE id = ?`

type AuditLog

+ ErrorCode int

+ Status int

+ WorkDirectory string

+ type Client struct

+ AuxInfo string

+ ContainerId string

+ Host string

+ Id string

+ Kind string

+ type Hosts struct

+ Data string

+ Id int

+ LastmodifiedTime time.Time

type Storage

+ func (s *Storage) DeleteClient(id string) error

+ func (s *Storage) GetAuditLog(id int64) ([]AuditLog, error)

+ func (s *Storage) GetClient(id string) ([]Client, error)

+ func (s *Storage) GetClientContainerId(id string) (string, error)

+ func (s *Storage) GetClients() ([]Client, error)

+ func (s *Storage) GetHostses() ([]Hosts, error)

+ func (s *Storage) InsertClient(id, kind, host, containerId, auxInfo string) error

+ func (s *Storage) SetAuditLogStatus(id int64, status, errorCode int) error

+ func (s *Storage) SetHosts(data string) error

v0.0.25

Jun 27, 2022

Changes in this version

+ var CREATE_PLAYGROUND_TABLE = ...

+ var DELETE_PLAYGROUND = `DELETE from playgrounds WHERE name = ?`

+ var INSERT_PLAYGROUND = ...

+ var SELECT_PLAYGROUND = `SELECT * FROM playgrounds WHERE name LIKE ?`

+ var SET_PLAYGROUND_STATUS = `UPDATE playgrounds SET status = ? WHERE name = ?`

+ type Playground struct

+ CreateTime time.Time

+ Id int

+ MountPoint string

+ Name string

+ Status string

type Storage

+ func (s *Storage) DeletePlayground(name string) error

+ func (s *Storage) GetPlaygrounds(name string) ([]Playground, error)

+ func (s *Storage) InsertPlayground(name, mountPoint, status string) error

+ func (s *Storage) SetPlaygroundStatus(name, status string) error

v0.0.23

Jun 22, 2022

Changes in this version

+ var CHECK_POOl_COLUMN = ...

+ var CREATE_AUDIT_TABLE = ...

+ var INSERT_AUDIT_LOG = `INSERT INTO audit(execute_time, command, success) VALUES(?, ?, ?)`

+ var SELECT_AUDIT_LOG = `SELECT * FROM audit`

+ var SET_CLUSTER_POOL = `UPDATE clusters SET pool = ? WHERE id = ?`

+ type AuditLog struct

+ Command string

+ ExecuteTime time.Time

+ Id int

+ Success bool

type Cluster

+ Pool string

type Storage

+ func (s *Storage) GetAuditLogs() ([]AuditLog, error)

+ func (s *Storage) InsertAuditLog(time time.Time, command string, success bool) error

+ func (s *Storage) SetClusterPool(id int, pool string) error

v0.0.22

Mar 15, 2022

Changes in this version

+ var CHECKOUT_CLUSTER = ...

+ var CHECK_UUID_COLUMN = ...

+ var CREATE_CLUSTERS_TABLE = ...

+ var CREATE_CONTAINERS_TABLE = ...

+ var DELETE_CLUSTER = `DELETE from clusters WHERE name = ?`

+ var DROP_OLD_CLUSTERS_TABLE = `DROP TABLE clusters_old`

+ var GET_CURRENT_CLUSTER = `SELECT * FROM clusters WHERE current = 1`

+ var INSERT_CLUSTER = ...

+ var INSERT_CLUSTERS_FROM_OLD_TABLE = ...

+ var INSERT_SERVICE = `INSERT INTO containers(id, cluster_id, container_id) VALUES(?, ?, ?)`

+ var RENAME_CLUSTERS_TABLE = `ALTER TABLE clusters RENAME TO clusters_old`

+ var SELECT_CLUSTER = `SELECT * FROM clusters WHERE name LIKE ?`

+ var SELECT_SERVICE = `SELECT * FROM containers WHERE id = ?`

+ var SELECT_SERVICE_IN_CLUSTER = `SELECT * FROM containers WHERE cluster_id = ?`

+ var SET_CLUSTER_TOPOLOGY = `UPDATE clusters SET topology = ? WHERE id = ?`

+ var SET_CONTAINER_ID = `UPDATE containers SET container_id = ? WHERE id = ?`

+ type Cluster struct

+ CreateTime time.Time

+ Current bool

+ Description string

+ Id int

+ Name string

+ Topology string

+ UUId string

+ type Service struct

+ ClusterId int

+ ContainerId string

+ Id string

+ type Storage struct

+ func NewStorage(dbfile string) (*Storage, error)

+ func (s *Storage) CheckoutCluster(name string) error

+ func (s *Storage) Close() error

+ func (s *Storage) DeleteCluster(name string) error

+ func (s *Storage) GetClusters(name string) ([]Cluster, error)

+ func (s *Storage) GetContainerId(serviceId string) (string, error)

+ func (s *Storage) GetCurrentCluster() (Cluster, error)

+ func (s *Storage) GetServices(clusterId int) ([]Service, error)

+ func (s *Storage) InsertCluster(name, description, topology string) error

+ func (s *Storage) InsertService(clusterId int, serviceId, containerId string) error

+ func (s *Storage) SetClusterTopology(id int, topology string) error

+ func (s *Storage) SetContainId(serviceId, containerId string) error

v0.0.12

Jan 17, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL