reader

Documentation

Index

• type LokiReader
• type Reader
  • func NewReader(writer io.Writer, receivedChan chan time.Time, tls bool, address string, ...) *Reader
  • func (r *Reader) Query(start time.Time, end time.Time) ([]time.Time, error)
  • func (r *Reader) Stop()

Types

type LokiReader

type LokiReader interface {
	Query(start time.Time, end time.Time) ([]time.Time, error)
}

type Reader

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

func NewReader

func NewReader(writer io.Writer, receivedChan chan time.Time, tls bool,
	address string, user string, pass string, labelName string, labelVal string) *Reader

func (*Reader) Query

func (r *Reader) Query(start time.Time, end time.Time) ([]time.Time, error)

func (*Reader) Stop

func (r *Reader) Stop()