Documentation
¶
Overview ¶
PostgreSQL + Badger for storage.
Index ¶
- func Initialize(q IQueryable)
- func Maintainance(q IQueryable, current uint64)
- type CStuff
- func (i *CStuff) ArticleDirectGet(id []byte, head, body bool) *newspolyglot.ArticleObject
- func (i *CStuff) ArticleDirectOverview(id []byte) *newspolyglot.ArticleOverview
- func (i *CStuff) ArticleDirectRollback(id []byte)
- func (i *CStuff) ArticleDirectStat(id []byte) bool
- func (i *CStuff) ArticleDirectStore(exp uint64, ov *newspolyglot.ArticleOverview, obj *newspolyglot.ArticleObject) (err error)
- type IConn
- type IQueryable
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Initialize ¶
func Initialize(q IQueryable)
func Maintainance ¶
func Maintainance(q IQueryable, current uint64)
Types ¶
type CStuff ¶
type CStuff struct {
Q IQueryable
DB *badger.DB
}
func (*CStuff) ArticleDirectGet ¶
func (*CStuff) ArticleDirectOverview ¶
func (*CStuff) ArticleDirectRollback ¶
func (*CStuff) ArticleDirectStat ¶
func (*CStuff) ArticleDirectStore ¶
type IConn ¶
type IConn interface {
IQueryable
Begin() (*pgx.Tx, error)
BeginEx(ctx context.Context, txOptions *pgx.TxOptions) (*pgx.Tx, error)
}
Generically allows access to *Conn and *ConnPool
var _ IConn = (*pgx.ConnPool)(nil) var _ IConn = (*pgx.Conn)(nil)
type IQueryable ¶
type IQueryable interface {
BeginBatch() *pgx.Batch
CopyFrom(tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int, error)
CopyFromReader(r io.Reader, sql string) (commandTag pgx.CommandTag, err error)
CopyToWriter(w io.Writer, sql string, args ...interface{}) (commandTag pgx.CommandTag, err error)
Exec(sql string, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
ExecEx(ctx context.Context, sql string, options *pgx.QueryExOptions, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
Prepare(name, sql string) (*pgx.PreparedStatement, error)
PrepareEx(ctx context.Context, name, sql string, opts *pgx.PrepareExOptions) (*pgx.PreparedStatement, error)
Query(sql string, args ...interface{}) (*pgx.Rows, error)
QueryEx(ctx context.Context, sql string, options *pgx.QueryExOptions, args ...interface{}) (*pgx.Rows, error)
QueryRow(sql string, args ...interface{}) *pgx.Row
QueryRowEx(ctx context.Context, sql string, options *pgx.QueryExOptions, args ...interface{}) *pgx.Row
}
Generically allows access to *Tx, *Conn and *ConnPool
var _ IQueryable = (*pgx.ConnPool)(nil) var _ IQueryable = (*pgx.Conn)(nil) var _ IQueryable = (*pgx.Tx)(nil)
Source Files
Click to show internal directories.
Click to hide internal directories.