Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v1

v1.1.0-beta

Feb 24, 2018

v1.0.8

Jan 29, 2018

Changes in this version

type Handler

+ func (h *Handler) AddBalanceHotRegionScheduler() error

+ func (h *Handler) AddBalanceRegionScheduler() error

type Server

+ func (s *Server) SetLogLevel(level string)

v1.0.0

Oct 16, 2017

Changes in this version

+ var ErrNotBootstrapped = errors.New("TiKV cluster is not bootstrapped, please start TiKV first")

+ var PDBuildTS = "None"

+ var PDGitBranch = "None"

+ var PDGitHash = "None"

+ var PDReleaseVersion = "1.0.0"

+ func GetMembers(etcdClient *clientv3.Client) ([]*pdpb.Member, error)

+ func LogPDInfo()

+ func NewTestServer(c *check.C) (*Config, *Server, CleanupFunc)

+ func ParseUrls(s string) ([]url.URL, error)

+ func PrepareJoinCluster(cfg *Config) error

+ func PrintPDInfo()

+ func StartMonitor(now func() time.Time, systimeErrHandler func())

+ type CleanupFunc func()

+ type ClusterStatus struct

+ RaftBootstrapTime time.Time

+ type Config struct

+ AdvertiseClientUrls string

+ AdvertisePeerUrls string

+ AutoCompactionRetention int

+ ClientUrls string

+ DataDir string

+ ElectionInterval typeutil.Duration

+ EnableNamespace bool

+ InitialCluster string

+ InitialClusterState string

+ Join string

+ LeaderLease int64

+ Log logutil.LogConfig

+ LogFileDeprecated string

+ LogLevelDeprecated string

+ Metric metricutil.MetricConfig

+ Name string

+ PeerUrls string

+ QuotaBackendBytes typeutil.ByteSize

+ Replication ReplicationConfig

+ Schedule ScheduleConfig

+ TickInterval typeutil.Duration

+ TsoSaveInterval typeutil.Duration

+ Version bool

+ WarningMsgs []string

+ func NewConfig() *Config

+ func NewTestMultiConfig(count int) []*Config

+ func NewTestSingleConfig() *Config

+ func (c *Config) Parse(arguments []string) error

+ func (c *Config) String() string

+ type Handler struct

+ func (h *Handler) AddAddPeerOperator(regionID uint64, toStoreID uint64) error

+ func (h *Handler) AddBalanceLeaderScheduler() error

+ func (h *Handler) AddEvictLeaderScheduler(storeID uint64) error

+ func (h *Handler) AddGrantLeaderScheduler(storeID uint64) error

+ func (h *Handler) AddRemovePeerOperator(regionID uint64, fromStoreID uint64) error

+ func (h *Handler) AddScheduler(s schedule.Scheduler, args ...string) error

+ func (h *Handler) AddShuffleLeaderScheduler() error

+ func (h *Handler) AddShuffleRegionScheduler() error

+ func (h *Handler) AddTransferLeaderOperator(regionID uint64, storeID uint64) error

+ func (h *Handler) AddTransferPeerOperator(regionID uint64, fromStoreID, toStoreID uint64) error

+ func (h *Handler) AddTransferRegionOperator(regionID uint64, storeIDs map[uint64]struct{}) error

+ func (h *Handler) GetAdminOperators() ([]*schedule.Operator, error)

+ func (h *Handler) GetHistoryOperators() ([]*schedule.Operator, error)

+ func (h *Handler) GetHistoryOperatorsOfKind(kind core.ResourceKind) ([]*schedule.Operator, error)

+ func (h *Handler) GetHotReadRegions() *core.StoreHotRegionInfos

+ func (h *Handler) GetHotReadStores() map[uint64]uint64

+ func (h *Handler) GetHotWriteRegions() *core.StoreHotRegionInfos

+ func (h *Handler) GetHotWriteStores() map[uint64]uint64

+ func (h *Handler) GetLeaderOperators() ([]*schedule.Operator, error)

+ func (h *Handler) GetOperator(regionID uint64) (*schedule.Operator, error)

+ func (h *Handler) GetOperators() ([]*schedule.Operator, error)

+ func (h *Handler) GetOperatorsOfKind(kind core.ResourceKind) ([]*schedule.Operator, error)

+ func (h *Handler) GetRegionOperators() ([]*schedule.Operator, error)

+ func (h *Handler) GetSchedulers() ([]string, error)

+ func (h *Handler) RemoveOperator(regionID uint64) error

+ func (h *Handler) RemoveScheduler(name string) error

+ type RaftCluster struct

+ func (c *RaftCluster) BuryStore(storeID uint64, force bool) error

+ func (c *RaftCluster) GetConfig() *metapb.Cluster

+ func (c *RaftCluster) GetNamespaceClassifier() namespace.Classifier

+ func (c *RaftCluster) GetRegionByID(regionID uint64) (*metapb.Region, *metapb.Peer)

+ func (c *RaftCluster) GetRegionByKey(regionKey []byte) (*metapb.Region, *metapb.Peer)

+ func (c *RaftCluster) GetRegionInfoByID(regionID uint64) *core.RegionInfo

