rpc

type BlockNumber int64

type Call struct {
	Version string            `json:"jsonrpc"`
	ID      json.RawMessage   `json:"id"`
	Method  string            `json:"method"`
	Params  []json.RawMessage `json:"params"`
}

type CallContext struct {
	Latest int64
	Await  func(int64) bool
	// contains filtered or unexported fields
}

type CallMetadata struct {
	Hash     types.Hash
	Compute  *big.Int
	Duration time.Duration
}

type Check struct {
	Frequency             int64  `yaml:"frequency"`
	Params                string `yaml:"params"`
	Method                string `yaml:"method"`
	MaxHeavyResponseTime  int64  `yaml:"max_heavy_response_time_ms"`
	MaxNormalResponseTime int64  `yaml:"max_normal_response_time_ms"`
	// contains filtered or unexported fields
}

type Checks []Check

type HealthCheck interface {
	Healthy() HealthStatus
}

type HealthStatus int

type Middleware interface {
	Enter(*CallContext, string, []json.RawMessage) (interface{}, *RPCError)
	Exit(*CallContext, interface{}, *RPCError) (interface{}, *RPCError)
}

type RPCError struct {
	C    int         `json:"code"`
	Msg  string      `json:"message"`
	Data interface{} `json:"data,omitempty"`
}

type RawResponse struct {
	Version string          `json:"jsonrpc"`
	ID      json.RawMessage `json:"id"`
	Error   *RPCError       `json:"error,omitempty"`
	Result  json.RawMessage `json:"result,omitempty"`
	Params  json.RawMessage `json:"params,omitempty"`
	Meta    *CallMetadata   `json:"-"`
}

type Registry interface {
	RegistryCallable
	Register(namespace string, service interface{})
	RegisterMiddleware(Middleware)
	RegisterHeightFeed(<-chan int64)
	SetBlockWaitDuration(time.Duration)
	OnMissing(func(*CallContext, string, []json.RawMessage) (interface{}, *RPCError, *CallMetadata))
	Disconnect(context.Context)
}

type RegistryCallable interface {
	Call(ctx context.Context, method string, args []json.RawMessage, output chan interface{}, latestNumber int64) (interface{}, *RPCError, *CallMetadata)
}

type Response struct {
	Version string          `json:"jsonrpc"`
	ID      json.RawMessage `json:"id"`
	Error   *RPCError       `json:"error,omitempty"`
	Result  interface{}     `json:"result,omitempty"`
	Params  interface{}     `json:"params,omitempty"`
	Meta    *CallMetadata   `json:"-"`
}

type SubscriptionResponse struct {
	Version string `json:"jsonrpc"`
	Method  string `json:"method"`
	Params  struct {
		ID     hexutil.Uint64 `json:"subscription"`
		Result interface{}    `json:"result"`
	} `json:"params"`
}

type SubscriptionResponseRaw struct {
	Version string `json:"jsonrpc"`
	Method  string `json:"method"`
	Params  struct {
		ID     hexutil.Uint64  `json:"subscription"`
		Result json.RawMessage `json:"result"`
	} `json:"params"`
}