-func NewRMRClientWithParams(protPort string, maxSize int, threadType int, statDesc string) *RMRClient {
- p := C.CString(protPort)
- m := C.int(maxSize)
- c := C.int(threadType)
+type RMRClientParams struct {
+ protPort string
+ maxSize int
+ threadType int
+ statDesc string
+ lowLatency bool
+ fastAck bool
+}
+
+func (params *RMRClientParams) String() string {
+ return fmt.Sprintf("protPort=%s maxSize=%d threadType=%d statDesc=%s lowLatency=%t fastAck=%t",
+ params.protPort, params.maxSize, params.threadType, params.statDesc, params.lowLatency, params.fastAck)
+}
+
+//-----------------------------------------------------------------------------
+//
+//-----------------------------------------------------------------------------
+func NewRMRClientWithParams(params *RMRClientParams) *RMRClient {
+ p := C.CString(params.protPort)
+ m := C.int(params.maxSize)
+ c := C.int(params.threadType)