vminsertapi

package

v1.129.1-cluster Latest Latest Go to latest Published: Nov 4, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	MetricRowsRpcCall = RPCCall{
		Name:          "metric_rows",
		VersionedName: "writeRows_v1",
	}
)

func SendRPCRequestToConn(bc *handshake.BufferedConn, rpcName string, buf []byte) error

SendRPCRequestToConn sends given buf over provided bc to the server

func SendToConn(bc *handshake.BufferedConn, buf []byte) error

SendToConn sends given buf over provided bc to the server

type API interface {
	WriteRows(rows []storage.MetricRow) error
	IsReadOnly() bool
}

API must implement vminsert API.

type RPCCall struct {
	Name          string
	VersionedName string
}

RPCCall defines rpc call from vminsert to vmstorage

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

RequestCtx defines server request context

func NewRequestCtx(bc *handshake.BufferedConn) *RequestCtx

NewRequestCtx returns new server request context for given BufferedConn

func (ctx *RequestCtx) ReadRPCName() ([]byte, error)

ReadRPCName reads rpc call name from the client

Returned bytes slice is valid until any ctx method call

func (ctx *RequestCtx) WriteErrorMessage(err error) error

WriteErrorMessage sends given error to the client

func (ctx *RequestCtx) WriteString(s string) error

WriteString writes provided string to the client

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

VMInsertServer processes connections from vminsert.

func NewVMInsertServer(addr string, connectionTimeout time.Duration, listenerName string, api API, tc *tls.Config) (*VMInsertServer, error)

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

func (s *VMInsertServer) MustStop()

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