table

Documentation

Index

• type Table
  • func New(source, tenantId, group string, inner dyndb.DynDB, handle *handle.Handle) *Table
  • func (t *Table) DeleteRow(txid uint32, req dyndb.DeleteRowReq) error
  • func (t *Table) DeleteRowBatch(txid uint32, req dyndb.DeleteRowBatchReq) ([]int64, error)
  • func (t *Table) DeleteRowMulti(txid uint32, req dyndb.DeleteRowMultiReq) error
  • func (t *Table) FTSQuery(txid uint32, req dyndb.FTSQueryReq) (*dyndb.QueryResult, error)
  • func (t *Table) GetRow(txid uint32, req dyndb.GetRowReq) (map[string]any, error)
  • func (t *Table) JoinQuery(txid uint32, req dyndb.JoinReq) (*dyndb.JoinResult, error)
  • func (t *Table) ListActivity(table string, rowId int) ([]*entities.DynActivity, error)
  • func (t *Table) ListActivityByAlt(table string, alt string) ([]*entities.DynActivity, error)
  • func (t *Table) LiveSeed(table, userId string, max int) error
  • func (t *Table) LoadTable(txid uint32, req dyndb.LoadTableReq) (*dyndb.LoadTableResp, error)
  • func (t *Table) MultiJoinQuery(txid uint32, req dyndb.MultiJoinReq) (*dyndb.MultiJoinResult, error)
  • func (t *Table) NewBatchRows(txid uint32, req dyndb.NewBatchRowReq) ([]int64, error)
  • func (t *Table) NewRow(txid uint32, req dyndb.NewRowReq) (int64, error)
  • func (t *Table) QueryActivity(table string, query *entities.ActivityQuery) ([]*entities.DynActivity, error)
  • func (t *Table) RefLoad(txid uint32, gslug string, req *dyndb.RefLoadReq) (*dyndb.QueryResult, error)
  • func (t *Table) RefResolve(txid uint32, gslug string, req *dyndb.RefResolveReq) (*dyndb.QueryResult, error)
  • func (t *Table) ReverseRefLoad(txid uint32, gslug string, req *dyndb.RevRefLoadReq) (*dyndb.QueryResult, error)
  • func (t *Table) SimpleQuery(txid uint32, req dyndb.SimpleQueryReq) (*dyndb.QueryResult, error)
  • func (t *Table) SqlQuery(txid uint32, req dyndb.SqlQueryReq) (*dyndb.SqlQueryResult, error)
  • func (t *Table) UpdateRow(txid uint32, req dyndb.UpdateRowReq) (map[string]any, error)

Types

type Table

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

func New

func New(source, tenantId, group string, inner dyndb.DynDB, handle *handle.Handle) *Table

func (*Table) DeleteRow

func (t *Table) DeleteRow(txid uint32, req dyndb.DeleteRowReq) error

func (*Table) DeleteRowBatch

func (t *Table) DeleteRowBatch(txid uint32, req dyndb.DeleteRowBatchReq) ([]int64, error)

func (*Table) DeleteRowMulti

func (t *Table) DeleteRowMulti(txid uint32, req dyndb.DeleteRowMultiReq) error

func (*Table) FTSQuery

func (t *Table) FTSQuery(txid uint32, req dyndb.FTSQueryReq) (*dyndb.QueryResult, error)

func (*Table) GetRow

func (t *Table) GetRow(txid uint32, req dyndb.GetRowReq) (map[string]any, error)

func (*Table) JoinQuery

func (t *Table) JoinQuery(txid uint32, req dyndb.JoinReq) (*dyndb.JoinResult, error)

func (*Table) ListActivity

func (t *Table) ListActivity(table string, rowId int) ([]*entities.DynActivity, error)

func (*Table) ListActivityByAlt

func (t *Table) ListActivityByAlt(table string, alt string) ([]*entities.DynActivity, error)

func (*Table) LiveSeed

func (t *Table) LiveSeed(table, userId string, max int) error

func (*Table) LoadTable

func (t *Table) LoadTable(txid uint32, req dyndb.LoadTableReq) (*dyndb.LoadTableResp, error)

func (*Table) MultiJoinQuery

func (t *Table) MultiJoinQuery(txid uint32, req dyndb.MultiJoinReq) (*dyndb.MultiJoinResult, error)

func (*Table) NewBatchRows

func (t *Table) NewBatchRows(txid uint32, req dyndb.NewBatchRowReq) ([]int64, error)

func (*Table) NewRow

func (t *Table) NewRow(txid uint32, req dyndb.NewRowReq) (int64, error)

func (*Table) QueryActivity

func (t *Table) QueryActivity(table string, query *entities.ActivityQuery) ([]*entities.DynActivity, error)

func (*Table) RefLoad

func (t *Table) RefLoad(txid uint32, gslug string, req *dyndb.RefLoadReq) (*dyndb.QueryResult, error)

func (*Table) RefResolve

func (t *Table) RefResolve(txid uint32, gslug string, req *dyndb.RefResolveReq) (*dyndb.QueryResult, error)

func (*Table) ReverseRefLoad

func (t *Table) ReverseRefLoad(txid uint32, gslug string, req *dyndb.RevRefLoadReq) (*dyndb.QueryResult, error)

func (*Table) SimpleQuery

func (t *Table) SimpleQuery(txid uint32, req dyndb.SimpleQueryReq) (*dyndb.QueryResult, error)

func (*Table) SqlQuery

func (t *Table) SqlQuery(txid uint32, req dyndb.SqlQueryReq) (*dyndb.SqlQueryResult, error)

func (*Table) UpdateRow

func (t *Table) UpdateRow(txid uint32, req dyndb.UpdateRowReq) (map[string]any, error)