ingestserver

Jun 5, 2025

Changes in this version

type Server

+ RPCRecordWriter *writer.RecordWriter

+ func (s *Server) GetWriteService() *writer.Service

Sep 28, 2023

Changes in this version

+ func NewCommand(info app.ServerInfo) *app.Command

type Server

+ RecordWriter *coordinator.RecordWriter

+ SubscriberManager *coordinator.SubscriberManager

Sep 27, 2022

Changes in this version

+ func NewServer(conf config.Config, cmd *cobra.Command, logger *Logger.Logger) (app.Server, error)

+ type Server struct

+ Listener net.Listener

+ Logger *Logger.Logger

+ MetaClient *meta.Client

+ Node *meta.Node

+ PointsWriter *coordinator.PointsWriter

+ QueryExecutor *query.Executor

+ TSDBStore netstorage.Storage

+ func (s *Server) Close() error

+ func (s *Server) Err() <-chan error

+ func (s *Server) Open() error

+ type Service interface

+ Close func() error

+ Open func() error