unit

Documentation

Index

• func New(addr string, timeout time.Duration) *unit
• type Unit

Functions

func New

func New(addr string, timeout time.Duration) *unit

addr is the address(ip:port) of unit, timeout is the read/write timeout period of the unit

Types

type Unit

type Unit interface {
	Close()
	Send(string, interface{}) error
	SendAndRecv(string, interface{}) (*protocol.Message, error)
}

worker unit