transport

type CltProtocol interface {
	Send(reqId int32, servant, funcName string, pkg []byte) ([]byte, error)
	Recv(pkg []byte)
	ParsePkg(pkg []byte) (int, int)
	String() string
}

type GPool interface {
	Start()
	AddTask(t func())
	Release()
}

type Logger interface {
	Debug(msg ...interface{})
	Info(msg ...interface{})
	Warn(msg ...interface{})
	Error(msg ...interface{})

	Debugf(tpl string, args ...interface{})
	Infof(tpl string, args ...interface{})
	Warnf(tpl string, args ...interface{})
	Errorf(tpl string, args ...interface{})
}

type OneClt struct {
	Proto CltProtocol
	// contains filtered or unexported fields
}

type OneCltConf struct {
	Address       string
	Balance       string `yaml:"balance"`
	TransProtocol string `yaml:"trans_protocol"`

	QueueCap int `yaml:"queue_cap"`

	DialTimeout  time.Duration `yaml:"dial_timeout"`
	ReadTimeout  time.Duration `yaml:"read_timeout"`
	WriteTimeout time.Duration `yaml:"write_timeout"`
	IdleTimeout  time.Duration `yaml:"idle_timeout"`
}

type OneHandler interface {
	Listen() error
	Handle() error
}

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

type OneSvrConf struct {
	Address  string `yaml:"address"`
	Protocol string `yaml:"protocol"`

	MaxInvoke int `yaml:"max_invoke"`
	QueueCap  int `yaml:"queue_cap"`

	AcceptTimeout time.Duration `yaml:"accept_timeout"`
	ReadTimeout   time.Duration
	WriteTimeout  time.Duration
	HandleTimeout time.Duration
	IdleTimeout   time.Duration

	TCPReadBuf  int
	TCPWriteBuf int
	TCPNoDelay  bool

	ServiceWeight int `yaml:"service_weight"`
}

type SvrProtocol interface {
	Invoke(ctx context.Context, req []byte) []byte
	ParsePkg(pkg []byte) (int, int)
	InvokeTimeout(ctx context.Context, req []byte) []byte
}