agent

Jun 13, 2023

Changes in this version

type Agent

+ MaxFileSize int64

May 5, 2023

Changes in this version

type Agent

+ func (a *Agent) Query(ctx context.Context, w io.Writer, q string)

Apr 4, 2023

Changes in this version

type Agent

+ KeyTimestamp string

+ Partition time.Duration

+ Stderr io.Writer

Apr 14, 2022

Changes in this version

type Agent

+ func (a *Agent) Close() error

type DB

+ func (d *DB) Close() (err error)

+ func (d *DB) ReadStream(ctx context.Context, id string) (io.WriterTo, error)

+ type MemFS struct

+ func NewMemFS() *MemFS

+ func (ff *MemFS) Open(name string) (fs.File, error)

+ func (ff *MemFS) OpenFile(name string, flags int, mode os.FileMode) (_ io.ReadWriteCloser, err error)

+ type OSFS struct

+ func NewOSFS(root string) OSFS

+ func (ff OSFS) Open(name string) (fs.File, error)

+ func (ff OSFS) OpenFile(name string, flags int, mode os.FileMode) (_ io.ReadWriteCloser, err error)

+ func (ff OSFS) ReadDir(name string) ([]fs.DirEntry, error)

+ func (ff OSFS) Sub(dir string) (_ fs.FS, err error)

+ type OpenFiler interface

+ OpenFile func(string, int, os.FileMode) (io.ReadWriteCloser, error)

+ type Stream struct

+ CompressorBlockSize int

+ MaxBlockEvents int

+ MaxDataSize int64

+ MaxEvents int

+ MaxFileSize int64

+ Partition time.Duration

+ TimeFormat string

+ func NewStream(fs fs.FS) (s *Stream, err error)

+ func (s *Stream) Close() (err error)

+ func (s *Stream) OpenReader() (*StreamReader, error)

+ func (s *Stream) Write(p []byte) (n int, err error)

+ func (s *Stream) WriteEvent(ev *parse.LowEvent) (err error)

+ type StreamInfo struct

+ ID string

+ Labels tlog.Labels

+ type StreamReader struct

+ func (r *StreamReader) Close() error

+ func (r *StreamReader) WriteTo(w io.Writer) (n int64, err error)

Feb 28, 2022

Changes in this version

type Agent

+ func (a *Agent) Serve0(ctx context.Context, w io.Writer) (err error)

+ func (a *Agent) ServeEvents(w http.ResponseWriter, req *http.Request)

+ func (a *Agent) ServeLabels(w http.ResponseWriter, req *http.Request)

+ func (a *Agent) ServeStreams(w http.ResponseWriter, req *http.Request)

+ func (a *Agent) Write0(p []byte) (_ int, err error)

+ type DB struct

+ MaxFileEvents int

+ MaxFileSize int64

+ func NewDB(dir string) (*DB, error)

+ func (d *DB) Stream(ctx context.Context, w io.Writer, q string, start int64) (err error)

+ func (d *DB) Write(p []byte) (i int, err error)

Dec 9, 2021

Changes in this version

type Agent

+ func (a *Agent) Serve(ctx context.Context, w io.Writer) (err error)

+ func (a *Agent) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (a *Agent) Write(p []byte) (_ int, err error)

+ type Sink struct

+ func NewSink(w io.Writer) *Sink

+ func (w *Sink) HandleConn(ctx context.Context, c net.Conn) (err error)

+ func (w *Sink) Listen(ctx context.Context, l net.Listener) (err error)

+ func (w *Sink) ListenPacket(ctx context.Context, p net.PacketConn) (err error)

Jun 23, 2021

Changes in this version

+ type Agent struct

+ MaxEvents int

+ func New() (a *Agent)

+ func (a *Agent) Listen(l net.Listener) (err error)

+ func (a *Agent) ListenPacket(p net.PacketConn) error

+ func (a *Agent) ServeConn(c net.Conn) (err error)

+ func (a *Agent) Subscribe(ctx context.Context, c io.Writer, n int, follow, addlabels bool) (err error)

+ func (a *Agent) Writer(addr net.Addr) (c *connWriter)

+ type Conn struct