state

Documentation

Index

• Variables
• func FetchHeightFromStatus(rpcUrl string) (int64, error)
• func Init()
• func InitPool()
• func IsNeededToFetchLastBlock(s *BackendState) bool
• func ReadHeightFromStatusJson(jsonText []byte) (int64, error)
• func TaskUpdateState()
• type BackendState
  • func GetPool(t config.ProtocolType) []*BackendState
  • func SelectMatchedBackend(height int64, t config.ProtocolType) (*BackendState, error)
  • func SelectPrunedNode(t config.ProtocolType) *BackendState

Variables

var (
	PoolRpc     []*BackendState
	PoolApi     []*BackendState
	PoolGrpc    []*BackendState
	PoolEth     []*BackendState
	PoolEthWs   []*BackendState
	ProxyMapRpc = make(map[string]*httputil.ReverseProxy)
	ProxyMapApi = make(map[string]*httputil.ReverseProxy)
	ProxyMapEth = make(map[string]*httputil.ReverseProxy)
)

Functions

func FetchHeightFromStatus

func FetchHeightFromStatus(rpcUrl string) (int64, error)

func Init

func Init()

func InitPool

func InitPool()

func IsNeededToFetchLastBlock

func IsNeededToFetchLastBlock(s *BackendState) bool

func ReadHeightFromStatusJson

func ReadHeightFromStatusJson(jsonText []byte) (int64, error)

func TaskUpdateState

func TaskUpdateState()

Types

type BackendState

type BackendState struct {
	Name      string
	NodeType  config.BackendNodeType
	LastBlock int64

	Backend *config.Backend
}

func GetPool

func GetPool(t config.ProtocolType) []*BackendState

func SelectMatchedBackend

func SelectMatchedBackend(height int64, t config.ProtocolType) (*BackendState, error)

func SelectPrunedNode

func SelectPrunedNode(t config.ProtocolType) *BackendState