sender

Documentation

Index

• type FailResponse
  • func (r FailResponse) Error() string
• type Sender
  • func NewSender(client client.Client, logger logging.Logger, kr keyring.Keyring, ...) (*Sender, error)
  • func (s *Sender) FailedRequestsCh() <-chan FailResponse
  • func (s *Sender) Start()
  • func (s *Sender) SuccessRequestsCh() <-chan SuccessResponse
• type SuccessResponse
• type Task
  • func NewTask(id uint64, msg oracletypes.MsgRequestData) Task
  • func (t Task) ID() uint64

Types

type FailResponse

type FailResponse struct {
	Task
	TxResponse sdk.TxResponse
	// contains filtered or unexported fields
}

func (FailResponse) Error

func (r FailResponse) Error() string

type Sender

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

func NewSender

func NewSender(
	client client.Client,
	logger logging.Logger,
	kr keyring.Keyring,
	gasPrice float64,
	timeout time.Duration,
	pollingDelay time.Duration,
	requestQueueCh chan Task,
	successChBufferSize int,
	failureChBufferSize int,
) (*Sender, error)

func (*Sender) FailedRequestsCh

func (s *Sender) FailedRequestsCh() <-chan FailResponse

func (*Sender) Start

func (s *Sender) Start()

func (*Sender) SuccessRequestsCh

func (s *Sender) SuccessRequestsCh() <-chan SuccessResponse

type SuccessResponse

type SuccessResponse struct {
	Task
	TxResponse sdk.TxResponse
}

type Task

type Task struct {
	Msg oracletypes.MsgRequestData
	// contains filtered or unexported fields
}

func NewTask

func NewTask(id uint64, msg oracletypes.MsgRequestData) Task

func (Task) ID

func (t Task) ID() uint64