Versions in this module Expand all Collapse all v2 v2.2.3 Apr 7, 2026 v2.2.2 Dec 15, 2025 v2.2.1 Oct 22, 2025 v2.2.0 Jun 26, 2025 v2.1.0 Dec 5, 2024 v2.0.5 Nov 6, 2024 v2.0.4 Oct 23, 2024 v2.0.3 Oct 9, 2024 v2.0.2 Aug 6, 2024 v2.0.1 Aug 2, 2024 v2.0.0 Jul 31, 2024 Changes in this version + func CoreClusterMemberExists(ctx context.Context, tx *sql.Tx, name string) (bool, error) + func CoreTokenRecordExists(ctx context.Context, tx *sql.Tx, secret string) (bool, error) + func CreateCoreClusterMember(ctx context.Context, tx *sql.Tx, object CoreClusterMember) (int64, error) + func CreateCoreTokenRecord(ctx context.Context, tx *sql.Tx, object CoreTokenRecord) (int64, error) + func DeleteCoreClusterMember(ctx context.Context, tx *sql.Tx, address string) error + func DeleteCoreTokenRecord(ctx context.Context, tx *sql.Tx, name string) error + func DeleteExpiredCoreTokenRecords(ctx context.Context, tx *sql.Tx) error + func GetCallerProject() string + func GetCoreClusterMemberID(ctx context.Context, tx *sql.Tx, name string) (int64, error) + func GetCoreTokenRecordID(ctx context.Context, tx *sql.Tx, secret string) (int64, error) + func PrepareStmts(db *sql.DB, project string, skipErrors bool) error + func RegisterStmt(sql string) int + func Stmt(tx *sql.Tx, code int) (*sql.Stmt, error) + func StmtString(code int) (string, error) + func UpdateCoreClusterMember(ctx context.Context, tx *sql.Tx, name string, object CoreClusterMember) error + type CoreClusterMember struct + APIExtensions extensions.Extensions + Address string + Certificate string + Heartbeat time.Time + ID int + Name string + Role Role + SchemaExternal uint64 + SchemaInternal uint64 + func GetCoreClusterMember(ctx context.Context, tx *sql.Tx, name string) (*CoreClusterMember, error) + func GetCoreClusterMembers(ctx context.Context, tx *sql.Tx, filters ...CoreClusterMemberFilter) ([]CoreClusterMember, error) + func GetUpgradingClusterMembers(ctx context.Context, tx *sql.Tx, schemaInternal uint64, schemaExternal uint64, ...) (allMembers []CoreClusterMember, awaitingMembers map[string]bool, err error) + func (c CoreClusterMember) ToAPI() (*types.ClusterMember, error) + type CoreClusterMemberFilter struct + Address *string + Name *string + type CoreTokenRecord struct + ExpiryDate sql.NullTime + ID int + Name string + Secret string + func GetCoreTokenRecord(ctx context.Context, tx *sql.Tx, secret string) (*CoreTokenRecord, error) + func GetCoreTokenRecords(ctx context.Context, tx *sql.Tx, filters ...CoreTokenRecordFilter) ([]CoreTokenRecord, error) + func (t *CoreTokenRecord) Expired() bool + func (t *CoreTokenRecord) ToAPI(clusterCert *x509.Certificate, joinAddresses []types.AddrPort) (*internalTypes.TokenRecord, error) + type CoreTokenRecordFilter struct + ID *int + Name *string + Secret *string + type DqliteMember struct + Address string + DqliteID uint64 + Name string + Role string + func (m DqliteMember) NodeInfo() (*dqlite.NodeInfo, error) + type Role string + const Pending + type Schema struct + ID int + UpdatedAt time.Time + Version int Other modules containing this package github.com/canonical/microcluster
Go to main page