spark

Documentation

Index

• func NewSpark() sparkv1.Spark
• type Config
• 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 Config

type Config struct {
	Foo string `json:"foo"`
}

type Spark

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

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()