models

Documentation

Index

• type Conf
• type Executor
• type NsTop3
• type Queue
• type Repl
• type ReplLsn
• type ReplLsnAck
• type ReplLsnCkpt
• type ReplNow
• type Sentinel
• type SyncerInnerQueue
• type Worker

Types

type Conf

type Conf struct {
	ConfVersion                            int           `json:"ConfVersion"`
	Id                                     string        `json:"Id"`
	MasterQuorum                           bool          `json:"MasterQuorum"`
	FullSyncHTTPListenPort                 int           `json:"FullSyncHTTPListenPort"`
	IncrSyncHTTPListenPort                 int           `json:"IncrSyncHTTPListenPort"`
	SystemProfilePort                      int           `json:"SystemProfilePort"`
	LogLevel                               string        `json:"LogLevel"`
	LogDirectory                           string        `json:"LogDirectory"`
	LogFileName                            string        `json:"LogFileName"`
	LogFlush                               bool          `json:"LogFlush"`
	SyncMode                               string        `json:"SyncMode"`
	MongoUrls                              []string      `json:"MongoUrls"`
	MongoCsUrl                             string        `json:"MongoCsUrl"`
	MongoSUrl                              string        `json:"MongoSUrl"`
	MongoSslRootCaFile                     string        `json:"MongoSslRootCaFile"`
	MongoSslClientCaFile                   string        `json:"MongoSslClientCaFile"`
	MongoConnectMode                       string        `json:"MongoConnectMode"`
	Tunnel                                 string        `json:"Tunnel"`
	TunnelAddress                          []string      `json:"TunnelAddress"`
	TunnelMessage                          string        `json:"TunnelMessage"`
	TunnelKafkaPartitionNumber             int           `json:"TunnelKafkaPartitionNumber"`
	TunnelJsonFormat                       string        `json:"TunnelJsonFormat"`
	TunnelMongoSslRootCaFile               string        `json:"TunnelMongoSslRootCaFile"`
	FilterNamespaceBlack                   []interface{} `json:"FilterNamespaceBlack"`
	FilterNamespaceWhite                   []interface{} `json:"FilterNamespaceWhite"`
	FilterPassSpecialDb                    []interface{} `json:"FilterPassSpecialDb"`
	FilterDDLEnable                        bool          `json:"FilterDDLEnable"`
	FilterOplogGids                        bool          `json:"FilterOplogGids"`
	CheckpointStorageUrl                   string        `json:"CheckpointStorageUrl"`
	CheckpointStorageDb                    string        `json:"CheckpointStorageDb"`
	CheckpointStorageCollection            string        `json:"CheckpointStorageCollection"`
	CheckpointStorageUrlMongoSslRootCaFile string        `json:"CheckpointStorageUrlMongoSslRootCaFile"`
	CheckpointStartPosition                int           `json:"CheckpointStartPosition"`
	TransformNamespace                     []interface{} `json:"TransformNamespace"`
	SpecialSourceDBFlag                    string        `json:"SpecialSourceDBFlag"`
	SkipNSShareKeyVerify                   interface{}   `json:"SkipNSShareKeyVerify"`
	FullSyncReaderCollectionParallel       int           `json:"FullSyncReaderCollectionParallel"`
	FullSyncReaderWriteDocumentParallel    int           `json:"FullSyncReaderWriteDocumentParallel"`
	FullSyncReaderDocumentBatchSize        int           `json:"FullSyncReaderDocumentBatchSize"`
	FullSyncReaderFetchBatchSize           int           `json:"FullSyncReaderFetchBatchSize"`
	FullSyncReaderParallelThread           int           `json:"FullSyncReaderParallelThread"`
	FullSyncReaderParallelIndex            string        `json:"FullSyncReaderParallelIndex"`
	FullSyncCollectionDrop                 bool          `json:"FullSyncCollectionDrop"`
	FullSyncCreateIndex                    string        `json:"FullSyncCreateIndex"`
	FullSyncReaderOplogStoreDisk           bool          `json:"FullSyncReaderOplogStoreDisk"`
	FullSyncReaderOplogStoreDiskMaxSize    int           `json:"FullSyncReaderOplogStoreDiskMaxSize"`
	FullSyncExecutorInsertOnDupUpdate      bool          `json:"FullSyncExecutorInsertOnDupUpdate"`
	FullSyncExecutorFilterOrphanDocument   bool          `json:"FullSyncExecutorFilterOrphanDocument"`
	FullSyncExecutorMajorityEnable         bool          `json:"FullSyncExecutorMajorityEnable"`
	IncrSyncMongoFetchMethod               string        `json:"IncrSyncMongoFetchMethod"`
	IncrSyncChangeStreamWatchFullDocument  bool          `json:"IncrSyncChangeStreamWatchFullDocument"`
	IncrSyncReaderFetchBatchSize           int           `json:"IncrSyncReaderFetchBatchSize"`
	IncrSyncOplogGIDS                      []interface{} `json:"IncrSyncOplogGIDS"`
	IncrSyncShardKey                       string        `json:"IncrSyncShardKey"`
	IncrSyncShardByObjectIdWhiteList       []interface{} `json:"IncrSyncShardByObjectIdWhiteList"`
	IncrSyncWorker                         int           `json:"IncrSyncWorker"`
	IncrSyncTunnelWriteThread              int           `json:"IncrSyncTunnelWriteThread"`
	IncrSyncTargetDelay                    int           `json:"IncrSyncTargetDelay"`
	IncrSyncWorkerBatchQueueSize           int           `json:"IncrSyncWorkerBatchQueueSize"`
	IncrSyncAdaptiveBatchingMaxSize        int           `json:"IncrSyncAdaptiveBatchingMaxSize"`
	IncrSyncFetcherBufferCapacity          int           `json:"IncrSyncFetcherBufferCapacity"`
	IncrSyncExecutorUpsert                 bool          `json:"IncrSyncExecutorUpsert"`
	IncrSyncExecutorInsertOnDupUpdate      bool          `json:"IncrSyncExecutorInsertOnDupUpdate"`
	IncrSyncConflictWriteTo                string        `json:"IncrSyncConflictWriteTo"`
	IncrSyncExecutorMajorityEnable         bool          `json:"IncrSyncExecutorMajorityEnable"`
	CheckpointStorage                      string        `json:"CheckpointStorage"`
	CheckpointInterval                     int           `json:"CheckpointInterval"`
	FullSyncExecutorDebug                  bool          `json:"FullSyncExecutorDebug"`
	IncrSyncDBRef                          bool          `json:"IncrSyncDBRef"`
	IncrSyncExecutor                       int           `json:"IncrSyncExecutor"`
	IncrSyncExecutorDebug                  bool          `json:"IncrSyncExecutorDebug"`
	IncrSyncReaderDebug                    string        `json:"IncrSyncReaderDebug"`
	IncrSyncCollisionEnable                bool          `json:"IncrSyncCollisionEnable"`
	IncrSyncReaderBufferTime               int           `json:"IncrSyncReaderBufferTime"`
	IncrSyncWorkerOplogCompressor          string        `json:"IncrSyncWorkerOplogCompressor"`
	IncrSyncTunnelKafkaDebug               string        `json:"IncrSyncTunnelKafkaDebug"`
	Version                                string        `json:"Version"`
	SourceDBVersion                        string        `json:"SourceDBVersion"`
	TargetDBVersion                        string        `json:"TargetDBVersion"`
	IncrSyncTunnel                         string        `json:"IncrSyncTunnel"`
	IncrSyncTunnelAddress                  interface{}   `json:"IncrSyncTunnelAddress"`
	IncrSyncTunnelMessage                  string        `json:"IncrSyncTunnelMessage"`
	HTTPListenPort                         int           `json:"HTTPListenPort"`
	SystemProfile                          int           `json:"SystemProfile"`
}

