transport

Documentation

Index

• func StartUnmarshalWorkers()
• func StopUnmarshalWorkers()
• type Server
  • func NewServer(vminsertAddr, vmselectAddr string, storage *storage.Storage) (*Server, error)
  • func (s *Server) MustClose()
  • func (s *Server) RunVMInsert()
  • func (s *Server) RunVMSelect()

Functions

func StartUnmarshalWorkers

func StartUnmarshalWorkers()

StartUnmarshalWorkers starts workers for unmarshaling data obtained from vminsert connections.

This function must be called before servers are created via NewServer.

func StopUnmarshalWorkers

func StopUnmarshalWorkers()

StopUnmarshalWorkers stops unmarshal workers which were started with StartUnmarshalWorkers.

This function must be called after Server.MustClose().

Types

type Server

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

Server processes connections from vminsert and vmselect.

func NewServer

func NewServer(vminsertAddr, vmselectAddr string, storage *storage.Storage) (*Server, error)

NewServer returns new Server.

func (*Server) MustClose

func (s *Server) MustClose()

MustClose gracefully closes the server, so it no longer touches s.storage after returning.

func (*Server) RunVMInsert

func (s *Server) RunVMInsert()

RunVMInsert runs a server accepting connections from vminsert.

func (*Server) RunVMSelect

func (s *Server) RunVMSelect()

RunVMSelect runs a server accepting connections from vmselect.