console

Documentation

Index

• Constants
• func Init()
• func NewConsoleSink(properties map[string]interface{}) (sink.Sink, error)
• type Console
  • func (s *Console) GetStats() *sink.Stats
  • func (s *Console) Init(name string, fields []common.Field) error
  • func (s *Console) Write(headers []string, rows [][]interface{}, index int) error

Constants

const CONSOLE_SINK_TYPE = "console"

Functions

func Init

func Init()

func NewConsoleSink

func NewConsoleSink(properties map[string]interface{}) (sink.Sink, error)

Types

type Console

type Console struct{}

func (*Console) GetStats

func (s *Console) GetStats() *sink.Stats

func (*Console) Init

func (s *Console) Init(name string, fields []common.Field) error

func (*Console) Write

func (s *Console) Write(headers []string, rows [][]interface{}, index int) error