cmd

Documentation

Index

• Constants
• func ParseFlags() (*flag.FlagSet, []string)
• type CmdDataCollector
  • func (c *CmdDataCollector) BuildPipeline(source bitflow.SampleSource) (*bitflow.SamplePipeline, error)
  • func (c *CmdDataCollector) RegisterFlags()
• type CmdPipelineBuilder
  • func (c *CmdPipelineBuilder) BuildPipeline(getScript func() (string, error)) (*bitflow.SamplePipeline, error)
  • func (c *CmdPipelineBuilder) PrintPipeline(pipe *bitflow.SamplePipeline) bool
  • func (c *CmdPipelineBuilder) RegisterFlags()
• type FileOutputFilterApi
  • func (api *FileOutputFilterApi) Register(pathPrefix string, router *mux.Router)
• type RestApiPath

Constants

const (
	RestApiPathPrefix = "/api"
)

Functions

func ParseFlags

func ParseFlags() (*flag.FlagSet, []string)

Types

type CmdDataCollector

type CmdDataCollector struct {
	CmdPipelineBuilder
	DefaultOutput string
	RestApis      []RestApiPath // HttpTagger and FileOutputFilterApi included by default
	// contains filtered or unexported fields
}

func (*CmdDataCollector) BuildPipeline

func (c *CmdDataCollector) BuildPipeline(source bitflow.SampleSource) (*bitflow.SamplePipeline, error)

func (*CmdDataCollector) RegisterFlags

func (c *CmdDataCollector) RegisterFlags()

type CmdPipelineBuilder

type CmdPipelineBuilder struct {
	reg.ProcessorRegistry
	SkipInputFlags bool
	// contains filtered or unexported fields
}

func (*CmdPipelineBuilder) BuildPipeline

func (c *CmdPipelineBuilder) BuildPipeline(getScript func() (string, error)) (*bitflow.SamplePipeline, error)

func (*CmdPipelineBuilder) PrintPipeline

func (c *CmdPipelineBuilder) PrintPipeline(pipe *bitflow.SamplePipeline) bool

Print the pipeline and return true, if the program should continue by executing it. If false is returned, the program should exit after printing.

func (*CmdPipelineBuilder) RegisterFlags

func (c *CmdPipelineBuilder) RegisterFlags()

type FileOutputFilterApi

type FileOutputFilterApi struct {
	FileOutputEnabled bool
	// contains filtered or unexported fields
}

func (*FileOutputFilterApi) Register

func (api *FileOutputFilterApi) Register(pathPrefix string, router *mux.Router)

type RestApiPath

type RestApiPath interface {
	Register(pathPrefix string, router *mux.Router)
}