tris

Documentation

Index

• func CopyFile(src string, dst string) error
• func PathExists(path string) (bool, error)
• func ReadUvarint(r io.ByteReader) (uint64, int, error)
• func ReadVarint(r io.ByteReader) (int64, int, error)
• type ZmqSocketPool
  • func InitializeZmqSocketPool(sType zmq.SocketType, connCount int) (p *ZmqSocketPool, err error)
  • func (p *ZmqSocketPool) Get() (s *zmq.Socket, err error)
  • func (p *ZmqSocketPool) Release() (err error)

Functions

func CopyFile

func CopyFile(src string, dst string) error

func PathExists

func PathExists(path string) (bool, error)

func ReadUvarint

func ReadUvarint(r io.ByteReader) (uint64, int, error)

func ReadVarint

func ReadVarint(r io.ByteReader) (int64, int, error)

Types

type ZmqSocketPool

type ZmqSocketPool struct {
	Ctx        *zmq.Context
	Pool       chan *zmq.Socket
	SocketType zmq.SocketType
	PoolSize   int
}

func InitializeZmqSocketPool

func InitializeZmqSocketPool(sType zmq.SocketType, connCount int) (p *ZmqSocketPool, err error)

func (*ZmqSocketPool) Get

func (p *ZmqSocketPool) Get() (s *zmq.Socket, err error)

func (*ZmqSocketPool) Release

func (p *ZmqSocketPool) Release() (err error)