cli

Documentation

Index

• Variables
• func ExampleSparkle(in string) string
• func Execute()
• type BlockRange
  • func (b BlockRange) ReprocRange() string
  • func (b BlockRange) String() string
  • func (b BlockRange) Unbounded() bool
• type LoggingOptions
• type ProgressMarker
• type TableShard
  • func (ts *TableShard) Run() (*tableShardMetrics, error)
• type TblShard
  • func NewTblShard(pool *pgxpool.Pool, pqSchema, tblName string, ent reflect.Type, ...) *TblShard
  • func (t *TblShard) Run(ctx context.Context) error
• type VersionedSubgraph

Variables

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
}