pipeline

Documentation

Index

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

Variables

var CreateFlag = flags.String()

CreateFlag defines wether we should create a pipeline.

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.