callback

Documentation

Index

• type Callback
  • func New(logger logging.Logger) *Callback
  • func (c *Callback) Cancel(id int) error
  • func (c *Callback) On(method string, f handlerFunc) int
  • func (c *Callback) Register(id uint64, method string)
  • func (c *Callback) Run(resp *Response)
• type Response

Types

type Callback

type Callback struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(logger logging.Logger) *Callback

func (*Callback) Cancel

func (c *Callback) Cancel(id int) error

Cancel removes a callback based on an callback ID

func (*Callback) On

func (c *Callback) On(method string, f handlerFunc) int

On adds a new callback based on an ethrpc method and returns the associated callback ID

func (*Callback) Register

func (c *Callback) Register(id uint64, method string)

Register keeps track of the ethrpc requests with ethrpc ID to ethrpc method name mapping. It must be called before callback.Run()

func (*Callback) Run

func (c *Callback) Run(resp *Response)

Run, with the ID from the ethrpc response, finds the registered method name, and executes all callbacks associated with the method.

type Response

type Response struct {
	Body *ethrpc.JsonrpcMessage
	IP   string
}