Documentation ¶
Index ¶
- type DB
- func (d *DB) Fetch(ctx context.Context, req *plutodbpb.FetchRequest) (resp *plutodbpb.FetchResponse, err error)
- func (d *DB) GetHistory(ctx context.Context, req *plutodbpb.GetHistoryRequest) (resp *plutodbpb.GetHistoryResponse, _ error)
- func (d *DB) GetTxnMulti(ctx context.Context, req *plutodbpb.GetTxnMultiRequest) (*plutodbpb.GetTxnMultiResponse, error)
- func (d *DB) Push(ctx context.Context, txns []pt.Txn) (err error)
- func (d *DB) PushSettings(ctx context.Context, sett *pt.Settings) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DB ¶
type DB struct {
// contains filtered or unexported fields
}
func (*DB) Fetch ¶
func (d *DB) Fetch(ctx context.Context, req *plutodbpb.FetchRequest) (resp *plutodbpb.FetchResponse, err error)
func (*DB) GetHistory ¶
func (d *DB) GetHistory(ctx context.Context, req *plutodbpb.GetHistoryRequest) (resp *plutodbpb.GetHistoryResponse, _ error)
func (*DB) GetTxnMulti ¶
func (d *DB) GetTxnMulti(ctx context.Context, req *plutodbpb.GetTxnMultiRequest) (*plutodbpb.GetTxnMultiResponse, error)
Click to show internal directories.
Click to hide internal directories.