server

package

Go to main page

Versions in this module

v1

v1.1.3

Nov 21, 2017

v1.1.2

Oct 26, 2017

v1.1.1

Oct 16, 2017

v1.1.0

Oct 4, 2017

Changes in this version

+ const DefaultCacheSize

+ const DefaultTempStoreMaxSizeBytesInMemStore

+ var ClusterSettings *cluster.Settings

+ var LicenseCheckFn = func(st *cluster.Settings, cluster uuid.UUID, org, feature string) error

+ func MakeTempStoreSpecFromStoreSpec(spec base.StoreSpec) base.StoreSpec

type Config

+ EnableWebSessionAuthentication bool

+ Settings *cluster.Settings

+ TempStoreMaxSizeBytes int64

+ TempStoreSpec base.StoreSpec

+ func (cfg *Config) RequireWebSession() bool

+ type DebugRemoteMode string

+ const DebugRemoteAny

+ const DebugRemoteLocal

+ const DebugRemoteOff

+ 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 Server

+ func (s *Server) ClusterSettings() *cluster.Settings

+ func (s *Server) Decommission(ctx context.Context, setTo bool, nodeIDs []roachpb.NodeID) error

type TestServer

+ func (ts *TestServer) Addr() string

+ func (ts *TestServer) ClusterSettings() *cluster.Settings

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

+ func (ts *TestServer) GetAuthenticatedHTTPClient() (http.Client, error)

+ func (ts *TestServer) GetRangeLease(ctx context.Context, key roachpb.Key) (_ roachpb.Lease, now hlc.Timestamp, _ error)

+ func (ts *TestServer) HTTPAddr() string

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

v1.1.0-rc.1

Oct 4, 2017

v1.0.6

Sep 9, 2017

v1.0.5

Aug 17, 2017

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