servers

Documentation

Index

• func GetMaxUniqueTimeSeries() int
• func NewVMSelectServer(addr string, s *storage.Storage) (*vmselectapi.Server, error)
• type VMInsertServer
  • func NewVMInsertServer(addr string, storage *storage.Storage) (*VMInsertServer, error)
  • func (s *VMInsertServer) MustStop()

Functions

func GetMaxUniqueTimeSeries

func GetMaxUniqueTimeSeries() int

GetMaxUniqueTimeSeries returns the max metrics limit calculated by available resources. The calculation is split into calculateMaxUniqueTimeSeriesForResource for unit testing.

func NewVMSelectServer

func NewVMSelectServer(addr string, s *storage.Storage) (*vmselectapi.Server, error)

NewVMSelectServer starts new server at the given addr, which serves vmselect requests from the given s.

Types

type VMInsertServer

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

VMInsertServer processes connections from vminsert.

func NewVMInsertServer

func NewVMInsertServer(addr string, storage *storage.Storage) (*VMInsertServer, error)

NewVMInsertServer starts VMInsertServer at the given addr serving the given storage.

func (*VMInsertServer) MustStop

func (s *VMInsertServer) MustStop()

MustStop gracefully stops s so it no longer touches s.storage after returning.