Function MockDefaultQueryHandler

proxycore/mockcluster.go:89–100

(cl *MockClient, frm *frame.Frame)

}

func MockDefaultQueryHandler(cl *MockClient, frm *frame.Frame) message.Message {
	if msg := cl.InterceptQuery(frm.Header, frm.Body.Message.(*message.Query)); msg != nil {
		return msg
	} else {
		return &message.RowsResult{
			Metadata: &message.RowsMetadata{
				ColumnCount: 0,
			},
			Data: message.RowSet{},
		}
	}
}

func MockDefaultPrepareHandler(_ *MockClient, frm *frame.Frame) message.Message {
	prepare := frm.Body.Message.(*message.Prepare)