Versions in this module Expand all Collapse all v1 v1.1.5 Jan 29, 2018 Changes in this version + const DefaultCacheSize + const DefaultTempStoreMaxSizeBytesInMemStore + const FirstNodeID + const TestUser + var GracefulDrainModes = []serverpb.DrainMode + var LicenseCheckFn = func(st *cluster.Settings, cluster uuid.UUID, org, feature string) error + var TestServerFactory = testServerFactoryImpl + func ExpectedInitialRangeCount(db *client.DB) (int, error) + func GetBootstrapSchema() sqlbase.MetadataSchema + func GetTotalMemory(ctx context.Context) (int64, error) + func MakeTempStoreSpecFromStoreSpec(spec base.StoreSpec) base.StoreSpec + func SetOpenFileLimitForOneStore() (uint64, error) + func WaitForInitialSplits(db *client.DB) error + type Config struct + AmbientCtx log.AmbientContext + Attrs string + CacheSize int64 + EnableWebSessionAuthentication bool + EventLogEnabled bool + Extra1_0Compatibility bool + GossipBootstrapResolvers []resolver.Resolver + JoinList base.JoinListType + Linearizable bool + ListeningURLFile string + Locality roachpb.Locality + MaxOffset MaxOffsetType + MetricsSampleInterval time.Duration + NodeAttributes roachpb.Attributes + PIDFile string + RetryOptions retry.Options + SQLMemoryPoolSize int64 + ScanInterval time.Duration + ScanMaxIdleTime time.Duration + Settings *cluster.Settings + SocketFile string + Stores base.StoreSpecList + TempStoreMaxSizeBytes int64 + TempStoreSpec base.StoreSpec + TestingKnobs base.TestingKnobs + TimeSeriesServerConfig ts.ServerConfig + func MakeConfig(st *cluster.Settings) Config + func (cfg *Config) CreateEngines(ctx context.Context) (Engines, error) + func (cfg *Config) FilterGossipBootstrapResolvers(ctx context.Context, listen, advert net.Addr) []resolver.Resolver + func (cfg *Config) InitNode() error + func (cfg *Config) Report(ctx context.Context) + func (cfg *Config) RequireWebSession() bool + func (cfg *Config) String() string + func (cfg Config) HistogramWindowInterval() time.Duration + type DebugRemoteMode string + const DebugRemoteAny + const DebugRemoteLocal + const DebugRemoteOff + type Engines []engine.Engine + func (e *Engines) Close() + type ListenError struct + Addr string + type MaxOffsetType time.Duration + func (mo *MaxOffsetType) Set(v string) error + func (mo *MaxOffsetType) String() string + func (mo *MaxOffsetType) Type() string + type Node struct + ClusterID uuid.UUID + Descriptor roachpb.NodeDescriptor + func NewNode(cfg storage.StoreConfig, recorder *status.MetricsRecorder, ...) *Node + func (n *Node) AnnotateCtx(ctx context.Context) context.Context + func (n *Node) AnnotateCtxWithSpan(ctx context.Context, opName string) (context.Context, opentracing.Span) + func (n *Node) Batch(ctx context.Context, args *roachpb.BatchRequest) (*roachpb.BatchResponse, error) + func (n *Node) IsDraining() bool + func (n *Node) SetDraining(drain bool) error + func (n *Node) String() string + type Server struct + func NewServer(cfg Config, stopper *stop.Stopper) (*Server, error) + func (s *Server) AnnotateCtx(ctx context.Context) context.Context + func (s *Server) AnnotateCtxWithSpan(ctx context.Context, opName string) (context.Context, opentracing.Span) + func (s *Server) ClusterID() uuid.UUID + func (s *Server) ClusterSettings() *cluster.Settings + func (s *Server) Decommission(ctx context.Context, setTo bool, nodeIDs []roachpb.NodeID) error + func (s *Server) Drain(on []serverpb.DrainMode) ([]serverpb.DrainMode, error) + func (s *Server) InitialBoot() bool + func (s *Server) NodeID() roachpb.NodeID + func (s *Server) PeriodicallyCheckForUpdates() + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (s *Server) Start(ctx context.Context) error + func (s *Server) Stop() + func (s *Server) Undrain(off []serverpb.DrainMode) []serverpb.DrainMode + func (ts *Server) SetDistSQLSpanResolver(spanResolver interface{}) + type TestServer struct + Cfg *Config + func (ts *TestServer) Addr() string + func (ts *TestServer) AdminURL() string + func (ts *TestServer) Clock() *hlc.Clock + func (ts *TestServer) ClusterSettings() *cluster.Settings + func (ts *TestServer) DB() *client.DB + func (ts *TestServer) DistSQLServer() interface{} + func (ts *TestServer) DistSender() *kv.DistSender + func (ts *TestServer) Engines() []engine.Engine + func (ts *TestServer) Executor() interface{} + func (ts *TestServer) ExpectedInitialRangeCount() (int, error) + func (ts *TestServer) GetAuthenticatedHTTPClient() (http.Client, error) + func (ts *TestServer) GetFirstStoreID() roachpb.StoreID + func (ts *TestServer) GetHTTPClient() (http.Client, error) + func (ts *TestServer) GetNode() *Node + func (ts *TestServer) GetRangeLease(ctx context.Context, key roachpb.Key) (_ roachpb.Lease, now hlc.Timestamp, _ error) + func (ts *TestServer) GetStores() interface{} + func (ts *TestServer) Gossip() *gossip.Gossip + func (ts *TestServer) HTTPAddr() string + func (ts *TestServer) JobRegistry() interface{} + func (ts *TestServer) KVClient() interface{} + func (ts *TestServer) KVDB() interface{} + func (ts *TestServer) LeaseManager() interface{} + func (ts *TestServer) LookupRange(key roachpb.Key) (roachpb.RangeDescriptor, error) + func (ts *TestServer) MustGetSQLCounter(name string) int64 + func (ts *TestServer) MustGetSQLNetworkCounter(name string) int64 + func (ts *TestServer) PGServer() *pgwire.Server + func (ts *TestServer) RPCContext() *rpc.Context + func (ts *TestServer) ServingAddr() string + func (ts *TestServer) SplitRange(splitKey roachpb.Key) (roachpb.RangeDescriptor, roachpb.RangeDescriptor, error) + func (ts *TestServer) Start(params base.TestServerArgs) error + func (ts *TestServer) Stopper() *stop.Stopper + func (ts *TestServer) Stores() *storage.Stores + func (ts *TestServer) TsDB() *ts.DB + func (ts *TestServer) WaitForInitialSplits() error + func (ts *TestServer) WriteSummaries() error
Go to main page