utils

Aug 11, 2022

Changes in this version

+ type Bitmap struct

+ func FromBytes(buffer []byte, cap uint32) *Bitmap

+ func FromString(hexString string, cap uint32) (*Bitmap, error)

+ func NewBitmap(size uint32) *Bitmap

+ func (a *Bitmap) And(other Bitmap, extra ...Bitmap)

+ func (a *Bitmap) AndNot(other Bitmap, extra ...Bitmap)

+ func (a *Bitmap) Or(other Bitmap, extra ...Bitmap)

+ func (a *Bitmap) Xor(other Bitmap, extra ...Bitmap)

+ func (b *Bitmap) Clear()

+ func (b *Bitmap) Contains(x uint32) bool

+ func (b *Bitmap) Count() int

+ func (b *Bitmap) CountTo(until uint32) int

+ func (b *Bitmap) Grow(desiredBit uint32)

+ func (b *Bitmap) MarshalJSON() ([]byte, error)

+ func (b *Bitmap) Max() (uint32, bool)

+ func (b *Bitmap) MaxZero() (uint32, bool)

+ func (b *Bitmap) Min() (uint32, bool)

+ func (b *Bitmap) MinZero() (uint32, bool)

+ func (b *Bitmap) Ones()

+ func (b *Bitmap) Remove(x uint32)

+ func (b *Bitmap) Set(x uint32)

+ func (b *Bitmap) ToBytes() (out []byte)

+ func (b *Bitmap) ToHexBitmap() *HexBitmap

+ func (b *Bitmap) ToString() string

+ func (b *Bitmap) UnmarshalJSON(data []byte) (err error)

type HexBitmap

+ Bits string

+ Size uint32

Aug 9, 2022

Changes in this version

type HexBitmap

+ func ToHexBitmap(bitmap bitmap.Bitmap) *HexBitmap

+ func (xb *HexBitmap) Ones()

Aug 9, 2022

Changes in this version

type HexBitmap

+ func (xb *HexBitmap) Count() int

Aug 9, 2022

Changes in this version

+ type HexBitmap string

+ func NewHexBitmap(bits uint32) *HexBitmap

+ func ToHexBitMap(bitmap bitmap.Bitmap) *HexBitmap

+ func (xb *HexBitmap) Contains(bit uint32) bool

+ func (xb *HexBitmap) Grow(bits uint32)

+ func (xb *HexBitmap) Remove(bit uint32)

+ func (xb *HexBitmap) Set(bit uint32)

+ func (xb *HexBitmap) ToBitmap() bitmap.Bitmap

Aug 8, 2022

Changes in this version

+ func Equal(a interface{}, b interface{}) bool

Aug 6, 2022

Changes in this version

+ func Uint32ToIpv4(ipv4Uint32 uint32) string

Aug 6, 2022

Changes in this version

+ func Ipv4ToUint32(ipv4 string) (uint32, error)

Jul 22, 2022

Changes in this version

+ const ScriptStatusExited

+ const ScriptStatusFailed

+ const ScriptStatusKilled

+ const ScriptStatusRunning

+ const ScriptStatusWaiting

type Script

+ Status string

Jul 22, 2022

Changes in this version

type ScriptSpec

+ SysProcAttr *syscall.SysProcAttr

Jul 18, 2022

Changes in this version

+ const DefaultThreadPoolSize

+ const DefaultThreadQueueSize

+ const LOG_DEBUG

+ const LOG_ERROR

+ const LOG_INFO

+ const LOG_WARN

+ const MODE_PERM_RO

+ const MODE_PERM_RW

+ const STATUS_DOWN

+ const STATUS_PENDING

+ const STATUS_UP

+ var LogLabel []string = []string

+ var LogLevel int = LOG_DEBUG

+ var Logger *log.Logger = log.Default()

+ func AllocIPFromCidr(cidr string, exist []string) (*string, error)

+ func AllocIPFromRange(start string, end string, exist []string) (*string, error)

+ func CreateFile(target string, data ...string) error

+ func DelFileIfExist(f string) error

+ func ExecCommand(cmd string) (int, error)

+ func FileExist(f string) bool

+ func GetIPStatus(ipaddress string, prefix *uint8, dev *string) string

+ func GetInterfaceOfIP(ipaddress string) (*string, *int, error)

+ func GetInterfaceStatus(dev *string) string

+ func GetProcStatus(pidFile string) string

+ func IpInNetwork(ipstr string, cidr string) bool

+ func ListContains(slice []string, obj string) bool

+ func ListDelete(slice []string, obj string) (result []string)

+ func LogPrintf(level int, module string, format string, v ...interface{})

+ func MergeFiles(target string, files ...string) error

+ func MkdirIfNotExist(path string) error

+ func RandNum(max int) int

+ func RandomString(len int) string

+ func WriteFile(target string, flag int, mode os.FileMode, data ...string) error

+ type CmdJob struct

+ Cmd *exec.Cmd

+ Id uuid.UUID

+ Spec *CmdJobSpec

+ func NewCmdJob(s *CmdJobSpec) (*CmdJob, error)

+ func (j *CmdJob) Expect(regex string, timeout time.Duration) (bool, error)

+ func (j *CmdJob) Input(line string) error

+ func (j *CmdJob) Run()

+ func (j *CmdJob) Wait()

+ type CmdJobSpec struct

+ Args []string

+ Dir string

+ Env []string

+ Out string

+ Path string

+ type Gossip struct

+ BindAddr string

+ BindPort int

+ InvalidatesHandler func(memberlist.Broadcast) bool

+ LocalStateHandler func() []byte

+ MergeRemoteStateHandler func([]byte)

+ Name string

+ NodeMetaHandler func() []byte

+ NotifyJoinHandler func(*memberlist.Node)

+ NotifyLeaveHandler func(*memberlist.Node)

+ NotifyMsgHandler func([]byte)

+ NotifyUpdateHandler func(*memberlist.Node)

+ ProbeInterval int

+ Ready bool

+ RetransmitMult int

+ SecretKey []byte

+ SyncInterval int

+ func DefaultGossip() *Gossip

+ func GossipWith(name string, bindAddr string, bindPort int) *Gossip

+ func (g *Gossip) Broadcast(msg []byte)

+ func (g *Gossip) Start(members *string) error

+ type Runnable interface

+ Run func()

+ type Script struct

+ Cmd *exec.Cmd

+ Id uuid.UUID

+ Spec *ScriptSpec

+ func NewScript(s *ScriptSpec) (*Script, error)

+ func (s *Script) Expect(regex string, timeout time.Duration) (bool, error)

+ func (s *Script) Input(line string) error

+ func (s *Script) Run()

+ func (s *Script) Wait()

+ type ScriptSpec struct

+ Args []string

+ Dir string

+ Env []string

+ Out string

+ Path string

+ type ThreadPool struct

+ PoolSize int

+ Queue chan Runnable

+ QueueSize int

+ func DefaultThreadPool() *ThreadPool

+ func NewThreadPool(QueueSize int, PoolSize int) *ThreadPool

+ func (p *ThreadPool) Destroy()

+ func (p *ThreadPool) Init()

+ func (p *ThreadPool) Put(r Runnable) error

+ func (p *ThreadPool) Wait()