prom

Documentation

Index

• type Prom
  • func New(options opt.Options) (*Prom, error)
  • func (p *Prom) Out() <-chan promql.Matrix
  • func (p *Prom) Run(ctx context.Context) error
• type SequentialQueryTracker
  • func NewSequentialQueryTracker() SequentialQueryTracker
  • func (s SequentialQueryTracker) Close() error
  • func (s SequentialQueryTracker) Delete(int)
  • func (s SequentialQueryTracker) GetMaxConcurrent() int
  • func (s SequentialQueryTracker) Insert(ctx context.Context, _ string) (int, error)

Types

type Prom

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

func New

func New(options opt.Options) (*Prom, error)

func (*Prom) Out

func (p *Prom) Out() <-chan promql.Matrix

func (*Prom) Run

func (p *Prom) Run(ctx context.Context) error

type SequentialQueryTracker

type SequentialQueryTracker chan struct{}

SequentialQueryTracker is a query tracker that allows only one query to be active at a time.

func NewSequentialQueryTracker

func NewSequentialQueryTracker() SequentialQueryTracker

func (SequentialQueryTracker) Close

func (s SequentialQueryTracker) Close() error

func (SequentialQueryTracker) Delete

func (s SequentialQueryTracker) Delete(int)

func (SequentialQueryTracker) GetMaxConcurrent

func (s SequentialQueryTracker) GetMaxConcurrent() int

func (SequentialQueryTracker) Insert

func (s SequentialQueryTracker) Insert(ctx context.Context, _ string) (int, error)