Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.7.0

Jul 10, 2024

Changes in this version

type OvsdbServer

+ func (o *OvsdbServer) DoEcho(ok bool)

+ func (o *OvsdbServer) MonitorCond(client *rpc2.Client, args []json.RawMessage, reply *ovsdb.TableUpdates2) error

+ func (o *OvsdbServer) MonitorCondSince(client *rpc2.Client, args []json.RawMessage, ...) error

+ func (o *OvsdbServer) OnConnect(f func(*rpc2.Client))

+ func (o *OvsdbServer) OnDisConnect(f func(*rpc2.Client))

v0.6.0

Jul 9, 2021

v0.4.0

Jun 11, 2021

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