Documentation ¶
Overview ¶
Package snapshotter provides the meta snapshot service.
Index ¶
Constants ¶
const ( // MuxHeader is the header byte used for the TCP muxer. MuxHeader = "snapshotter" // BackupMagicHeader is the first 8 bytes used to identify and validate // a metastore backup file BackupMagicHeader = 0x6b6d657461 //kmeta )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client provides an API for the snapshotter service.
func (*Client) MetastoreBackup ¶
MetastoreBackup returns a snapshot of the meta store.
func (*Client) UpdateMeta ¶
takes a request object, writes a Base64 encoding to the tcp connection, and then sends the request to the snapshotter service. returns a mapping of the uploaded metadata shardID's to actual shardID's on the destination system.
type CopyShardInfo ¶ added in v1.0.2
type Request ¶
type Request struct { Type RequestType CopyShardDestHost string BackupDatabase string RestoreDatabase string BackupRetentionPolicy string RestoreRetentionPolicy string ShardID uint64 Since time.Time ExportStart time.Time ExportEnd time.Time UploadSize int64 DelaySecond int }
Request represents a request for a specific backup or for information about the shards on this server for a database or retention policy.
type RequestType ¶
type RequestType uint8
RequestType indicates the typeof snapshot request.
const ( // RequestShardBackup represents a request for a shard backup. RequestShardBackup RequestType = iota // RequestMetastoreBackup represents a request to back up the metastore. RequestMetastoreBackup // RequestSeriesFileBackup represents a request to back up the database series file. RequestSeriesFileBackup // RequestDatabaseInfo represents a request for database info. RequestDatabaseInfo // RequestRetentionPolicyInfo represents a request for retention policy info. RequestRetentionPolicyInfo // RequestShardExport represents a request to export Shard data. Similar to a backup, but shards // may be filtered based on the start/end times on each block. RequestShardExport // RequestMetaStoreUpdate represents a request to upload a metafile that will be used to do a live update // to the existing metastore. RequestMetaStoreUpdate // RequestShardUpdate will initiate the upload of a shard data tar file // and have the engine import the data. RequestShardUpdate // RequestCopyShard represents a request for copy a shard to dest host RequestCopyShard // RequestRemoveShard represents a request for remove a shard copy RequestRemoveShard RequestCopyShardStatus RequestKillCopyShard RequestTruncateShards )
type Response ¶
type Response struct {
Paths []string
}
Response contains the relative paths for all the shards on this server that are in the requested database or retention policy.
type Service ¶
type Service struct { Node *cnosdb.Node MetaClient interface { encoding.BinaryMarshaler Database(name string) *meta.DatabaseInfo Data() meta.Data SetData(data *meta.Data) error TruncateShardGroups(t time.Time) error UpdateShardOwners(shardID uint64, addOwners []uint64, delOwners []uint64) error } TSDBStore interface { BackupShard(id uint64, since time.Time, w io.Writer) error ExportShard(id uint64, ExportStart time.Time, ExportEnd time.Time, w io.Writer) error Shard(id uint64) *tsdb.Shard ShardRelativePath(id uint64) (string, error) SetShardEnabled(shardID uint64, enabled bool) error RestoreShard(id uint64, r io.Reader) error CreateShard(database, retentionPolicy string, shardID uint64, enabled bool) error DeleteShard(shardID uint64) error } Listener net.Listener Logger *zap.Logger CopyingShards map[string]*Record // contains filtered or unexported fields }
Service manages the listener for the snapshot endpoint.
func (*Service) WithLogger ¶
WithLogger sets the logger on the service.
type WriteCounter ¶ added in v1.0.3
type WriteCounter struct {
CurrentSize uint64
}