submitter

Documentation

Index

• type AuthQuerier
• type BothanClient
• type RemoteClient
• type SignalPriceSubmission
• type Submitter
  • func New(clientCtx client.Context, clients []rpcclient.RemoteClient, ...) (*Submitter, error)
  • func (s *Submitter) Start()
• type TxQuerier

Types

type AuthQuerier

type AuthQuerier interface {
	QueryAccount(address sdk.Address) (*auth.QueryAccountResponse, error)
}

type BothanClient

type BothanClient interface {
	bothanclient.Client
}

type RemoteClient

type RemoteClient interface {
	rpcclient.RemoteClient
}

type SignalPriceSubmission

type SignalPriceSubmission struct {
	SignalPrices []types.SignalPrice
	UUID         string
}

type Submitter

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

func New

func New(
	clientCtx client.Context,
	clients []rpcclient.RemoteClient,
	bothanClient BothanClient,
	logger *logger.Logger,
	submitSignalPriceCh <-chan SignalPriceSubmission,
	authQuerier AuthQuerier,
	txQuerier TxQuerier,
	valAddress sdk.ValAddress,
	pendingSignalIDs *sync.Map,
	broadcastTimeout time.Duration,
	broadcastMaxTry uint64,
	pollingInterval time.Duration,
	gasPrices string,
) (*Submitter, error)

func (*Submitter) Start

func (s *Submitter) Start()

type TxQuerier

type TxQuerier interface {
	QueryTx(hash string) (*sdk.TxResponse, error)
}