function

Documentation

Index

• func Debug(...) (*sql.DB, error)
• func Run(...)
• type DebugOption
  • func WithApiKey(apiKey string) DebugOption
  • func WithBlockHash(blockHash string) DebugOption
  • func WithBlockNumber(blockNumber int64) DebugOption
  • func WithDataDir(dataDir string) DebugOption
  • func WithFirecacheAddress(firecacheAddress string) DebugOption
  • func WithFlightAddress(flightAddress string) DebugOption
  • func WithInputsDir(inputsDir string) DebugOption
  • func WithOutputDatasetMigration(migrationSql string) DebugOption
  • func WithOutputsDir(outputsDir string) DebugOption
  • func WithPathTrigger(pathTrigger string) DebugOption
• type FunctionContextVariables
• type FunctionCtx
  • func NewFunctionCtx(parentCtx context.Context, blockNumber int64, blockHash string) *FunctionCtx
  • func (f *FunctionCtx) BlockHash() string
  • func (f *FunctionCtx) BlockNumber() int64
  • func (f *FunctionCtx) Deadline() (deadline time.Time, ok bool)
  • func (f *FunctionCtx) Done() <-chan struct{}
  • func (f *FunctionCtx) Err() error
  • func (f *FunctionCtx) Value(key interface{}) interface{}

Functions

func Debug

func Debug(handler func(ctx *FunctionCtx, duckDb *sql.DB, spiceClient *gospice.SpiceClient) error, options ...DebugOption) (*sql.DB, error)

func Run

func Run(handler func(ctx *FunctionCtx, duckDb *sql.DB, spiceClient *gospice.SpiceClient) error)

Types

type DebugOption

type DebugOption func(*debugOptions)

func WithApiKey

func WithApiKey(apiKey string) DebugOption

func WithBlockHash

func WithBlockHash(blockHash string) DebugOption

func WithBlockNumber

func WithBlockNumber(blockNumber int64) DebugOption

func WithDataDir

func WithDataDir(dataDir string) DebugOption

func WithFirecacheAddress

func WithFirecacheAddress(firecacheAddress string) DebugOption

func WithFlightAddress

func WithFlightAddress(flightAddress string) DebugOption

func WithInputsDir

func WithInputsDir(inputsDir string) DebugOption

func WithOutputDatasetMigration

func WithOutputDatasetMigration(migrationSql string) DebugOption

func WithOutputsDir

func WithOutputsDir(outputsDir string) DebugOption

func WithPathTrigger

func WithPathTrigger(pathTrigger string) DebugOption

type FunctionContextVariables

type FunctionContextVariables struct {
	BlockNumber             int64    `mapstructure:"block_number,omitempty" json:"block_number,omitempty" yaml:"block_number,omitempty"`
	BlockHash               string   `mapstructure:"block_hash,omitempty" json:"block_hash,omitempty" yaml:"block_hash,omitempty"`
	OutputDatasetMigrations []string `` /* 136-byte string literal not displayed */
}

type FunctionCtx

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

func NewFunctionCtx

func NewFunctionCtx(parentCtx context.Context, blockNumber int64, blockHash string) *FunctionCtx

func (*FunctionCtx) BlockHash

func (f *FunctionCtx) BlockHash() string

func (*FunctionCtx) BlockNumber

func (f *FunctionCtx) BlockNumber() int64

func (*FunctionCtx) Deadline

func (f *FunctionCtx) Deadline() (deadline time.Time, ok bool)

func (*FunctionCtx) Done

func (f *FunctionCtx) Done() <-chan struct{}

func (*FunctionCtx) Err

func (f *FunctionCtx) Err() error

func (*FunctionCtx) Value

func (f *FunctionCtx) Value(key interface{}) interface{}