+ func (c *RaftCluster) GetRegionInfoByKey(regionKey []byte) *core.RegionInfo

+ func (c *RaftCluster) GetRegions() []*metapb.Region

+ func (c *RaftCluster) GetStore(storeID uint64) (*core.StoreInfo, error)

+ func (c *RaftCluster) GetStores() []*metapb.Store

+ func (c *RaftCluster) HandleRegionHeartbeat(region *core.RegionInfo) error

+ func (c *RaftCluster) RemoveStore(storeID uint64) error

+ func (c *RaftCluster) SetStoreState(storeID uint64, state metapb.StoreState) error

+ func (c *RaftCluster) SetStoreWeight(storeID uint64, leader, region float64) error

+ func (c *RaftCluster) UpdateStoreLabels(storeID uint64, labels []*metapb.StoreLabel) error

+ type Replication struct

+ func (r *Replication) GetLocationLabels() []string

+ func (r *Replication) GetMaxReplicas() int

+ func (r *Replication) SetMaxReplicas(replicas int)

+ type ReplicationConfig struct

+ LocationLabels typeutil.StringSlice

+ MaxReplicas uint64

+ type ScheduleConfig struct

+ LeaderScheduleLimit uint64

+ MaxSnapshotCount uint64

+ MaxStoreDownTime typeutil.Duration

+ RegionScheduleLimit uint64

+ ReplicaScheduleLimit uint64

+ Schedulers SchedulerConfigs

+ type SchedulerConfig struct

+ Args []string

+ Type string

+ type SchedulerConfigs []SchedulerConfig

+ type Server struct

+ func CreateServer(cfg *Config, apiRegister func(*Server) http.Handler) (*Server, error)

+ func (s *Server) AllocID(ctx context.Context, request *pdpb.AllocIDRequest) (*pdpb.AllocIDResponse, error)

+ func (s *Server) AskSplit(ctx context.Context, request *pdpb.AskSplitRequest) (*pdpb.AskSplitResponse, error)

+ func (s *Server) Bootstrap(ctx context.Context, request *pdpb.BootstrapRequest) (*pdpb.BootstrapResponse, error)

+ func (s *Server) Close()

+ func (s *Server) ClusterID() uint64

+ func (s *Server) GetAddr() string

+ func (s *Server) GetClient() *clientv3.Client

+ func (s *Server) GetCluster() *metapb.Cluster

+ func (s *Server) GetClusterConfig(ctx context.Context, request *pdpb.GetClusterConfigRequest) (*pdpb.GetClusterConfigResponse, error)

+ func (s *Server) GetClusterStatus() (*ClusterStatus, error)

+ func (s *Server) GetConfig() *Config

+ func (s *Server) GetEndpoints() []string

+ func (s *Server) GetHandler() *Handler

+ func (s *Server) GetLeader() (*pdpb.Member, error)

+ func (s *Server) GetMembers(context.Context, *pdpb.GetMembersRequest) (*pdpb.GetMembersResponse, error)

+ func (s *Server) GetRaftCluster() *RaftCluster

+ func (s *Server) GetRegion(ctx context.Context, request *pdpb.GetRegionRequest) (*pdpb.GetRegionResponse, error)

+ func (s *Server) GetRegionByID(ctx context.Context, request *pdpb.GetRegionByIDRequest) (*pdpb.GetRegionResponse, error)

+ func (s *Server) GetReplicationConfig() *ReplicationConfig

+ func (s *Server) GetScheduleConfig() *ScheduleConfig

+ func (s *Server) GetStore(ctx context.Context, request *pdpb.GetStoreRequest) (*pdpb.GetStoreResponse, error)

+ func (s *Server) ID() uint64

+ func (s *Server) IsBootstrapped(ctx context.Context, request *pdpb.IsBootstrappedRequest) (*pdpb.IsBootstrappedResponse, error)

+ func (s *Server) IsLeader() bool

+ func (s *Server) Name() string

+ func (s *Server) PutClusterConfig(ctx context.Context, request *pdpb.PutClusterConfigRequest) (*pdpb.PutClusterConfigResponse, error)

+ func (s *Server) PutStore(ctx context.Context, request *pdpb.PutStoreRequest) (*pdpb.PutStoreResponse, error)

+ func (s *Server) RegionHeartbeat(stream pdpb.PD_RegionHeartbeatServer) error

+ func (s *Server) ReportSplit(ctx context.Context, request *pdpb.ReportSplitRequest) (*pdpb.ReportSplitResponse, error)

+ func (s *Server) ResignLeader(nextLeader string) error

+ func (s *Server) Run() error

+ func (s *Server) SetReplicationConfig(cfg ReplicationConfig)

+ func (s *Server) SetScheduleConfig(cfg ScheduleConfig)

+ func (s *Server) StoreHeartbeat(ctx context.Context, request *pdpb.StoreHeartbeatRequest) (*pdpb.StoreHeartbeatResponse, error)

+ func (s *Server) Tso(stream pdpb.PD_TsoServer) error

Incompatible versions in this module

v2.1.19+incompatible

Dec 25, 2019

v2.0.10+incompatible

Dec 17, 2018