transport

Documentation

Index

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

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.