dqlite

package

v0.0.0-...-1b2443f Latest Latest Go to latest Published: May 4, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/caesium-cloud/caesium

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ClusterNodes(ctx context.Context) ([]client.NodeInfo, error)
func IsLocalLeader(ctx context.Context) (bool, error)
func Open(dsn string) gorm.Dialector
type ClusterNode
- func Cluster(ctx context.Context) ([]ClusterNode, error)
type Dialector
type Migrator

Constants ¶

View Source

const (
	// DriverName is the default driver name for dqlite.
	DriverName = "dqlite"
)

Variables ¶

View Source

var (
	ErrNoNativeApp = errors.New("dqlite: native app is not active")
)

Functions ¶

func ClusterNodes ¶

func ClusterNodes(ctx context.Context) ([]client.NodeInfo, error)

ClusterNodes returns the current list of nodes in the dqlite cluster.

func IsLocalLeader ¶

func IsLocalLeader(ctx context.Context) (bool, error)

IsLocalLeader reports whether this process hosts the current dqlite leader.

func Open ¶

func Open(dsn string) gorm.Dialector

Types ¶

type ClusterNode ¶

type ClusterNode struct {
	ID       uint64
	Address  string
	Role     string
	IsLeader bool
}

ClusterNode is a dqlite cluster member visible to the current native app.

func Cluster ¶

func Cluster(ctx context.Context) ([]ClusterNode, error)

Cluster returns the current dqlite cluster membership from the leader.

type Dialector ¶

type Dialector struct {
	DriverName string
	DSN        string
	Conn       gorm.ConnPool
}

func (Dialector) BindVarTo ¶

func (dialector Dialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{})

func (Dialector) ClauseBuilders ¶

func (dialector Dialector) ClauseBuilders() map[string]clause.ClauseBuilder

func (Dialector) DataTypeOf ¶

func (dialector Dialector) DataTypeOf(field *schema.Field) string

func (Dialector) DefaultValueOf ¶

func (dialector Dialector) DefaultValueOf(field *schema.Field) clause.Expression

func (Dialector) Explain ¶

func (dialector Dialector) Explain(sql string, vars ...interface{}) string

func (Dialector) Initialize ¶

func (dialector Dialector) Initialize(db *gorm.DB) (err error)

func (Dialector) Migrator ¶

func (dialector Dialector) Migrator(db *gorm.DB) gorm.Migrator

func (Dialector) Name ¶

func (dialector Dialector) Name() string

func (Dialector) QuoteTo ¶

func (dialector Dialector) QuoteTo(writer clause.Writer, str string)

func (Dialector) RollbackTo ¶

func (dialectopr Dialector) RollbackTo(tx *gorm.DB, name string) error

func (Dialector) SavePoint ¶

func (dialectopr Dialector) SavePoint(tx *gorm.DB, name string) error

type Migrator ¶

type Migrator struct {
	migrator.Migrator
}

func (Migrator) AlterColumn ¶

func (m Migrator) AlterColumn(value interface{}, name string) error

func (Migrator) BuildIndexOptions ¶

func (m Migrator) BuildIndexOptions(opts []schema.IndexOption, stmt *gorm.Statement) (results []interface{})

func (Migrator) CreateConstraint ¶

func (m Migrator) CreateConstraint(value interface{}, name string) error

func (Migrator) CreateIndex ¶

func (m Migrator) CreateIndex(value interface{}, name string) error

func (Migrator) CurrentDatabase ¶

func (m Migrator) CurrentDatabase() (name string)

func (Migrator) DropColumn ¶

func (m Migrator) DropColumn(value interface{}, name string) error

func (Migrator) DropConstraint ¶

func (m Migrator) DropConstraint(value interface{}, name string) error

func (Migrator) DropIndex ¶

func (m Migrator) DropIndex(value interface{}, name string) error

func (Migrator) DropTable ¶

func (m Migrator) DropTable(values ...interface{}) error

func (Migrator) HasColumn ¶

func (m Migrator) HasColumn(value interface{}, name string) bool

func (Migrator) HasConstraint ¶

func (m Migrator) HasConstraint(value interface{}, name string) bool

func (Migrator) HasIndex ¶

func (m Migrator) HasIndex(value interface{}, name string) bool

func (Migrator) HasTable ¶

func (m Migrator) HasTable(value interface{}) bool

func (Migrator) RenameIndex ¶

func (m Migrator) RenameIndex(value interface{}, oldName, newName string) error

func (*Migrator) RunWithoutForeignKey ¶

func (m *Migrator) RunWithoutForeignKey(fc func() error) error

Source Files ¶

View all Source files

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