cmd

Documentation

Index

• Constants
• func IsConsoleOutput(sink bitflow.SampleSink) bool
• func JSONMarshal(t interface{}) ([]byte, error)
• 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) *bitflow.SamplePipeline
  • func (c *CmdPipelineBuilder) RegisterFlags()
• type FileOutputFilterApi
  • func (api *FileOutputFilterApi) Register(pathPrefix string, router *mux.Router)
• type RestApiPath

Constants

const (
	RestApiPathPrefix = "/api"
)

Functions

func IsConsoleOutput

func IsConsoleOutput(sink bitflow.SampleSink) bool

IsConsoleOutput returns true if the given processor will output to the standard output when started.

func JSONMarshal

func JSONMarshal(t interface{}) ([]byte, error)

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) *bitflow.SamplePipeline

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