request

Documentation

Index

• type FailResponse
  • func (r FailResponse) Error() string
• type SuccessResponse
• type Task
  • func NewTask(id, requestID uint64, msg oracletypes.MsgRequestData) Task
  • func (t Task) ID() uint64
• type Watcher
  • func NewWatcher(client client.Client, logger logging.Logger, timeout time.Duration, ...) *Watcher
  • func (w *Watcher) FailedRequestCh() <-chan FailResponse
  • func (w *Watcher) Start()
  • func (w *Watcher) SuccessfulRequestCh() <-chan SuccessResponse

Types

type FailResponse

type FailResponse struct {
	Task
	oracletypes.Result
	// contains filtered or unexported fields
}

func (FailResponse) Error

func (r FailResponse) Error() string

type SuccessResponse

type SuccessResponse struct {
	Task
	oracletypes.Result
}

type Task

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

func NewTask

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

func (Task) ID

func (t Task) ID() uint64

type Watcher

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

func NewWatcher

func NewWatcher(
	client client.Client,
	logger logging.Logger,
	timeout time.Duration,
	pollingDelay time.Duration,
	watchQueueCh chan Task,
	successChBufferSize int,
	failureChBufferSize int,
) *Watcher

func (*Watcher) FailedRequestCh

func (w *Watcher) FailedRequestCh() <-chan FailResponse

func (*Watcher) Start

func (w *Watcher) Start()

func (*Watcher) SuccessfulRequestCh

func (w *Watcher) SuccessfulRequestCh() <-chan SuccessResponse