utils

type FramingReader ¶

type FramingReader struct {
	// contains filtered or unexported fields
}

func NewFramingReader(r io.Reader) *FramingReader

func (f *FramingReader) Read(p []byte) (n int, err error)

type LogLevel ¶

type LogLevel int

var (
	Debug  LogLevel = 1
	Normal LogLevel = 2
	Urgent LogLevel = 3
	None   LogLevel = 4
)

func ParseLogLevel(val string) (LogLevel, error)

func (l LogLevel) String() string

type LogWrapper ¶

type LogWrapper struct {
	Logger
}

func L(ctx context.Context) LogWrapper

func (l LogWrapper) Debugf(format string, v ...interface{})

func (l LogWrapper) Normalf(format string, v ...interface{})

func (l LogWrapper) Urgentf(format string, v ...interface{})

type Logger ¶

type Logger interface {
	Printf(level LogLevel, format string, v ...interface{})
}

func StandardLogger(minLevel LogLevel) Logger

type LoggerFunc ¶

type LoggerFunc func(level LogLevel, format string, v ...interface{})

func (f LoggerFunc) Printf(level LogLevel, format string, v ...interface{})

type ReaderBuf ¶

type ReaderBuf struct {
	// contains filtered or unexported fields
}

ReaderBuf wraps a Reader with a goroutine that fills an internal buffer of the next read. Using ReaderBuf will keep the next read pipelined and ready. Calling a read (however small) will trigger the next pipelined read up to the internal buffer size. If you want many small reads, this should probably be wrapped in a bufio.Reader. ReaderBuf should be closed when done to make sure the goroutine gets shut down.

func NewReaderBuf(r io.ReadCloser) *ReaderBuf

func (rb *ReaderBuf) Close() error

func (rb *ReaderBuf) Read(p []byte) (n int, err error)

type ReaderFunc ¶

type ReaderFunc func(p []byte) (n int, err error)

func (f ReaderFunc) Read(p []byte) (n int, err error)

type UnframingReader ¶

type UnframingReader struct {
	// contains filtered or unexported fields
}

func NewUnframingReader(r io.Reader) *UnframingReader

func (u *UnframingReader) Read(p []byte) (n int, err error)