protocol

type AbstractUpstreamStateEvent interface {
	// contains filtered or unexported methods
}

type ApiConnectorType int

type AvailabilityStatus int

type BanMethodUpstreamStateEvent struct {
	Method string
}

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

type Block struct {
	BlockData *BlockData
}

type BlockData struct {
	Height uint64
	Slot   uint64
	Hash   string
}

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

type BlockType int

type BlockUpstreamStateEvent struct {
	BlockData *BlockData
	BlockType BlockType
}

type Cap int

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

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

type FatalErrorUpstreamStateEvent struct{}

type HeadUpstreamStateEvent struct {
	HeadData *BlockData
}

type HttpMethod int

type JsonRpcRequestBody struct {
	Id      json.RawMessage `json:"id"`
	Jsonrpc string          `json:"jsonrpc"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params"`
}

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

type RemoveUpstreamEvent struct{}

type ReplyError struct {
	ErrorKind ResponseErrorKind
	// contains filtered or unexported fields
}

type RequestHolder interface {
	Id() string
	Method() string
	Headers() map[string]string
	Body() ([]byte, error)
	ParseParams(ctx context.Context) specs.MethodParam
	ModifyParams(ctx context.Context, newValue any)
	IsStream() bool
	IsSubscribe() bool
	RequestType() RequestType
	RequestHash() string
	SpecMethod() *specs.Method
}

type RequestType int

type ResponseError struct {
	Code    int
	Message string
	Data    interface{}
}

type ResponseErrorKind int

type ResponseHolder interface {
	ResponseResult() []byte
	ResponseResultString() (string, error)
	ResponseCode() int
	GetError() *ResponseError
	EncodeResponse(realId []byte) io.Reader
	HasError() bool
	HasStream() bool
	Id() string
}

type ResponseHolderWrapper struct {
	UpstreamId string
	RequestId  string
	Response   ResponseHolder
}

type ResultType int

type StateUpstreamEvent struct {
	State *UpstreamState
}

type StopRetryErr struct {
}

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

type UnbanMethodUpstreamStateEvent struct {
	Method string
}

type UpstreamEvent struct {
	Id        string
	Chain     chains.Chain
	EventType UpstreamEventType
}

type UpstreamEventType interface {
	// contains filtered or unexported methods
}

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

type UpstreamRestRequest struct {
}

type UpstreamState struct {
	Status              AvailabilityStatus
	HeadData            *BlockData
	UpstreamMethods     methods.Methods
	BlockInfo           *BlockInfo
	Caps                mapset.Set[Cap]
	UpstreamIndex       string
	RateLimiterBudget   *ratelimiter.RateLimitBudget
	AutoTuneRateLimiter *ratelimiter.UpstreamAutoTune
}

type UpstreamSubscriptionResponse interface {
	ResponseChan() chan *WsResponse
}

type ValidUpstreamEvent struct{}

type ValidUpstreamStateEvent struct{}

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

type WsResponse struct {
	Id      string
	SubId   string
	Message []byte
	Type    RequestType
	Error   *ResponseError
	Event   []byte
}