Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mstreamer

package module

Go to main page

Versions in this module

v0

v0.1.6

May 19, 2023

v0.1.5

May 19, 2023

v0.1.4

May 17, 2023

v0.1.3

May 17, 2023

Changes in this version

type Measure

+ func (m *Measure) InsertOrUpdateTag(name string, data string)

v0.1.2

May 17, 2023

Changes in this version

type Output

+ func NewOutput(handler func(m Measure) error) (Output, error)

v0.1.1

May 16, 2023

Changes in this version

+ const TBool

+ const TFloat

+ const TInt

+ const TNil

+ const TString

+ const TUint

+ func ParseValue(t FieldType, value string) interface

+ type ComposedFilter func(flts ...Filter) (Filter, error)

+ type ComposedInput func(Source, Encoder) (Input, error)

+ type ComposedOutput func(Decoder, Sinker) (Output, error)

+ type Decoder func(Feedback, MeasureReader) (io.ReadCloser, error)

+ func NewDecoder(adapter DecoderAdapter) (Decoder, error)

+ func NewGenericDecoder(decw DecoderToWriter) (Decoder, error)

+ type DecoderAdapter func(Feedback, MeasureReader, io.Writer)

+ type DecoderToWriter func(Measure, io.Writer) error

+ type EncodeToWriter func(interface{}, MeasureWriter) error

+ type Encoder func(Feedback, io.ReadCloser) (MeasureReader, error)

+ func NewEncoder(adapter EncoderAdapter) (Encoder, error)

+ func NewFromJSONEncoder(data interface{}, encode EncodeToWriter) (Encoder, error)

+ type EncoderAdapter func(Feedback, io.Reader, MeasureWriter)

+ type Feedback func(format string, a ...interface{})

+ type Field struct

+ Data interface{}

+ Name string

+ Type FieldType

+ func ParseField(name, kind, value string) Field

+ func (f *Field) Compare(o Field) (int, error)

+ type FieldType byte

+ func FieldValueType(value interface{}) FieldType

+ func ParseType(str string) FieldType

+ type Filter func(Feedback, MeasureReader) (MeasureReader, error)

+ func NewByPassFilter() (Filter, error)

+ func NewComposedFilter(flts ...Filter) (Filter, error)

+ func NewFieldInjectorFilter(fields ...Field) (Filter, error)

+ func NewFilter(adapter FilterAdapter, finalizer FinalizeAdapter) (Filter, error)

+ func NewLogFilter(label string) (Filter, error)

+ func NewMeasureCountFilter() (Filter, error)

+ func NewNameInjectorFilter(name string) (Filter, error)

+ func NewNameSanityFilter() (Filter, error)

+ func NewTagInjectorFilter(tags ...Tag) (Filter, error)

+ func NewTimeInjectorFilter(time int64) (Filter, error)

+ type FilterAdapter func(Feedback, *Measure, MeasureWriter)

+ type FilteredInput func(Input, Filter) (Input, error)

+ type FilteredOutput func(Filter, Output) (Output, error)

+ type FinalizeAdapter func(Feedback, MeasureWriter)

+ type Helpers struct

+ IOPipe func() (*io.PipeReader, *io.PipeWriter)

+ IOcopy func(io.Writer, io.Reader)

+ NewReader func(io.Reader) MeasureReader

+ NewWriter func(io.Writer) MeasureWriter

+ type IOPipeline func(Input, Filter, Output) (Runnable, error)

+ type Input func(Feedback) (MeasureReader, error)

+ func NewComposedInput(src Source, enc Encoder) (Input, error)

+ func NewFilteredInput(inp Input, flt Filter) (Input, error)

+ func NewInputFromProducer(producer func(f Feedback, w MeasureWriter)) (Input, error)

+ func NewMergedInput(inputs ...Input) (Input, error)

+ type Measure struct

+ Flds []Field

+ Name string

+ Tags []Tag

+ Time int64

+ func (m *Measure) Field(name string) (Field, error)

+ func (m *Measure) FieldValue(name string) (interface{}, error)

+ func (m *Measure) MD5() []byte

+ func (m *Measure) SHA1() []byte

+ func (m *Measure) Tag(name string) (Tag, error)

+ func (m *Measure) TagValue(name string) (string, error)

+ type MeasureReader interface

+ Read func(*Measure) error

+ func NewReader(r io.Reader) MeasureReader

+ type MeasureWriter interface

+ Write func(Measure) error

+ func NewWriter(w io.Writer) MeasureWriter

+ type MergedInput func(...Input) (Input, error)

+ type MergedOutput func(...Output) (Output, error)

+ type Output func(Feedback, MeasureReader) error

+ func NewComposedOutput(dec Decoder, snk Sinker) (Output, error)

+ func NewFilteredOutput(flt Filter, out Output) (Output, error)

+ func NewMergedOutput(outputs ...Output) (Output, error)

+ type PushSinker func(Feedback, io.ReadCloser) error

+ type Runnable func(Feedback) error

+ func NewIOPipeline(i Input, f Filter, o Output) (Runnable, error)

+ type Sinker func(Feedback, io.ReadCloser) error

+ func NewBasicHTTPSinker(url, user, pwd string) (Sinker, error)

+ func NewPushSinker(push PushSinker) (Sinker, error)

+ func NewSinker(adapter SinkerAdapter) (Sinker, error)

+ func NewStdoutSinker() (Sinker, error)

+ func NewTCPSinker(addr string) (Sinker, error)

+ func NewWriteCloserSinker(out io.WriteCloser) (Sinker, error)

+ func NewWriterSinker(out io.Writer) (Sinker, error)

+ type SinkerAdapter func(Feedback, io.ReadCloser) error

+ type Source func(Feedback) (io.ReadCloser, error)

+ func NewBasicHTTPSource(url, user, pwd string) (Source, error)

+ func NewGetterSource(get SourceGetter) (Source, error)

+ func NewSource(adapter SourceAdapter) (Source, error)

+ type SourceAdapter func(Feedback, io.Writer)

+ type SourceGetter func() (io.ReadCloser, error)

+ type Tag struct

+ Data string

+ Name string

+ func MakeTag(name, value string) Tag