file

Documentation

Overview

Package file Double-write of files

Index

• Constants
• Variables
• func BatchReplay(clients map[string]redis.UniversalClient, fileNames []string)
• func FileListNeedReplay(dir string) []string
• func MkDirs(dir string)
• func Replay(filename string, client redis.UniversalClient) bool
• func ReplayExec(client redis.UniversalClient, interrupted, lineIndex *int64, line []byte)
• type Item
• type NameInfo
  • func Parse(fileName string) (*NameInfo, error)
• type Operation
  • func NewFileOperation() *Operation
  • func (f *Operation) CloseWriter()
  • func (f *Operation) CreateFile(originPath string) (*os.File, error)
  • func (f *Operation) WriteFile(path string, content Item)

Constants

const (
	CacheFilePerm                      = 0666
	Suffix                             = ".dat"
	Delimiter                          = "-"
	DefaultVersion                     = "0"
	FileTimestampGapMillions           = 60000
	FileTimestampCloseMillions         = 70000
	FileCloseCheckTimestampGapMillions = 5000
	FlushGapMillions                   = 10000
	RelativePattern                    = "(dc[12])-([0-9]{13})-([0-9]*)\\.dat"
	MaxLine                            = 1 << 20
)

Variables

var Pattern = regexp.MustCompile("(.*/)(.*)?-(.*)?-(.*)?\\.dat")

Functions

func BatchReplay

func BatchReplay(clients map[string]redis.UniversalClient, fileNames []string)

BatchReplay Run the following command to filter the files to be executed

func FileListNeedReplay

func FileListNeedReplay(dir string) []string

FileListNeedReplay Obtain the list of files to be executed

func MkDirs

func MkDirs(dir string)

func Replay

func Replay(filename string, client redis.UniversalClient) bool

Replay Traverse all commands in the file and execute them

func ReplayExec

func ReplayExec(client redis.UniversalClient, interrupted, lineIndex *int64, line []byte)

ReplayExec Run the command on the client

Types

type Item

type Item struct {
	Args []interface{}
}

type NameInfo

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

func Parse

func Parse(fileName string) (*NameInfo, error)

Parse Check whether the parsed file name meets requirements

type Operation

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

func NewFileOperation

func NewFileOperation() *Operation

func (*Operation) CloseWriter

func (f *Operation) CloseWriter()

CloseWriter Polling disables the write of files that are not operated within a specified period of time

func (*Operation) CreateFile

func (f *Operation) CreateFile(originPath string) (*os.File, error)

func (*Operation) WriteFile

func (f *Operation) WriteFile(path string, content Item)

WriteFile Command Write