dbx

Documentation

Index

• func GetConn() *pgx.Conn
• func NewConn() (*pgx.Conn, error)
• type Connection
• type DBX
  • func Dbx() DBX
  • func (dbx DBX) Queries(q *db.Queries) QueriesX
• type Machine
• type QueriesX
  • func (r QueriesX) AddRoomMember(roomId misc.RoomId, connectionId misc.ConnectionId)
  • func (c QueriesX) CreateConnection(connectionId misc.ConnectionId, machineId misc.MachineId) error
  • func (c QueriesX) CreateMachine(machineId misc.MachineId, machineType string) error
  • func (r QueriesX) CreateRoom(roomId misc.RoomId, machineId misc.MachineId, name string, script string, ...) error
  • func (c QueriesX) DeleteConnection(connectionId misc.ConnectionId) error
  • func (c QueriesX) DeleteMachine(machineId misc.MachineId) error
  • func (r QueriesX) DeleteRoom(roomId misc.RoomId)
  • func (c QueriesX) FindMachine(id misc.ConnectionId) misc.MachineId
  • func (c QueriesX) GetConnections() ([]Connection, error)
  • func (c QueriesX) GetConnectionsByMachine(machineId misc.MachineId) ([]Connection, error)
  • func (c QueriesX) GetLeaderForType(machineType string) misc.MachineId
  • func (c QueriesX) GetMachine(machineId misc.MachineId) (Machine, error)
  • func (c QueriesX) GetMachines()
  • func (c QueriesX) GetMachinesByType(machineType string) ([]Machine, error)
  • func (r QueriesX) GetMembershipByConnection(connectionId misc.ConnectionId) ([]misc.ConnectionId, error)
  • func (r QueriesX) GetOrphanedRooms() ([]Room, error)
  • func (r QueriesX) GetRoomMembers(roomId misc.RoomId) ([]misc.ConnectionId, error)
  • func (r QueriesX) GetRooms() ([]Room, error)
  • func (r QueriesX) GetRoomsByMachine(machineId misc.MachineId) ([]Room, error)
  • func (c QueriesX) IsMachineOnline(machineId misc.MachineId) (bool, error)
  • func (r QueriesX) RemoveRoomMember(roomId misc.RoomId, connectionId misc.ConnectionId)
  • func (c QueriesX) SetMachineAsLeader(uuid misc.MachineId) error
  • func (r QueriesX) SetRoomOwner(roomId misc.RoomId, oldOwner misc.MachineId, newOwner misc.MachineId) error
  • func (c QueriesX) TouchConnection(connectionId misc.ConnectionId) error
  • func (c QueriesX) TouchMachine(machineId misc.MachineId) error
• type Room

Functions

func GetConn

func GetConn() *pgx.Conn

func NewConn

func NewConn() (*pgx.Conn, error)

Types

type Connection

type Connection struct {
	Uuid        misc.ConnectionId
	MachineUuid misc.MachineId
	CreatedAt   time.Time
	LastUpdated time.Time
}

type DBX

type DBX struct {
}

func Dbx

func Dbx() DBX

func (DBX) Queries

func (dbx DBX) Queries(q *db.Queries) QueriesX

type Machine

type Machine struct {
	Uuid        misc.MachineId
	MachineType string
	CreatedAt   time.Time
	LastUpdated time.Time
}

type QueriesX

type QueriesX struct {
	// contains filtered or unexported fields
}

func (QueriesX) AddRoomMember

func (r QueriesX) AddRoomMember(roomId misc.RoomId, connectionId misc.ConnectionId)

func (QueriesX) CreateConnection

func (c QueriesX) CreateConnection(connectionId misc.ConnectionId, machineId misc.MachineId) error

func (QueriesX) CreateMachine

func (c QueriesX) CreateMachine(machineId misc.MachineId, machineType string) error

func (QueriesX) CreateRoom

func (r QueriesX) CreateRoom(roomId misc.RoomId, machineId misc.MachineId, name string, script string, destroyOnOrphan bool) error

func (QueriesX) DeleteConnection

func (c QueriesX) DeleteConnection(connectionId misc.ConnectionId) error

func (QueriesX) DeleteMachine

func (c QueriesX) DeleteMachine(machineId misc.MachineId) error

func (QueriesX) DeleteRoom

func (r QueriesX) DeleteRoom(roomId misc.RoomId)

func (QueriesX) FindMachine

func (c QueriesX) FindMachine(id misc.ConnectionId) misc.MachineId

func (QueriesX) GetConnections

func (c QueriesX) GetConnections() ([]Connection, error)

func (QueriesX) GetConnectionsByMachine

func (c QueriesX) GetConnectionsByMachine(machineId misc.MachineId) ([]Connection, error)

func (QueriesX) GetLeaderForType

func (c QueriesX) GetLeaderForType(machineType string) misc.MachineId

func (QueriesX) GetMachine

func (c QueriesX) GetMachine(machineId misc.MachineId) (Machine, error)

func (QueriesX) GetMachines

func (c QueriesX) GetMachines()

func (QueriesX) GetMachinesByType

func (c QueriesX) GetMachinesByType(machineType string) ([]Machine, error)

func (QueriesX) GetMembershipByConnection

func (r QueriesX) GetMembershipByConnection(connectionId misc.ConnectionId) ([]misc.ConnectionId, error)

func (QueriesX) GetOrphanedRooms

func (r QueriesX) GetOrphanedRooms() ([]Room, error)

func (QueriesX) GetRoomMembers

func (r QueriesX) GetRoomMembers(roomId misc.RoomId) ([]misc.ConnectionId, error)

func (QueriesX) GetRooms

func (r QueriesX) GetRooms() ([]Room, error)

func (QueriesX) GetRoomsByMachine

func (r QueriesX) GetRoomsByMachine(machineId misc.MachineId) ([]Room, error)

func (QueriesX) IsMachineOnline

func (c QueriesX) IsMachineOnline(machineId misc.MachineId) (bool, error)

func (QueriesX) RemoveRoomMember

func (r QueriesX) RemoveRoomMember(roomId misc.RoomId, connectionId misc.ConnectionId)

func (QueriesX) SetMachineAsLeader

func (c QueriesX) SetMachineAsLeader(uuid misc.MachineId) error

func (QueriesX) SetRoomOwner

func (r QueriesX) SetRoomOwner(roomId misc.RoomId, oldOwner misc.MachineId, newOwner misc.MachineId) error

func (QueriesX) TouchConnection

func (c QueriesX) TouchConnection(connectionId misc.ConnectionId) error

func (QueriesX) TouchMachine

func (c QueriesX) TouchMachine(machineId misc.MachineId) error

type Room

type Room struct {
	Uuid            misc.RoomId
	MachineUuid     misc.MachineId
	Name            string
	Script          string
	DestroyOnOrphan bool
	CreatedAt       time.Time
	LastUpdated     time.Time
}