Versions in this module Expand all Collapse all v1 v1.1.3 Sep 20, 2021 v1.1.2 Sep 20, 2021 Changes in this version + const DBFilename + const DefaultPoolDBTimeout + const Subsystem + var ErrAccountNotFound = errors.New("account not found") + var ErrDBReversion = errors.New("cannot revert to prior version") + var ErrNoOrder = errors.New("no order found") + var ErrNoSidecar = errors.New("no sidecar found") + var ErrOrderExists = errors.New("order with this nonce already exists") + func DeserializeOrder(nonce order.Nonce, r io.Reader) (order.Order, error) + func ReadElement(r io.Reader, element interface{}) error + func ReadElements(r io.Reader, elements ...interface{}) error + func SerializeOrder(o order.Order, w io.Writer) error + func UseLogger(logger btclog.Logger) + func WriteElement(w io.Writer, element interface{}) error + func WriteElements(w io.Writer, elements ...interface{}) error + type CreatedEvent struct + func NewCreatedEvent(o order.Order) *CreatedEvent + func (e *CreatedEvent) Deserialize(r io.Reader) error + func (e *CreatedEvent) Nonce() order.Nonce + func (e *CreatedEvent) Serialize(w io.Writer) error + func (e *CreatedEvent) SetTimestamp(ts time.Time) + func (e *CreatedEvent) String() string + func (e *CreatedEvent) Timestamp() time.Time + func (e *CreatedEvent) Type() event.Type + type DB struct + func New(dir, fileName string) (*DB, error) + func (db *DB) Account(traderKey *btcec.PublicKey) (*account.Account, error) + func (db *DB) Accounts() ([]*account.Account, error) + func (db *DB) AddAccount(account *account.Account) error + func (db *DB) AddSidecar(ticket *sidecar.Ticket) error + func (db *DB) AddSidecarWithBid(ticket *sidecar.Ticket, bid *order.Bid) error + func (db *DB) AllEvents(evtType event.Type) ([]event.Event, error) + func (db *DB) DeletePendingBatch() error + func (db *DB) GetEvents(timestamps map[time.Time]struct{}) ([]event.Event, error) + func (db *DB) GetEventsInRange(start, end time.Time, evtType event.Type) ([]event.Event, error) + func (db *DB) GetLocalBatchSnapshot(id order.BatchID) (*LocalBatchSnapshot, error) + func (db *DB) GetLocalBatchSnapshots() ([]*LocalBatchSnapshot, error) + func (db *DB) GetOrder(nonce order.Nonce) (order.Order, error) + func (db *DB) GetOrderEvents(o order.Nonce) ([]event.Event, error) + func (db *DB) GetOrders() ([]order.Order, error) + func (db *DB) LockID() (wtxmgr.LockID, error) + func (db *DB) MarkBatchComplete() error + func (db *DB) PendingBatchSnapshot() (*LocalBatchSnapshot, error) + func (db *DB) Sidecar(id [8]byte, offerSignPubKey *btcec.PublicKey) (*sidecar.Ticket, error) + func (db *DB) SidecarBidTemplate(ticket *sidecar.Ticket) (*order.Bid, error) + func (db *DB) Sidecars() ([]*sidecar.Ticket, error) + func (db *DB) StoreBatchEvents(batch *order.Batch, state order.MatchState, ...) error + func (db *DB) StoreBatchPartialRejectEvents(batch *order.Batch, partialRejects map[order.Nonce]*auctioneerrpc.OrderReject) error + func (db *DB) StoreOrderEvents(events []OrderEvent) error + func (db *DB) StorePendingBatch(batch *order.Batch, orders []order.Nonce, orderModifiers [][]order.Modifier, ...) error + func (db *DB) SubmitOrder(newOrder order.Order) error + func (db *DB) UpdateAccount(acct *account.Account, modifiers ...account.Modifier) error + func (db *DB) UpdateOrder(nonce order.Nonce, modifiers ...order.Modifier) error + func (db *DB) UpdateOrders(nonces []order.Nonce, modifiers [][]order.Modifier) error + func (db *DB) UpdateSidecar(ticket *sidecar.Ticket) error + type LocalBatchSnapshot struct + Accounts map[[33]byte]*account.Account + BatchID order.BatchID + BatchTX *wire.MsgTx + BatchTxFeeRate chainfee.SatPerKWeight + ClearingPrices map[uint32]order.FixedRatePremium + ExecutionFee terms.LinearFeeSchedule + MatchedOrders map[order.Nonce][]*order.MatchedOrder + Orders map[order.Nonce]order.Order + Version order.BatchVersion + func NewSnapshot(batch *order.Batch, ourOrders []order.Order, accounts []*account.Account) (*LocalBatchSnapshot, error) + type MatchEvent struct + MatchState order.MatchState + MatchedOrder order.Nonce + RejectReason uint32 + UnitsFilled order.SupplyUnit + func NewMatchEvent(ts time.Time, nonce order.Nonce, state order.MatchState, ...) *MatchEvent + func (e *MatchEvent) Deserialize(r io.Reader) error + func (e *MatchEvent) Nonce() order.Nonce + func (e *MatchEvent) Serialize(w io.Writer) error + func (e *MatchEvent) SetTimestamp(ts time.Time) + func (e *MatchEvent) String() string + func (e *MatchEvent) Timestamp() time.Time + func (e *MatchEvent) Type() event.Type + type OrderEvent interface + Nonce func() order.Nonce + type UpdatedEvent struct + NewState order.State + PrevState order.State + UnitsFilled order.SupplyUnit + func NewUpdatedEvent(prevState order.State, o order.Order) *UpdatedEvent + func (e *UpdatedEvent) Deserialize(r io.Reader) error + func (e *UpdatedEvent) Nonce() order.Nonce + func (e *UpdatedEvent) Serialize(w io.Writer) error + func (e *UpdatedEvent) SetTimestamp(ts time.Time) + func (e *UpdatedEvent) String() string + func (e *UpdatedEvent) Timestamp() time.Time + func (e *UpdatedEvent) Type() event.Type
Go to main page