server

package

Go to main page

Versions in this module

v1

v1.0.4

Jul 20, 2017

v1.0.3

Jul 6, 2017

Changes in this version

type TestServer

+ func (ts *TestServer) GetStores() interface{}

v1.0.2

Jun 7, 2017

Changes in this version

type Config

+ func (cfg *Config) Report(ctx context.Context)

+ func (cfg *Config) String() string

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL