Versions in this module Expand all Collapse all v1 v1.1.0 Aug 16, 2024 Changes in this version + type Database interface + Abort func(database, table string) ovsdb.OperationResult + Assert func(database, table, lock string) ovsdb.OperationResult + Comment func(database, table string, comment string) ovsdb.OperationResult + Commit func(database, table string, durable bool) ovsdb.OperationResult + CreateDatabase func(name string, model *ovsdb.DatabaseSchema) error + Delete func(database, table string, where []ovsdb.Condition) (ovsdb.OperationResult, ovsdb.TableUpdates) + Exists func(name string) bool + Insert func(database string, table string, uuidName string, row ovsdb.Row) (ovsdb.OperationResult, ovsdb.TableUpdates) + Mutate func(database, table string, where []ovsdb.Condition, mutations []ovsdb.Mutation) (ovsdb.OperationResult, ovsdb.TableUpdates) + Select func(database string, table string, where []ovsdb.Condition, columns []string) ovsdb.OperationResult + Transact func(database string, operations []ovsdb.Operation) ([]ovsdb.OperationResult, ovsdb.TableUpdates) + Update func(database, table string, where []ovsdb.Condition, row ovsdb.Row) (ovsdb.OperationResult, ovsdb.TableUpdates) + Wait func(database, table string, timeout int, conditions []ovsdb.Condition, ...) ovsdb.OperationResult + func NewInMemoryDatabase(models map[string]*model.DBModel) Database + type DatabaseModel struct + Model *model.DBModel + Schema *ovsdb.DatabaseSchema + type OvsdbServer struct + func NewOvsdbServer(db Database, models ...DatabaseModel) (*OvsdbServer, error) + func (o *OvsdbServer) Cancel(client *rpc2.Client, args []interface{}, reply *[]interface{}) error + func (o *OvsdbServer) Close() + func (o *OvsdbServer) Echo(client *rpc2.Client, args []interface{}, reply *[]interface{}) error + func (o *OvsdbServer) GetSchema(client *rpc2.Client, args []interface{}, reply *ovsdb.DatabaseSchema) error + func (o *OvsdbServer) ListDatabases(client *rpc2.Client, args []interface{}, reply *[]string) error + func (o *OvsdbServer) Lock(client *rpc2.Client, args []interface{}, reply *[]interface{}) error + func (o *OvsdbServer) Monitor(client *rpc2.Client, args []json.RawMessage, reply *ovsdb.TableUpdates) error + func (o *OvsdbServer) MonitorCancel(client *rpc2.Client, args []interface{}, reply *[]interface{}) error + func (o *OvsdbServer) Ready() bool + func (o *OvsdbServer) Serve(protocol string, path string) error + func (o *OvsdbServer) Steal(client *rpc2.Client, args []interface{}, reply *[]interface{}) error + func (o *OvsdbServer) Transact(client *rpc2.Client, args []json.RawMessage, reply *[]ovsdb.OperationResult) error + func (o *OvsdbServer) Unlock(client *rpc2.Client, args []interface{}, reply *[]interface{}) error
Go to main page