func (*QueueElement) XXX_OneofWrappers() []interface{} {
	return []interface{}{
		(*QueueElement_Record)(nil),
		(*QueueElement_Error)(nil),
	}
}
XXX_OneofWrappers is for the internal use of the proto package.
package kafka
import (
	fmt "fmt"
	execution "github.com/cube2222/octosql/execution"
	proto "github.com/golang/protobuf/proto"
	math "math"
)
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
const _ = proto.ProtoPackageIsVersion3  
type QueueElement struct {
	Type                 isQueueElement_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}
func (m *QueueElement) Reset()         { *m = QueueElement{} }
func (m *QueueElement) String() string { return proto.CompactTextString(m) }
func (*QueueElement) ProtoMessage()    {}
func (*QueueElement) Descriptor() ([]byte, []int) {
	return fileDescriptor_118b046d139daa5a, []int{0}
}
func (m *QueueElement) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueueElement.Unmarshal(m, b)
}
func (m *QueueElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueueElement.Marshal(b, m, deterministic)
}
func (m *QueueElement) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueueElement.Merge(m, src)
}
func (m *QueueElement) XXX_Size() int {
	return xxx_messageInfo_QueueElement.Size(m)
}
func (m *QueueElement) XXX_DiscardUnknown() {
	xxx_messageInfo_QueueElement.DiscardUnknown(m)
}
var xxx_messageInfo_QueueElement proto.InternalMessageInfo
type isQueueElement_Type interface {
	isQueueElement_Type()
}
type QueueElement_Record struct {
	Record *execution.Record `protobuf:"bytes,1,opt,name=record,proto3,oneof"`
}
type QueueElement_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}
func (*QueueElement_Record) isQueueElement_Type() {}
func (*QueueElement_Error) isQueueElement_Type() {}
func (m *QueueElement) GetType() isQueueElement_Type {
	if m != nil {
		return m.Type
	}
	return nil
}
func (m *QueueElement) GetRecord() *execution.Record {
	if x, ok := m.GetType().(*QueueElement_Record); ok {
		return x.Record
	}
	return nil
}
func (m *QueueElement) GetError() string {
	if x, ok := m.GetType().(*QueueElement_Error); ok {
		return x.Error
	}
	return ""
}