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
• type ConnectPool
  • func NewConnectPool() (cp *ConnectPool)
  • 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 Object
• type Pool
  • func NewPool(min, max int, timeout 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)

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

Types

type ConnectPool

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

func NewConnectPool

func NewConnectPool() (cp *ConnectPool)

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 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 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 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)