Versions in this module Expand all Collapse all v1 v1.0.1 May 18, 2017 Changes in this version + const FirstNodeID + const TestUser + var GracefulDrainModes = []serverpb.DrainMode + var TestServerFactory = testServerFactoryImpl + func ExpectedInitialRangeCount(db *client.DB) (int, error) + func GetBootstrapSchema() sqlbase.MetadataSchema + func GetTotalMemory() (int64, error) + func SetOpenFileLimitForOneStore() (int, error) + func WaitForInitialSplits(db *client.DB) error + type Config struct + AmbientCtx log.AmbientContext + Attrs string + CacheSize int64 + ConsistencyCheckInterval time.Duration + ConsistencyCheckPanicOnFailure bool + EventLogEnabled bool + GossipBootstrapResolvers []resolver.Resolver + JoinList base.JoinListType + Linearizable bool + ListeningURLFile string + Locality roachpb.Locality + MaxOffset time.Duration + MetricsSampleInterval time.Duration + NodeAttributes roachpb.Attributes + PIDFile string + RaftElectionTimeoutTicks int + RaftTickInterval time.Duration + RetryOptions retry.Options + SQLMemoryPoolSize int64 + ScanInterval time.Duration + ScanMaxIdleTime time.Duration + SendNextTimeout time.Duration + SocketFile string + Stores base.StoreSpecList + TestingKnobs base.TestingKnobs + TimeSeriesServerConfig ts.ServerConfig + TimeUntilStoreDead *settings.DurationSetting + func MakeConfig() Config + func (cfg *Config) CreateEngines() (Engines, error) + func (cfg *Config) FilterGossipBootstrapResolvers(ctx context.Context, listen, advert net.Addr) []resolver.Resolver + func (cfg *Config) InitNode() error + func (cfg Config) HistogramWindowInterval() time.Duration + type Engines []engine.Engine + func (e *Engines) Close() + 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) ClusterStores() []roachpb.ReplicationTarget + 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) AdminURL() string + func (ts *TestServer) Clock() *hlc.Clock + 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) ExpectedInitialRangeCount() (int, error) + func (ts *TestServer) GetFirstStoreID() roachpb.StoreID + func (ts *TestServer) GetHTTPClient() (http.Client, error) + func (ts *TestServer) GetNode() *Node + func (ts *TestServer) Gossip() *gossip.Gossip + 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