output

Documentation

Index

• func PrometheusHTTP()
• type Outputer
• type PrometheusOutput
  • func (o *PrometheusOutput) Configure() error
  • func (o *PrometheusOutput) Loop()
  • func (o *PrometheusOutput) Shutdown()
• type SimpleTableOutput
  • func (o *SimpleTableOutput) Configure() error
  • func (o *SimpleTableOutput) Loop()
  • func (o *SimpleTableOutput) Shutdown()
• type StreamOutput
  • func (o *StreamOutput) CreateStreamFromConfigurationMapping(mapping *conf.Mapping, createNamedQueries []string) error
  • func (o *StreamOutput) EnableProfile()
  • func (o *StreamOutput) ErrorChan() *chan error
  • func (o *StreamOutput) InputExists() *bool
  • func (o *StreamOutput) Profile() bool
  • func (o *StreamOutput) SetInputExists(inputExists func() *bool)
  • func (o *StreamOutput) Stream() *tablestream.Stream
• type TableOutput
  • func (o *TableOutput) Configure() error
  • func (o *TableOutput) Loop()
  • func (o *TableOutput) Shutdown()

Functions

func PrometheusHTTP

func PrometheusHTTP()

Types

type Outputer

type Outputer interface {
	Loop()
	Configure() error
	Stream() *tablestream.Stream
	ErrorChan() *chan error
	CreateStreamFromConfigurationMapping(mapping *conf.Mapping, createNamedQueries []string) error
	InputExists() *bool
	SetInputExists(func() *bool)
	EnableProfile()
	Profile() bool
}

type PrometheusOutput

type PrometheusOutput struct {
	StreamOutput
	// contains filtered or unexported fields
}

func (*PrometheusOutput) Configure

func (o *PrometheusOutput) Configure() error

func (*PrometheusOutput) Loop

func (o *PrometheusOutput) Loop()

func (*PrometheusOutput) Shutdown

func (o *PrometheusOutput) Shutdown()

type SimpleTableOutput

type SimpleTableOutput struct {
	StreamOutput
}

func (*SimpleTableOutput) Configure

func (o *SimpleTableOutput) Configure() error

func (*SimpleTableOutput) Loop

func (o *SimpleTableOutput) Loop()

func (*SimpleTableOutput) Shutdown

func (o *SimpleTableOutput) Shutdown()

type StreamOutput

type StreamOutput struct {
	Outputer
	// contains filtered or unexported fields
}

func (*StreamOutput) CreateStreamFromConfigurationMapping

func (o *StreamOutput) CreateStreamFromConfigurationMapping(mapping *conf.Mapping, createNamedQueries []string) error

func (*StreamOutput) EnableProfile

func (o *StreamOutput) EnableProfile()

func (*StreamOutput) ErrorChan

func (o *StreamOutput) ErrorChan() *chan error

func (*StreamOutput) InputExists

func (o *StreamOutput) InputExists() *bool

func (*StreamOutput) Profile

func (o *StreamOutput) Profile() bool

func (*StreamOutput) SetInputExists

func (o *StreamOutput) SetInputExists(inputExists func() *bool)

func (*StreamOutput) Stream

func (o *StreamOutput) Stream() *tablestream.Stream

type TableOutput

type TableOutput struct {
	StreamOutput
	// contains filtered or unexported fields
}

func (*TableOutput) Configure

func (o *TableOutput) Configure() error

func (*TableOutput) Loop

func (o *TableOutput) Loop()

func (*TableOutput) Shutdown

func (o *TableOutput) Shutdown()