server

Documentation

Index

• Constants
• Variables
• type Server
  • func (s *Server) Close()
  • func (s *Server) ConfigureFlags()
  • func (s *Server) GetSessionTicketKey() [32]byte
  • func (s *Server) HandleShutdownSignal()
  • func (s *Server) Prepare() (db *zenodb.DB, run func() error, finalErr error)

Constants

const (
	DefaultClusterQueryConcurrency = 25
	DefaultNextQueryTimeout        = 5 * time.Minute
)

Variables

var (
	ErrInvalidID      = serrors.New("id below 0")
	ErrMissingID      = serrors.New("clustered server missing id")
	ErrAlreadyRunning = serrors.New("already running")
)

Types

type Server

type Server struct {
	DBDir                     string
	WebAssetsDir              string
	Vtime                     bool
	WALSync                   time.Duration
	MaxWALSize                int
	WALCompressionSize        int
	WhitelistedDimensions     string
	MaxMemory                 float64
	IterationCoalesceInterval time.Duration
	IterationConcurrency      int
	Addr                      string
	Listener                  net.Listener
	HTTPAddr                  string
	HTTPListener              net.Listener
	HTTPSAddr                 string
	HTTPSListener             net.Listener
	Router                    *mux.Router
	Password                  string
	PKFile                    string
	CertFile                  string
	CookieHashKey             string
	CookieBlockKey            string
	OauthClientID             string
	OauthClientSecret         string
	GitHubOrg                 string
	Insecure                  bool
	Passthrough               bool
	Capture                   string
	CaptureOverride           string
	Feed                      string
	FeedOverride              string
	ID                        int
	AllowZeroID               bool
	NumPartitions             int
	Partition                 int
	ClusterQueryConcurrency   int
	ClusterQueryTimeout       time.Duration
	NextQueryTimeout          time.Duration
	MaxFollowAge              time.Duration
	MaxFollowQueue            int
	TLSDomain                 string
	WebQueryCacheTTL          time.Duration
	WebQueryTimeout           time.Duration
	WebQueryConcurrencyLimit  int
	WebMaxResponseBytes       int
	ListenTimeout             time.Duration
	MaxReconnectWaitTime      time.Duration
	Panic                     func(err interface{})

	Schema         string
	AliasesFile    string
	EnableGeo      bool
	RedisCacheSize int
	// contains filtered or unexported fields
}

Server is a zeno server (standalone, leader of follower)

func (*Server) Close

func (s *Server) Close()

func (*Server) ConfigureFlags

func (s *Server) ConfigureFlags()

func (*Server) GetSessionTicketKey

func (s *Server) GetSessionTicketKey() [32]byte

GetSessionTicketKey allows us to reuse a session ticket key across restarts, which avoids excessive TLS renegotiation with old clients.

func (*Server) HandleShutdownSignal

func (s *Server) HandleShutdownSignal()

func (*Server) Prepare

func (s *Server) Prepare() (db *zenodb.DB, run func() error, finalErr error)

Prepare prepares the zeno server to run, returning a reference to the underlying db and a blocking function for actually running.