type Executor

type Executor struct {
	Id            int      `json:"id"`
	Insert        int      `json:"insert"`
	Update        int      `json:"update"`
	Delete        int      `json:"delete"`
	Ddl           int      `json:"ddl"`
	Unknown       int      `json:"unknown"`
	Error         int      `json:"error"`
	InsertNsTop3  []NsTop3 `json:"insert_ns_top_3"`
	UpdateNsTop3  []NsTop3 `json:"update_ns_top_3"`
	DeleteNsTop3  []NsTop3 `json:"delete_ns_top_3"`
	DdlNsTop3     []NsTop3 `json:"ddl_ns_top_3"`
	UnknownNsTop3 []NsTop3 `json:"unknown_ns_top_3"`
	ErrorNsTop3   []NsTop3 `json:"error_ns_top_3"`
}

type NsTop3

type NsTop3 struct {
	Key string `json:"Key"`
	Val int    `json:"Val"`
}

type Queue

type Queue struct {
	SyncerReplicaSetName string             `json:"syncer_replica_set_name"`
	LogsQueueSize        int                `json:"logs_queue_size"`
	PendingQueueSize     int                `json:"pending_queue_size"`
	SyncerInnerQueue     []SyncerInnerQueue `json:"syncer_inner_queue"`
	PersisterBufferUsed  int                `json:"persister_buffer_used"`
}

