cli

Documentation

Index

• Constants
• func Execute()
• func GetLogger() logger.Logger
• func InitLogger()
• type CliStepPublisher
  • func NewCliStepPublisher(logger logger.Logger) *CliStepPublisher
  • func (p *CliStepPublisher) Error(step core.StepType, err error)
  • func (p *CliStepPublisher) PublishStep(step core.StepType)
• type Engine
  • func NewProjectEngine(pub core.StepPublisher, l logger.Logger, workers int, fs *fs.FileSystem, ...) (*Engine, error)
  • func (e *Engine) AddRequest(request *core.Request) chan error
  • func (e *Engine) Shutdown(timeout time.Duration)
  • func (e *Engine) Start(ctx context.Context)
• type ExecutionRequest
• type ZerologAdapter
  • func (z *ZerologAdapter) Debug(msg string)
  • func (z *ZerologAdapter) Error(msg string)
  • func (z *ZerologAdapter) Fatal(msg string)
  • func (z *ZerologAdapter) Info(msg string)
  • func (z *ZerologAdapter) Warn(msg string)
  • func (z *ZerologAdapter) WithField(key string, value interface{}) logger.Logger

Constants

const (
	Input state = iota
	Initializing
	Processing
	Questions
	Finished
)

Functions

func Execute

func Execute()

func GetLogger

func GetLogger() logger.Logger

GetLogger returns the logger instance

func InitLogger

func InitLogger()

InitLogger initializes the logger

Types

type CliStepPublisher

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

func NewCliStepPublisher

func NewCliStepPublisher(logger logger.Logger) *CliStepPublisher

func (*CliStepPublisher) Error

func (p *CliStepPublisher) Error(step core.StepType, err error)

func (*CliStepPublisher) PublishStep

func (p *CliStepPublisher) PublishStep(step core.StepType)

type Engine

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

func NewProjectEngine

func NewProjectEngine(pub core.StepPublisher, l logger.Logger, workers int, fs *fs.FileSystem, tellmURL string) (*Engine, error)

func (*Engine) AddRequest

func (e *Engine) AddRequest(request *core.Request) chan error

func (*Engine) Shutdown

func (e *Engine) Shutdown(timeout time.Duration)

func (*Engine) Start

func (e *Engine) Start(ctx context.Context)

type ExecutionRequest

type ExecutionRequest struct {
	Request    *core.Request
	ResultChan chan error
	CreatedAt  time.Time
}

type ZerologAdapter

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

ZerologAdapter adapts zerolog.Logger to our Logger interface

func (*ZerologAdapter) Debug

func (z *ZerologAdapter) Debug(msg string)

func (*ZerologAdapter) Error

func (z *ZerologAdapter) Error(msg string)

func (*ZerologAdapter) Fatal

func (z *ZerologAdapter) Fatal(msg string)

func (*ZerologAdapter) Info

func (z *ZerologAdapter) Info(msg string)

func (*ZerologAdapter) Warn

func (z *ZerologAdapter) Warn(msg string)

func (*ZerologAdapter) WithField

func (z *ZerologAdapter) WithField(key string, value interface{}) logger.Logger