server

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 23, 2018 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnknownCommand         = errors.New("unknown command")
	ErrWrongNumberOfArguments = errors.New("wrong number of arguments")
	ErrDisabled               = errors.New("disabled")
)

Functions

func GetIPv4ForInterfaceName 

func GetIPv4ForInterfaceName(ifname string) string

func SLogger 

func SLogger() *common.LevelLogger

func SetLogger 

func SetLogger(level int32, logger common.Logger)

Types

type ConfigFile 

type ConfigFile struct {
	ServerConf ServerConfig `json:"server_conf"`
}

type NamespaceNodeConfig 

type NamespaceNodeConfig struct {
	Name           string `json:"name"`
	LocalReplicaID uint64 `json:"local_replica_id"`
}

type RaftStatus 

type RaftStatus struct {
	LeaderInfo *common.MemberInfo
	Members    []*common.MemberInfo
	Learners   []*common.MemberInfo
	RaftStat   raft.Status
}

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(conf ServerConfig) *Server

func (*Server) ApplyRaftReqs 

func (s *Server) ApplyRaftReqs(ctx context.Context, reqs *syncerpb.RaftReqs) (*syncerpb.RpcErr, error)

func (*Server) DeleteRange added in v0.3.2 

func (s *Server) DeleteRange(ns string, dtr node.DeleteTableRange) error

func (*Server) GetApplySnapStatus 

func (s *Server) GetApplySnapStatus(ctx context.Context, req *syncerpb.RaftApplySnapStatusReq) (*syncerpb.RaftApplySnapStatusRsp, error)

func (*Server) GetCoord 

func (s *Server) GetCoord() *datanode_coord.DataCoordinator

func (*Server) GetDBStats 

func (s *Server) GetDBStats(leaderOnly bool) map[string]string

func (*Server) GetHandler 

func (s *Server) GetHandler(cmdName string, cmd redcon.Command) (bool, common.CommandFunc, redcon.Command, error)

func (*Server) GetLogSyncStats 

func (s *Server) GetLogSyncStats(leaderOnly bool, srcClusterName string) []common.LogSyncStats

func (*Server) GetLogSyncStatsInSyncLearner added in v0.4.0 

func (s *Server) GetLogSyncStatsInSyncLearner() ([]common.LogSyncStats, []common.LogSyncStats)

func (*Server) GetMergeHandlers 

func (s *Server) GetMergeHandlers(cmd redcon.Command) ([]common.MergeCommandFunc, []redcon.Command, bool, error)

func (*Server) GetNamespace 

func (s *Server) GetNamespace(ns string, pk []byte) (*node.NamespaceNode, error)

func (*Server) GetNamespaceFromFullName 

func (s *Server) GetNamespaceFromFullName(ns string) *node.NamespaceNode

func (*Server) GetStats 

func (s *Server) GetStats(leaderOnly bool) common.ServerStats

func (*Server) GetSyncedRaft 

func (s *Server) GetSyncedRaft(ctx context.Context, req *syncerpb.SyncedRaftReq) (*syncerpb.SyncedRaftRsp, error)

func (*Server) InitKVNamespace 

func (s *Server) InitKVNamespace(id uint64, conf *node.NamespaceConfig, join bool) (*node.NamespaceNode, error)

func (*Server) IsPeerRemoved 

func (s *Server) IsPeerRemoved(peerID uint64) bool

func (*Server) NotifyApplySnap 

func (s *Server) NotifyApplySnap(ctx context.Context, req *syncerpb.RaftApplySnapReq) (*syncerpb.RpcErr, error)

func (*Server) NotifyTransferSnap 

func (s *Server) NotifyTransferSnap(ctx context.Context, req *syncerpb.RaftApplySnapReq) (*syncerpb.RpcErr, error)

func (*Server) OptimizeDB 

func (s *Server) OptimizeDB(ns string, table string)

func (*Server) Process 

func (s *Server) Process(ctx context.Context, m raftpb.Message) error

implement the Raft interface for transport

func (*Server) ReportSnapshot 

func (s *Server) ReportSnapshot(id uint64, gp raftpb.Group, status raft.SnapshotStatus)

func (*Server) ReportUnreachable 

func (s *Server) ReportUnreachable(id uint64, group raftpb.Group)

func (*Server) RestartAsStandalone 

func (s *Server) RestartAsStandalone(fullNamespace string) error

func (*Server) SaveDBFrom 

func (s *Server) SaveDBFrom(r io.Reader, msg raftpb.Message) (int64, error)

implement the snapshotter interface for transport

func (*Server) ServeHTTP 

func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*Server) Start 

func (s *Server) Start()

func (*Server) Stop 

func (s *Server) Stop()

type ServerConfig 

type ServerConfig struct {
	// this cluster id is used for server transport to tell
	// different global cluster
	ClusterID            string            `json:"cluster_id"`
	EtcdClusterAddresses string            `json:"etcd_cluster_addresses"`
	BroadcastInterface   string            `json:"broadcast_interface"`
	BroadcastAddr        string            `json:"broadcast_addr"`
	RedisAPIPort         int               `json:"redis_api_port"`
	HttpAPIPort          int               `json:"http_api_port"`
	GrpcAPIPort          int               `json:"grpc_api_port"`
	ProfilePort          int               `json:"profile_port"`
	DataDir              string            `json:"data_dir"`
	DataRsyncModule      string            `json:"data_rsync_module"`
	LocalRaftAddr        string            `json:"local_raft_addr"`
	Tags                 map[string]string `json:"tags"`
	SyncerWriteOnly      bool              `json:"syncer_write_only"`
	SyncerNormalInit     bool              `json:"syncer_normal_init"`
	LearnerRole          string            `json:"learner_role"`
	RemoteSyncCluster    string            `json:"remote_sync_cluster"`
	StateMachineType     string            `json:"state_machine_type"`

	ElectionTick int `json:"election_tick"`
	TickMs       int `json:"tick_ms"`
	// default rocksdb options, can be override by namespace config
	RocksDBOpts rockredis.RockOptions `json:"rocksdb_opts"`
	Namespaces  []NamespaceNodeConfig `json:"namespaces"`
	MaxScanJob  int32                 `json:"max_scan_job"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.