cli

package
v0.0.0-...-efbdb50 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 11, 2022 License: Apache-2.0 Imports: 61 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var RootCmd = &cobra.Command{
	Use:           "subgraph",
	Short:         "Live & Parallel Processor for Subgraphs",
	SilenceUsage:  true,
	SilenceErrors: true,
}

Functions

func ExampleSparkle

func ExampleSparkle(in string) string

func Execute

func Execute()

Types

type BlockRange

type BlockRange struct {
	Start uint64
	Stop  uint64
}

func (BlockRange) ReprocRange

func (b BlockRange) ReprocRange() string

func (BlockRange) String

func (b BlockRange) String() string

func (BlockRange) Unbounded

func (b BlockRange) Unbounded() bool

type LoggingOptions

type LoggingOptions struct {
	Verbosity     int    // verbosity level
	LogFormat     string // specifies the log format
	LogListenAddr string // address that listens to change the logs
}

type ProgressMarker

type ProgressMarker struct {
	Filename   string    `db:"filename"`
	TableName  string    `db:"table_name"`
	InjectedAt time.Time `db:"injected_at"`
}

type TableShard

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

func (*TableShard) Run

func (ts *TableShard) Run() (*tableShardMetrics, error)

type TblShard

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

func NewTblShard

func NewTblShard(pool *pgxpool.Pool, pqSchema, tblName string, ent reflect.Type, startBlockNum, stopBlockNum uint64, inStore dstore.Store) *TblShard

func (*TblShard) Run

func (t *TblShard) Run(ctx context.Context) error

type VersionedSubgraph

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL