spork

Documentation

Overview

*

• spork/spork.go
• Copyright (c) 2021 Alvin(Xinyao) Sun <asun@whitematrix.io> *
• Licensed under the Apache License, Version 2.0 (the "License");
• you may not use this file except in compliance with the License.
• You may obtain a copy of the License at *
• http://www.apache.org/licenses/LICENSE-2.0 *
• Unless required by applicable law or agreed to in writing, software
• distributed under the License is distributed on an "AS IS" BASIS,
• WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
• See the License for the specific language governing permissions and
• limitations under the License.

Index

• func BlockEventsToJSON(e []client.BlockEvents) []interface{}
• func EventToJSON(e *cadence.Event) interface{}
• type EventResult
  • func (e *EventResult) JSON() interface{}
• type ResolvedAccessNodeList
• type Spork
  • func ReadJSONFromUrl(url string) ([]Spork, error)
• type SporkStore
  • func New(url string, maxQueryBlocks uint64, queryBatchSize uint64) *SporkStore
  • func (ss *SporkStore) QueryEventByBlockRange(event string, start uint64, end uint64) ([]client.BlockEvents, error)
  • func (ss *SporkStore) QueryLatestBlockHeight() (uint64, error)
  • func (ss *SporkStore) String() string
  • func (ss *SporkStore) SyncSpork() error

Functions

func BlockEventsToJSON

func BlockEventsToJSON(e []client.BlockEvents) []interface{}

func EventToJSON

func EventToJSON(e *cadence.Event) interface{}

Types

type EventResult

type EventResult struct {
	BlockEvents []client.BlockEvents
}

func (*EventResult) JSON

func (e *EventResult) JSON() interface{}

type ResolvedAccessNodeList

type ResolvedAccessNodeList struct {
	Start      uint64
	End        uint64
	AccessNode string
}

type Spork

type Spork struct {
	Name       string `json:"name"`
	RootHeight uint64 `json:"rootHeight"`
	AccessNode string `json:"accessNode"`
}

func ReadJSONFromUrl

func ReadJSONFromUrl(url string) ([]Spork, error)

type SporkStore

type SporkStore struct {
	sync.Mutex

	SporkList []Spork
	// contains filtered or unexported fields
}

func New

func New(url string, maxQueryBlocks uint64, queryBatchSize uint64) *SporkStore

func (*SporkStore) QueryEventByBlockRange

func (ss *SporkStore) QueryEventByBlockRange(event string, start uint64, end uint64) ([]client.BlockEvents, error)

func (*SporkStore) QueryLatestBlockHeight

func (ss *SporkStore) QueryLatestBlockHeight() (uint64, error)

func (*SporkStore) String

func (ss *SporkStore) String() string

func (*SporkStore) SyncSpork

func (ss *SporkStore) SyncSpork() error