pbutils

Documentation

Index

• Variables
• func DayEnd(t time.Time) (time.Time, error)
• func DayStart(t time.Time) (time.Time, error)
• func FormatDatetime(sec int64) string
• func HTTPGet(URL string, timeout int) (err error)
• func ParseDatetime(d string) (int64, error)
• func ParseDatetimeMinute(d string) (int64, error)
• type FileLock
  • func NewFLock(path string) (*FileLock, error)
  • func (l *FileLock) TryLock() error
  • func (l *FileLock) TryLockWin() error
  • func (l *FileLock) Unlock() error
  • func (l *FileLock) UnlockWin() error
  • func (l *FileLock) WriteContent(s string) error
• type GenericPool
  • func NewGenericPool(config poolConfig) (GenericPool, error)
• type PortLock
  • func NewPortLock(port int) *PortLock
  • func (p *PortLock) TryLock() (bool, error)
  • func (p *PortLock) UnLock() error

Variables

var (
	ErrObjectNil     = errors.New("object is nil.")
	ErrFetchTimedOut = errors.New("fetch object timeout.")
)

Functions

func DayEnd

func DayEnd(t time.Time) (time.Time, error)

func DayStart

func DayStart(t time.Time) (time.Time, error)

func FormatDatetime

func FormatDatetime(sec int64) string

func HTTPGet

func HTTPGet(URL string, timeout int) (err error)

func ParseDatetime

func ParseDatetime(d string) (int64, error)

func ParseDatetimeMinute

func ParseDatetimeMinute(d string) (int64, error)

Types

type FileLock

type FileLock struct {
	sync.Mutex
	// contains filtered or unexported fields
}

file lock

func NewFLock

func NewFLock(path string) (*FileLock, error)

func (*FileLock) TryLock

func (l *FileLock) TryLock() error

func (*FileLock) TryLockWin

func (l *FileLock) TryLockWin() error

windows

func (*FileLock) Unlock

func (l *FileLock) Unlock() error

func (*FileLock) UnlockWin

func (l *FileLock) UnlockWin() error

func (*FileLock) WriteContent

func (l *FileLock) WriteContent(s string) error

type GenericPool

type GenericPool interface {
	Get() (obj interface{}, err error)
	Put(obj interface{}) error
	Clear()
	Close()
	Len() int
}

func NewGenericPool

func NewGenericPool(config poolConfig) (GenericPool, error)

type PortLock

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

locked by port

func NewPortLock

func NewPortLock(port int) *PortLock

func (*PortLock) TryLock

func (p *PortLock) TryLock() (bool, error)

func (*PortLock) UnLock

func (p *PortLock) UnLock() error