Documentation ¶
Index ¶
- type Config
- type ContainerFile
- func NewContainerFileWTableName(container string, bucket string, subBucket string, table string) ContainerFile
- func ParseContainerFileFromActivePath(b string) (*ContainerFile, error)
- func ParseContainerFileFromArchivePath(b string) (*ContainerFile, error)
- func ParseContainerFileKey(b string) (*ContainerFile, error)
- func (cf ContainerFile) ArchiveFolder(archiveFolder string) string
- func (cf ContainerFile) ArchivePath(archiveFolder string, shardIndex, walIndex, operationIndex int) string
- func (cf ContainerFile) BaseFolder(c Config) string
- func (cf ContainerFile) DataSize() int
- func (cf ContainerFile) Key() string
- func (cf ContainerFile) PathToFile(c Config) string
- func (cf ContainerFile) PathToFileFromFolder(folder string) string
- func (cf ContainerFile) PrefixAndFilename() (prefix string, filename string)
- func (cf ContainerFile) ShardIndex(shardCount uint32) uint32
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { DeleteInsteadOfArchiving bool ActiveFolder string ArchiveFolder string SqliteFolder string WalArchiveFolder string ReplicationActiveFolder string ReplicationArchiveFolder string ShardCount int MaxFileOpen int WALFolder string MaxWALFileSize int MaxWALFileDurationS int ArchiveCommand string RsyncCommand string SqliteArchiverJournalMode string SqliteArchiverSynchronous string DisableResumeArchiving bool }
Config config
func InitDefaultConfig ¶
func InitDefaultConfig() *Config
InitDefaultConfig init config with default parameters
func InitDefaultTestConfig ¶
func InitDefaultTestConfig() *Config
InitDefaultTestConfig init config for test
type ContainerFile ¶
ContainerFile container file
func NewContainerFileWTableName ¶
func NewContainerFileWTableName(container string, bucket string, subBucket string, table string) ContainerFile
NewContainerFileWTableName new container file
func ParseContainerFileFromActivePath ¶ added in v0.0.23
func ParseContainerFileFromActivePath(b string) (*ContainerFile, error)
ParseContainerFileFromActivePath parse file path
func ParseContainerFileFromArchivePath ¶ added in v0.0.13
func ParseContainerFileFromArchivePath(b string) (*ContainerFile, error)
ParseContainerFileFromArchivePath parse file path
func ParseContainerFileKey ¶
func ParseContainerFileKey(b string) (*ContainerFile, error)
ParseContainerFileKey parse a container file from string
func (ContainerFile) ArchiveFolder ¶ added in v0.0.13
func (cf ContainerFile) ArchiveFolder(archiveFolder string) string
ArchiveFolder path to the archive file
func (ContainerFile) ArchivePath ¶
func (cf ContainerFile) ArchivePath(archiveFolder string, shardIndex, walIndex, operationIndex int) string
ArchivePath path to the archive folder
func (ContainerFile) BaseFolder ¶
func (cf ContainerFile) BaseFolder(c Config) string
BaseFolder to file
func (ContainerFile) DataSize ¶ added in v0.0.13
func (cf ContainerFile) DataSize() int
DataSize path to file
func (ContainerFile) PathToFile ¶
func (cf ContainerFile) PathToFile(c Config) string
PathToFile path to file
func (ContainerFile) PathToFileFromFolder ¶
func (cf ContainerFile) PathToFileFromFolder(folder string) string
PathToFileFromFolder path to file
func (ContainerFile) PrefixAndFilename ¶ added in v0.0.13
func (cf ContainerFile) PrefixAndFilename() (prefix string, filename string)
PrefixAndFilename give prefix use as a frst folder to limit the count of file per folder and the filename
func (ContainerFile) ShardIndex ¶
func (cf ContainerFile) ShardIndex(shardCount uint32) uint32
ShardIndex compute the shard index for a container file