config

Documentation

Index

• type Config
  • func InitDefaultConfig() *Config
  • func InitDefaultTestConfig() *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

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

type ContainerFile struct {
	Container string
	Bucket    string
	SubBucket string
	TableName string
}

ContainerFile container file

func NewContainerFileWTableName

func NewContainerFileWTableName(container string, bucket string, subBucket string, table string) ContainerFile

NewContainerFileWTableName new container file

func ParseContainerFileFromActivePath

func ParseContainerFileFromActivePath(b string) (*ContainerFile, error)

ParseContainerFileFromActivePath parse file path

func ParseContainerFileFromArchivePath

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

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

func (cf ContainerFile) DataSize() int

DataSize path to file

func (ContainerFile) Key

func (cf ContainerFile) Key() string

Key string representing the config

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

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