type Repl

type Repl struct {
	Who         string      `json:"who"`
	Tag         string      `json:"tag"`
	Replset     string      `json:"replset"`
	LogsGet     int         `json:"logs_get"`
	LogsRepl    int         `json:"logs_repl"`
	LogsSuccess int         `json:"logs_success"`
	Tps         int         `json:"tps"`
	Lsn         ReplLsn     `json:"lsn"`
	LsnAck      ReplLsnAck  `json:"lsn_ack"`
	LsnCkpt     ReplLsnCkpt `json:"lsn_ckpt"`
	Now         ReplNow     `json:"now"`
	LogSizeAvg  string      `json:"log_size_avg"`
	LogSizeMax  string      `json:"log_size_max"`
}

type ReplLsn

type ReplLsn struct {
	Unix int64  `json:"unix"`
	Time string `json:"time"`
	Ts   string `json:"ts"`
}

type ReplLsnAck

type ReplLsnAck struct {
	Unix int64  `json:"unix"`
	Time string `json:"time"`
	Ts   string `json:"ts"`
}

type ReplLsnCkpt

type ReplLsnCkpt struct {
	Unix int64  `json:"unix"`
	Time string `json:"time"`
	Ts   string `json:"ts"`
}

type ReplNow

type ReplNow struct {
	Unix int64  `json:"unix"`
	Time string `json:"time"`
}

type Sentinel

type Sentinel struct {
	OplogDump      int  `json:"OplogDump"`
	DuplicatedDump bool `json:"DuplicatedDump"`
	Pause          bool `json:"Pause"`
	TPS            int  `json:"TPS"`
	TargetDelay    int  `json:"TargetDelay"`
	ExitPoint      int  `json:"ExitPoint"`
	Shutdown       bool `json:"Shutdown"`
}

type SyncerInnerQueue

type SyncerInnerQueue struct {
	QueueId          int `json:"queue_id"`
	PendingQueueUsed int `json:"pending_queue_used"`
	LogsQueueUsed    int `json:"logs_queue_used"`
}

type Worker

type Worker struct {
	WorkerId        int    `json:"worker_id"`
	JobsInQueue     int    `json:"jobs_in_queue"`
	JobsUnackBuffer int    `json:"jobs_unack_buffer"`
	LastUnack       string `json:"last_unack"`
	LastAck         string `json:"last_ack"`
	Count           int    `json:"count"`
}