transactions, err := handler.Handler(cc, &transaction)
if err != nil {
- return err
+ return fmt.Errorf("error handling transaction: %w", err)
}
for _, t := range transactions {
cc.Server.outbox <- t
// NewReply returns a reply Transaction with fields for the ClientConn
func (cc *ClientConn) NewReply(t *Transaction, fields ...Field) Transaction {
return Transaction{
- Flags: 0x00,
IsReply: 0x01,
Type: []byte{0x00, 0x00},
ID: t.ID,
func (cc *ClientConn) NewErrReply(t *Transaction, errMsg string) Transaction {
return Transaction{
clientID: cc.ID,
- Flags: 0x00,
IsReply: 0x01,
Type: []byte{0, 0},
ID: t.ID,