bank

Documentation

Index

• type Client
  • func New(pooldbClient *dbcl.Client, redisClient *redis.Client, ...) *Client
  • func (c *Client) BroadcastOutgoingTxs(node types.PayoutNode) error
  • func (c *Client) ConfirmOutgoingTxs(node types.PayoutNode) error
  • func (c *Client) FetchLock(chain string) (*redislock.Lock, error)
  • func (c *Client) MergeUTXOs(node types.PayoutNode, count int) error
  • func (c *Client) PrepareOutgoingTxs(q dbcl.Querier, node types.PayoutNode, txType types.TransactionType, ...) ([]*pooldb.Transaction, error)
  • func (c *Client) RegisterIncomingTx(node types.PayoutNode, txid string) (bool, error)

Types

type Client

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

func New

func New(
	pooldbClient *dbcl.Client,
	redisClient *redis.Client,
	telegramClient *telegram.Client,
) *Client

func (*Client) BroadcastOutgoingTxs

func (c *Client) BroadcastOutgoingTxs(node types.PayoutNode) error

func (*Client) ConfirmOutgoingTxs

func (c *Client) ConfirmOutgoingTxs(node types.PayoutNode) error

func (*Client) FetchLock

func (c *Client) FetchLock(chain string) (*redislock.Lock, error)

func (*Client) MergeUTXOs

func (c *Client) MergeUTXOs(node types.PayoutNode, count int) error

func (*Client) PrepareOutgoingTxs

func (c *Client) PrepareOutgoingTxs(
	q dbcl.Querier,
	node types.PayoutNode,
	txType types.TransactionType,
	txOutputList ...[]*types.TxOutput,
) ([]*pooldb.Transaction, error)

func (*Client) RegisterIncomingTx

func (c *Client) RegisterIncomingTx(node types.PayoutNode, txid string) (bool, error)