appspacedb

Documentation

Index

• type AppspaceDB
  • func (a *AppspaceDB) CloseAppspace(appspaceID domain.AppspaceID)
  • func (a *AppspaceDB) Init()
• type ConnManager
  • func (m *ConnManager) Init(appspacesPath string)
• type V0
  • func (v *V0) GetService(appspace *domain.Appspace) domain.ReverseServiceI
  • func (v *V0) Run(appspace *domain.Appspace, dbName string, qData domain.V0AppspaceDBQuery) ([]byte, error)
• type V0Service
  • func (s *V0Service) HandleMessage(message twine.ReceivedMessageI)

Types

type AppspaceDB

type AppspaceDB struct {
	Config *domain.RuntimeConfig `checkinject:"required"`
	V0     *V0
	// contains filtered or unexported fields
}

AppspaceDB holds various api versions of AppspaceDB

func (*AppspaceDB) CloseAppspace

func (a *AppspaceDB) CloseAppspace(appspaceID domain.AppspaceID)

CloseAppspace closes all appsace DBs

func (*AppspaceDB) Init

func (a *AppspaceDB) Init()

Init creates the versions of appspace db

type ConnManager

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

ConnManager keeps tabs on open conns and can open more or close them

func (*ConnManager) Init

func (m *ConnManager) Init(appspacesPath string)

Init makes the necessary maps

type V0

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

V0 is the appspace db interface at dropserver API version 0

func (*V0) GetService

func (v *V0) GetService(appspace *domain.Appspace) domain.ReverseServiceI

GetService returns a twine service for the appspace

func (*V0) Run

func (v *V0) Run(appspace *domain.Appspace, dbName string, qData domain.V0AppspaceDBQuery) ([]byte, error)

Run a query on the appspace db Not sure at all how to handle the return values How do we enable sending back a series of row datas, or something like that? Returning a []byte seems a bit contrived. Maybe an additional parameter? Or....?

type V0Service

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

V0Service is a twine service for a given appspace.

func (*V0Service) HandleMessage

func (s *V0Service) HandleMessage(message twine.ReceivedMessageI)

HandleMessage takes a twine message and performs the desired op