util

Documentation

Index

• Constants
• Variables
• func DailTimeOut(target string, timeout time.Duration) (c *net.TCPConn, err error)
• func GetMemInfo() (total, used uint64, err error)
• func GetProcessMemory(pid int) (used uint64, err error)
• func IsIPV4(val interface{}) bool
• func Max(a, b int) int
• func Min(a, b int) int
• func RandomString(length int, seed RandomSeed) string
• func SubString(sourceString string, begin, end int) string
• type ConnectPool
  • func NewConnectPool() (cp *ConnectPool)
  • func NewConnectPoolWithTimeout(idleConnTimeout time.Duration, connectTimeout int64) (cp *ConnectPool)
  • func (cp *ConnectPool) Close()
  • func (cp *ConnectPool) GetConnect(targetAddr string) (c *net.TCPConn, err error)
  • func (cp *ConnectPool) PutConnect(c *net.TCPConn, forceClose bool)
• type MasterHelper
  • func NewMasterHelper() MasterHelper
• type MultipartID
  • func CreateMultipartID(mpId uint64) MultipartID
  • func MultipartIDFromString(src string) MultipartID
  • func (id MultipartID) PartitionID() (pID uint64, found bool)
  • func (id MultipartID) String() string
• type Object
• type Pool
  • func NewPool(min, max int, timeout, connectTimeout int64, target string) (p *Pool)
  • func (p *Pool) GetConnectFromPool() (c *net.TCPConn, err error)
  • func (p *Pool) NewConnect(target string) (c *net.TCPConn, err error)
  • func (p *Pool) PutConnectObjectToPool(o *Object)
  • func (p *Pool) ReleaseAll()
• type RandomSeed
  • func (s RandomSeed) Runes() []rune

Constants

const (
	MEMINFO = "/proc/meminfo"
	PRO_MEM = "/proc/%d/status"
)

const (
	KB = 1 << (10 * iota)
	MB
	GB
	TB
	PB
	DefaultDataPartitionSize = 120 * GB
	TaskWorkerInterval       = 1
)

const (
	BlockCount       = 1024
	BlockSize        = 65536 * 2
	ReadBlockSize    = BlockSize
	PerBlockCrcSize  = 4
	ExtentSize       = BlockCount * BlockSize
	PacketHeaderSize = 57
	BlockHeaderSize  = 4096
)

const (
	ConnectIdleTime = 30
)

const (
	DefaultTinySizeLimit = 1 * MB // TODO explain tiny extent?
)

Variables

var (
	ErrNoValidMaster = errors.New("no valid master")
)

Functions

func DailTimeOut

func DailTimeOut(target string, timeout time.Duration) (c *net.TCPConn, err error)

func GetMemInfo

func GetMemInfo() (total, used uint64, err error)

GetMemInfo returns the memory information.

func GetProcessMemory

func GetProcessMemory(pid int) (used uint64, err error)

func IsIPV4

func IsIPV4(val interface{}) bool

IsIPV4 returns if it is IPV4 address.

func Max

func Max(a, b int) int

func Min

func Min(a, b int) int

func RandomString

func RandomString(length int, seed RandomSeed) string

func SubString

func SubString(sourceString string, begin, end int) string

Types

type ConnectPool

type ConnectPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConnectPool

func NewConnectPool() (cp *ConnectPool)

func NewConnectPoolWithTimeout

func NewConnectPoolWithTimeout(idleConnTimeout time.Duration, connectTimeout int64) (cp *ConnectPool)

func (*ConnectPool) Close

func (cp *ConnectPool) Close()

func (*ConnectPool) GetConnect

func (cp *ConnectPool) GetConnect(targetAddr string) (c *net.TCPConn, err error)

func (*ConnectPool) PutConnect

func (cp *ConnectPool) PutConnect(c *net.TCPConn, forceClose bool)

type MasterHelper

type MasterHelper interface {
	AddNode(address string)
	Nodes() []string
	Leader() string
	Request(method, path string, param, header map[string]string, body []byte) (data []byte, err error)
}

MasterHelper defines the helper struct to manage the master.

func NewMasterHelper

func NewMasterHelper() MasterHelper

NewMasterHelper returns a new MasterHelper instance.

type MultipartID

type MultipartID string

func CreateMultipartID

func CreateMultipartID(mpId uint64) MultipartID

func MultipartIDFromString

func MultipartIDFromString(src string) MultipartID

func (MultipartID) PartitionID

func (id MultipartID) PartitionID() (pID uint64, found bool)

func (MultipartID) String

func (id MultipartID) String() string

type Object

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

type Pool

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

func NewPool

func NewPool(min, max int, timeout, connectTimeout int64, target string) (p *Pool)

func (*Pool) GetConnectFromPool

func (p *Pool) GetConnectFromPool() (c *net.TCPConn, err error)

func (*Pool) NewConnect

func (p *Pool) NewConnect(target string) (c *net.TCPConn, err error)

func (*Pool) PutConnectObjectToPool

func (p *Pool) PutConnectObjectToPool(o *Object)

func (*Pool) ReleaseAll

func (p *Pool) ReleaseAll()

type RandomSeed

type RandomSeed byte

const (
	Numeric RandomSeed = 1 << iota
	LowerLetter
	UpperLetter
)

func (RandomSeed) Runes

func (s RandomSeed) Runes() []rune