input

package

v0.0.0-...-e253636 Latest Latest Go to latest Published: Sep 4, 2025 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gfleury/gstreamtop

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateLokiStream(lokiUrl string) (io.Reader, error)
type CSVStreamInput
type Inputer
- func CreateCSVStreamInputFromStreamOutput(o output.Outputer) (Inputer, error)
- func CreateStreamInputFromStreamOutput(o output.Outputer) (Inputer, error)
type LokiReader
- func (lr *LokiReader) Read(p []byte) (n int, err error)
type StreamInput

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateLokiStream ¶

func CreateLokiStream(lokiUrl string) (io.Reader, error)

Types ¶

type CSVStreamInput ¶

type CSVStreamInput struct {
	Inputer
	// contains filtered or unexported fields
}

func (*CSVStreamInput) Configure ¶

func (i *CSVStreamInput) Configure() error

func (*CSVStreamInput) EntriesRead ¶

func (i *CSVStreamInput) EntriesRead() int64

func (*CSVStreamInput) Errors ¶

func (i *CSVStreamInput) Errors() *chan error

func (*CSVStreamInput) InputExists ¶

func (i *CSVStreamInput) InputExists() *bool

func (*CSVStreamInput) Loop ¶

func (i *CSVStreamInput) Loop(file io.Reader)

func (*CSVStreamInput) PushData ¶

func (i *CSVStreamInput) PushData(data interface{})

func (*CSVStreamInput) Run ¶

func (i *CSVStreamInput) Run(file io.Reader)

func (*CSVStreamInput) SetTable ¶

func (i *CSVStreamInput) SetTable(t tablestream.Table)

func (*CSVStreamInput) Table ¶

func (i *CSVStreamInput) Table() tablestream.Table

type Inputer ¶

type Inputer interface {
	Configure() error
	PushData(interface{})
	Run(io.Reader)
	InputExists() *bool
	Table() tablestream.Table
	SetTable(tablestream.Table)
	Errors() *chan error
	EntriesRead() int64
}

func CreateCSVStreamInputFromStreamOutput ¶

func CreateCSVStreamInputFromStreamOutput(o output.Outputer) (Inputer, error)

func CreateStreamInputFromStreamOutput ¶

func CreateStreamInputFromStreamOutput(o output.Outputer) (Inputer, error)

type LokiReader ¶

type LokiReader struct {
	Query string
	Url   string
	// contains filtered or unexported fields
}

func (*LokiReader) Read ¶

func (lr *LokiReader) Read(p []byte) (n int, err error)

type StreamInput ¶

type StreamInput struct {
	Inputer
	// contains filtered or unexported fields
}

func (*StreamInput) Configure ¶

func (i *StreamInput) Configure() error

func (*StreamInput) EntriesRead ¶

func (i *StreamInput) EntriesRead() int64

func (*StreamInput) Errors ¶

func (i *StreamInput) Errors() *chan error

func (*StreamInput) InputExists ¶

func (i *StreamInput) InputExists() *bool

func (*StreamInput) Loop ¶

func (i *StreamInput) Loop(file io.Reader)

func (*StreamInput) PushData ¶

func (i *StreamInput) PushData(data interface{})

func (*StreamInput) Run ¶

func (i *StreamInput) Run(file io.Reader)

func (*StreamInput) SetTable ¶

func (i *StreamInput) SetTable(t tablestream.Table)

func (*StreamInput) Table ¶

func (i *StreamInput) Table() tablestream.Table

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL