persistence

Documentation

Index

• Constants
• func Authenticate(ctx context.Context, jwtToken string) (string, error)
• func CancelOrder(ctx context.Context, order *engine.Order) error
• func CancelOrderAction(ctx context.Context, orderId string, createdAt time.Time, userId string) error
• func CreateOrderAction(ctx context.Context, o *engine.Order, userId string, createdAt time.Time) error
• func CreateRefundTransfer(ctx context.Context, userId, assetId string, amount number.Decimal, ...) error
• func ExpireTransfers(ctx context.Context, transfers []*Transfer) error
• func ReadProperty(ctx context.Context, key string) (string, error)
• func ReadPropertyAsTime(ctx context.Context, key string) (time.Time, error)
• func SetupSpanner(ctx context.Context, client *spanner.Client) context.Context
• func Spanner(ctx context.Context) *spanner.Client
• func Transact(ctx context.Context, taker, maker *engine.Order, amount, funds number.Integer) (string, error)
• func UpdateUserPublicKey(ctx context.Context, userId, publicKey string) error
• func WriteProperty(ctx context.Context, key, value string) error
• func WriteTimeProperty(ctx context.Context, key string, value time.Time) error
• type Action
  • func ListPendingActions(ctx context.Context, checkpoint time.Time, limit int) ([]*Action, error)
• type Order
  • func UserOrders(ctx context.Context, userId string, market, state string, offset time.Time, ...) ([]*Order, error)
• type Property
• type Trade
  • func LastTrade(ctx context.Context, market string) (*Trade, error)
  • func MarketTrades(ctx context.Context, market string, offset time.Time, order string, limit int) ([]*Trade, error)
  • func ReadTransferTrade(ctx context.Context, tradeId, assetId string) (*Trade, error)
• type Transfer
  • func ListPendingTransfers(ctx context.Context, limit int) ([]*Transfer, error)
• type User

Constants

const (
	OrderStatePending = "PENDING"
	OrderStateDone    = "DONE"
)

const (
	MakerFeeRate = "0.000"
	TakerFeeRate = "0.001"

	TradeLiquidityTaker = "TAKER"
	TradeLiquidityMaker = "MAKER"
)

const (
	TransferSourceTradeConfirmed = "TRADE_CONFIRMED"
	TransferSourceOrderCancelled = "ORDER_CANCELLED"
	TransferSourceOrderFilled    = "ORDER_FILLED"
	TransferSourceOrderInvalid   = "ORDER_INVALID"
)

Functions

func Authenticate

func Authenticate(ctx context.Context, jwtToken string) (string, error)

func CancelOrder

func CancelOrder(ctx context.Context, order *engine.Order) error

func CancelOrderAction

func CancelOrderAction(ctx context.Context, orderId string, createdAt time.Time, userId string) error

func CreateOrderAction

func CreateOrderAction(ctx context.Context, o *engine.Order, userId string, createdAt time.Time) error

func CreateRefundTransfer

func CreateRefundTransfer(ctx context.Context, userId, assetId string, amount number.Decimal, trace string) error

func ExpireTransfers

func ExpireTransfers(ctx context.Context, transfers []*Transfer) error

func ReadProperty

func ReadProperty(ctx context.Context, key string) (string, error)

func ReadPropertyAsTime

func ReadPropertyAsTime(ctx context.Context, key string) (time.Time, error)

func SetupSpanner

func SetupSpanner(ctx context.Context, client *spanner.Client) context.Context

func Spanner

func Spanner(ctx context.Context) *spanner.Client

func Transact

func Transact(ctx context.Context, taker, maker *engine.Order, amount, funds number.Integer) (string, error)

func UpdateUserPublicKey

func UpdateUserPublicKey(ctx context.Context, userId, publicKey string) error

func WriteProperty

func WriteProperty(ctx context.Context, key, value string) error

func WriteTimeProperty

func WriteTimeProperty(ctx context.Context, key string, value time.Time) error

Types

type Action

type Action struct {
	OrderId   string    `spanner:"order_id"`
	Action    string    `spanner:"action"`
	CreatedAt time.Time `spanner:"created_at"`

	Order *Order `spanner:"-"`
}

func ListPendingActions

func ListPendingActions(ctx context.Context, checkpoint time.Time, limit int) ([]*Action, error)

type Order

type Order struct {
	OrderId         string    `spanner:"order_id"`
	OrderType       string    `spanner:"order_type"`
	QuoteAssetId    string    `spanner:"quote_asset_id"`
	BaseAssetId     string    `spanner:"base_asset_id"`
	Side            string    `spanner:"side"`
	Price           string    `spanner:"price"`
	RemainingAmount string    `spanner:"remaining_amount"`
	FilledAmount    string    `spanner:"filled_amount"`
	RemainingFunds  string    `spanner:"remaining_funds"`
	FilledFunds     string    `spanner:"filled_funds"`
	CreatedAt       time.Time `spanner:"created_at"`
	State           string    `spanner:"state"`
	UserId          string    `spanner:"user_id"`
}

func UserOrders

func UserOrders(ctx context.Context, userId string, market, state string, offset time.Time, order string, limit int) ([]*Order, error)

type Property

type Property struct {
	Key       string
	Value     string
	UpdatedAt time.Time
}

type Trade

type Trade struct {
	TradeId      string    `spanner:"trade_id"`
	Liquidity    string    `spanner:"liquidity"`
	AskOrderId   string    `spanner:"ask_order_id"`
	BidOrderId   string    `spanner:"bid_order_id"`
	QuoteAssetId string    `spanner:"quote_asset_id"`
	BaseAssetId  string    `spanner:"base_asset_id"`
	Side         string    `spanner:"side"`
	Price        string    `spanner:"price"`
	Amount       string    `spanner:"amount"`
	CreatedAt    time.Time `spanner:"created_at"`
	UserId       string    `spanner:"user_id"`
	FeeAssetId   string    `spanner:"fee_asset_id"`
	FeeAmount    string    `spanner:"fee_amount"`
}

func LastTrade

func LastTrade(ctx context.Context, market string) (*Trade, error)

func MarketTrades

func MarketTrades(ctx context.Context, market string, offset time.Time, order string, limit int) ([]*Trade, error)

func ReadTransferTrade

func ReadTransferTrade(ctx context.Context, tradeId, assetId string) (*Trade, error)

type Transfer

type Transfer struct {
	TransferId string    `spanner:"transfer_id"`
	Source     string    `spanner:"source"`
	Detail     string    `spanner:"detail"`
	AssetId    string    `spanner:"asset_id"`
	Amount     string    `spanner:"amount"`
	CreatedAt  time.Time `spanner:"created_at"`
	UserId     string    `spanner:"user_id"`
}

func ListPendingTransfers

func ListPendingTransfers(ctx context.Context, limit int) ([]*Transfer, error)

type User

type User struct {
	UserId    string
	PublicKey string
}