file

Index ¶

• Constants
• func Exists(path string) bool
• func GetTimeoutContext(ctx context.Context, waitTimeOut time.Duration) (context.Context, context.CancelFunc)
• func LockExists(path string) bool
• func LockFilePath(path string) string
• func NewAlreadyExistError(message string) error
• func NewCompositeError(err1 error, err2 error) error
• func NewContextCanceled() error
• func NewContextDone(message string) error
• func NewForcedUnlockError(errs []error) error
• func NewIOError(message string) error
• func NewLockError(message string) error
• func NewNotExistError(message string) error
• func NewTimeoutError(path string) error
• func ParseError(err error) error
• func RLockExists(path string) bool
• func RLockFilePath(path string) string
• func RandomString(length int) string
• func TempFilePath(path string) string
• type AlreadyExistError
• • func (e AlreadyExistError) Error() string
• type CompositeError
• • func (e CompositeError) Error() string
• type Container
• • func NewContainer() *Container
• • func (c *Container) Add(path string, handler *Handler) error
  • func (c *Container) Close(h *Handler) error
  • func (c *Container) CloseAll() error
  • func (c *Container) CloseAllWithErrors() error
  • func (c *Container) CloseWithErrors(h *Handler) (err error)
  • func (c *Container) Commit(h *Handler) error
  • func (c *Container) CreateHandlerForCreate(path string) (*Handler, error)
  • func (c *Container) CreateHandlerForRead(ctx context.Context, path string, defaultWaitTimeout time.Duration, ...) (*Handler, error)
  • func (c *Container) CreateHandlerForUpdate(ctx context.Context, path string, defaultWaitTimeout time.Duration, ...) (*Handler, error)
  • func (c *Container) CreateHandlerWithoutLock(ctx context.Context, path string, defaultWaitTimeout time.Duration, ...) (*Handler, error)
  • func (c *Container) Keys() []string
  • func (c *Container) Remove(path string)
• type ContextCanceled
• • func (e ContextCanceled) Error() string
• type ContextDone
• • func (e ContextDone) Error() string
• type ControlFile
• • func CreateControlFileContext(ctx context.Context, filePath string, fileType ControlFileType, ...) (*ControlFile, error)
  • func NewControlFile(path string, fp *os.File) *ControlFile
  • func TryCreateLockFile(filePath string) (*ControlFile, error)
  • func TryCreateRLockFile(filePath string) (controlFile *ControlFile, err error)
  • func TryCreateTempFile(filePath string) (*ControlFile, error)
• • func (m *ControlFile) Close() error
  • func (m *ControlFile) CloseWithErrors() []error
• type ControlFileType
• • func (t ControlFileType) String() string
• type ForcedUnlockError
• • func (e ForcedUnlockError) Error() string
• type Handler
• • func NewHandlerForCreate(path string) (*Handler, error)
  • func NewHandlerForRead(ctx context.Context, path string, defaultWaitTimeout time.Duration, ...) (*Handler, error)
  • func NewHandlerForUpdate(ctx context.Context, path string, defaultWaitTimeout time.Duration, ...) (*Handler, error)
  • func NewHandlerWithoutLock(ctx context.Context, path string, defaultWaitTimeout time.Duration, ...) (*Handler, error)
• • func (h *Handler) CreateControlFileContext(ctx context.Context, fileType ControlFileType, retryDelay time.Duration) error
  • func (h *Handler) File() *os.File
  • func (h *Handler) FileForUpdate() (*os.File, error)
  • func (h *Handler) Path() string
• type IOError
• • func (e IOError) Error() string
• type LockError
• • func (e LockError) Error() string
• type NotExistError
• • func (e NotExistError) Error() string
• type OpenType
• type Reader
• • func NewReader(r io.Reader, headLen int) (*Reader, error)
• • func (r *Reader) HeadBytes() (io.ReadSeeker, error)
  • func (r *Reader) Read(p []byte) (n int, err error)
  • func (r *Reader) Size() int64
• type TimeoutError
• • func (e TimeoutError) Error() string