redis

Documentation

Index

• type Line
  • func (l Line) Format(f sdk.CDNReaderFormat) ([]byte, error)
• type Reader
  • func (r *Reader) Close() error
  • func (r *Reader) Read(p []byte) (n int, err error)
• type Writer
  • func (w *Writer) Close() error
  • func (w *Writer) Write(p []byte) (int, error)

Types

type Line

type Line struct {
	Number int64  `json:"number"`
	Value  string `json:"value"`
	Since  int64  `json:"since,omitempty"`
}

func (Line) Format

func (l Line) Format(f sdk.CDNReaderFormat) ([]byte, error)

type Reader

type Reader struct {
	Store      cache.ScoredSetStore
	ApiRefHash string
	ItemID     string
	PrefixKey  string

	From int64 // the offset that we want to use when reading lines from Redis, allows negative value to get last lines
	Size uint  // the count of lines that we want to read (0 means to the end)

	Format sdk.CDNReaderFormat

	Sort int64 // < 0 for latest logs first, >= 0 for older logs first
	// contains filtered or unexported fields
}

func (*Reader) Close

func (r *Reader) Close() error

Close is declared ot match buffer unit interface

func (*Reader) Read

func (r *Reader) Read(p []byte) (n int, err error)

type Writer

type Writer struct {
	Store     cache.ScoredSetStore
	ItemID    string
	PrefixKey string
	// contains filtered or unexported fields
}

func (*Writer) Close

func (w *Writer) Close() error

Close will write the end of the buffer to store in case the last line is not ended by \n

func (*Writer) Write

func (w *Writer) Write(p []byte) (int, error)