spark

Documentation

Index

• func NewSpark() sparkv1.Spark
• type Spark
  • func (s Spark) BuildChain(b sparkv1.Builder) sparkv1.Chain
  • func (s Spark) Init(ctx sparkv1.InitContext) error
  • func (s Spark) Stop()

Functions

func NewSpark

func NewSpark() sparkv1.Spark

NewSpark creates a Spark shutdown is a reference to the context cancel function, it can be used to gracefully stop the worker if needed

Types

type Spark

type Spark struct{}

func (Spark) BuildChain

func (s Spark) BuildChain(b sparkv1.Builder) sparkv1.Chain

func (Spark) Init

func (s Spark) Init(ctx sparkv1.InitContext) error

func (Spark) Stop

func (s Spark) Stop()