pipeline

Documentation

Index

• Variables
• func Start(lc fx.Lifecycle, cfg *pipeline.Config, logger *zap.Logger)

Variables

var (
	// CreateFlag defines the pipeline path to create a pipeline.
	CreateFlag = flags.String()

	// GetFlag defines a pipeline id to be retrieved.
	GetFlag = flags.String()
)

var Module = fx.Options(
	fx.Invoke(Start),
)

Module for fx.

Functions

func Start

func Start(lc fx.Lifecycle, cfg *pipeline.Config, logger *zap.Logger)

Start for redis.