oracle

Documentation

Index

• func DecodeResponse(resp *resty.Response) ([]byte, error)
• func New(exchange core.Exchange, client *mixin.Client, wallets core.WalletStore, ...) worker.Worker
• func Request(ctx context.Context) *resty.Request
• func UnmarshalResponse(resp *resty.Response, v interface{}) error
• type Error
  • func (err *Error) Error() string
• type Oracle
  • func (m *Oracle) OnMessage(ctx context.Context, msg *mixin.MessageView, userID string) error
  • func (m *Oracle) Run(ctx context.Context) error

Functions

func DecodeResponse

func DecodeResponse(resp *resty.Response) ([]byte, error)

func New

func New(
	exchange core.Exchange,
	client *mixin.Client,
	wallets core.WalletStore,
	subscribers core.SubscriberStore,
	system *core.System,
) worker.Worker

func Request

func Request(ctx context.Context) *resty.Request

func UnmarshalResponse

func UnmarshalResponse(resp *resty.Response, v interface{}) error

Types

type Error

type Error struct {
	Code int    `json:"code,omitempty"`
	Msg  string `json:"msg,omitempty"`
}

func (*Error) Error

func (err *Error) Error() string

type Oracle

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

func (*Oracle) OnMessage

func (m *Oracle) OnMessage(ctx context.Context, msg *mixin.MessageView, userID string) error

func (*Oracle) Run

func (m *Oracle) Run(ctx context.Context) error