file

Documentation

Overview

package file implements the Streamer interface backed by a file buffer.

Index

• type Streamer
  • func New(filename string) (*Streamer, error)
  • func (s *Streamer) Close() error
  • func (s *Streamer) Follow(ctx context.Context, offset int64, writer io.Writer) error
  • func (s *Streamer) Stop()
  • func (s *Streamer) Write(p []byte) (int, error)

Types

type Streamer

type Streamer struct {
	io.WriteCloser
	// contains filtered or unexported fields
}

func New

func New(filename string) (*Streamer, error)

func (*Streamer) Close

func (s *Streamer) Close() error

func (*Streamer) Follow

func (s *Streamer) Follow(ctx context.Context, offset int64, writer io.Writer) error

func (*Streamer) Stop

func (s *Streamer) Stop()

func (*Streamer) Write

func (s *Streamer) Write(p []byte) (int, error)