// Code generated by protoc-gen-go. DO NOT EDIT.
// source: server/data/grpc/proto/gateway.proto

package proto

import (
	context "context"
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

type WarehouseJob_Status int32

const (
	WarehouseJob_PENDING WarehouseJob_Status = 0
	WarehouseJob_RUNNING WarehouseJob_Status = 1
	WarehouseJob_DONE    WarehouseJob_Status = 2
)

var WarehouseJob_Status_name = map[int32]string{
	0: "PENDING",
	1: "RUNNING",
	2: "DONE",
}

var WarehouseJob_Status_value = map[string]int32{
	"PENDING": 0,
	"RUNNING": 1,
	"DONE":    2,
}

func (x WarehouseJob_Status) String() string {
	return proto.EnumName(WarehouseJob_Status_name, int32(x))
}

func (WarehouseJob_Status) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{2, 0}
}

type Record struct {
	AvroData             []byte   `protobuf:"bytes,1,opt,name=avro_data,json=avroData,proto3" json:"avro_data,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *Record) Reset()         { *m = Record{} }
func (m *Record) String() string { return proto.CompactTextString(m) }
func (*Record) ProtoMessage()    {}
func (*Record) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{0}
}

func (m *Record) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Record.Unmarshal(m, b)
}
func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Record.Marshal(b, m, deterministic)
}
func (m *Record) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Record.Merge(m, src)
}
func (m *Record) XXX_Size() int {
	return xxx_messageInfo_Record.Size(m)
}
func (m *Record) XXX_DiscardUnknown() {
	xxx_messageInfo_Record.DiscardUnknown(m)
}

var xxx_messageInfo_Record proto.InternalMessageInfo

func (m *Record) GetAvroData() []byte {
	if m != nil {
		return m.AvroData
	}
	return nil
}

func (m *Record) GetTimestamp() int64 {
	if m != nil {
		return m.Timestamp
	}
	return 0
}

type InstanceRecords struct {
	InstanceId           []byte    `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Records              []*Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *InstanceRecords) Reset()         { *m = InstanceRecords{} }
func (m *InstanceRecords) String() string { return proto.CompactTextString(m) }
func (*InstanceRecords) ProtoMessage()    {}
func (*InstanceRecords) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{1}
}

func (m *InstanceRecords) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InstanceRecords.Unmarshal(m, b)
}
func (m *InstanceRecords) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InstanceRecords.Marshal(b, m, deterministic)
}
func (m *InstanceRecords) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InstanceRecords.Merge(m, src)
}
func (m *InstanceRecords) XXX_Size() int {
	return xxx_messageInfo_InstanceRecords.Size(m)
}
func (m *InstanceRecords) XXX_DiscardUnknown() {
	xxx_messageInfo_InstanceRecords.DiscardUnknown(m)
}

var xxx_messageInfo_InstanceRecords proto.InternalMessageInfo

func (m *InstanceRecords) GetInstanceId() []byte {
	if m != nil {
		return m.InstanceId
	}
	return nil
}

func (m *InstanceRecords) GetRecords() []*Record {
	if m != nil {
		return m.Records
	}
	return nil
}

type WarehouseJob struct {
	JobId                 []byte              `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status                WarehouseJob_Status `protobuf:"varint,2,opt,name=status,proto3,enum=gateway.v1.WarehouseJob_Status" json:"status,omitempty"`
	Error                 string              `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	ResultAvroSchema      string              `protobuf:"bytes,4,opt,name=result_avro_schema,json=resultAvroSchema,proto3" json:"result_avro_schema,omitempty"`
	ReplayCursors         [][]byte            `protobuf:"bytes,5,rep,name=replay_cursors,json=replayCursors,proto3" json:"replay_cursors,omitempty"`
	ReferencedInstanceIds [][]byte            `protobuf:"bytes,6,rep,name=referenced_instance_ids,json=referencedInstanceIds,proto3" json:"referenced_instance_ids,omitempty"`
	BytesScanned          int64               `protobuf:"varint,7,opt,name=bytes_scanned,json=bytesScanned,proto3" json:"bytes_scanned,omitempty"`
	ResultSizeBytes       int64               `protobuf:"varint,8,opt,name=result_size_bytes,json=resultSizeBytes,proto3" json:"result_size_bytes,omitempty"`
	ResultSizeRecords     int64               `protobuf:"varint,9,opt,name=result_size_records,json=resultSizeRecords,proto3" json:"result_size_records,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}            `json:"-"`
	XXX_unrecognized      []byte              `json:"-"`
	XXX_sizecache         int32               `json:"-"`
}

func (m *WarehouseJob) Reset()         { *m = WarehouseJob{} }
func (m *WarehouseJob) String() string { return proto.CompactTextString(m) }
func (*WarehouseJob) ProtoMessage()    {}
func (*WarehouseJob) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{2}
}

func (m *WarehouseJob) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WarehouseJob.Unmarshal(m, b)
}
func (m *WarehouseJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WarehouseJob.Marshal(b, m, deterministic)
}
func (m *WarehouseJob) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WarehouseJob.Merge(m, src)
}
func (m *WarehouseJob) XXX_Size() int {
	return xxx_messageInfo_WarehouseJob.Size(m)
}
func (m *WarehouseJob) XXX_DiscardUnknown() {
	xxx_messageInfo_WarehouseJob.DiscardUnknown(m)
}

var xxx_messageInfo_WarehouseJob proto.InternalMessageInfo

func (m *WarehouseJob) GetJobId() []byte {
	if m != nil {
		return m.JobId
	}
	return nil
}

func (m *WarehouseJob) GetStatus() WarehouseJob_Status {
	if m != nil {
		return m.Status
	}
	return WarehouseJob_PENDING
}

func (m *WarehouseJob) GetError() string {
	if m != nil {
		return m.Error
	}
	return ""
}

func (m *WarehouseJob) GetResultAvroSchema() string {
	if m != nil {
		return m.ResultAvroSchema
	}
	return ""
}

func (m *WarehouseJob) GetReplayCursors() [][]byte {
	if m != nil {
		return m.ReplayCursors
	}
	return nil
}

func (m *WarehouseJob) GetReferencedInstanceIds() [][]byte {
	if m != nil {
		return m.ReferencedInstanceIds
	}
	return nil
}

func (m *WarehouseJob) GetBytesScanned() int64 {
	if m != nil {
		return m.BytesScanned
	}
	return 0
}

func (m *WarehouseJob) GetResultSizeBytes() int64 {
	if m != nil {
		return m.ResultSizeBytes
	}
	return 0
}

func (m *WarehouseJob) GetResultSizeRecords() int64 {
	if m != nil {
		return m.ResultSizeRecords
	}
	return 0
}

type PingRequest struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	ClientVersion        string   `protobuf:"bytes,2,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PingRequest) Reset()         { *m = PingRequest{} }
func (m *PingRequest) String() string { return proto.CompactTextString(m) }
func (*PingRequest) ProtoMessage()    {}
func (*PingRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{3}
}

func (m *PingRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PingRequest.Unmarshal(m, b)
}
func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PingRequest.Marshal(b, m, deterministic)
}
func (m *PingRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PingRequest.Merge(m, src)
}
func (m *PingRequest) XXX_Size() int {
	return xxx_messageInfo_PingRequest.Size(m)
}
func (m *PingRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_PingRequest.DiscardUnknown(m)
}

var xxx_messageInfo_PingRequest proto.InternalMessageInfo

func (m *PingRequest) GetClientId() string {
	if m != nil {
		return m.ClientId
	}
	return ""
}

func (m *PingRequest) GetClientVersion() string {
	if m != nil {
		return m.ClientVersion
	}
	return ""
}

type PingResponse struct {
	Authenticated        bool     `protobuf:"varint,1,opt,name=authenticated,proto3" json:"authenticated,omitempty"`
	VersionStatus        string   `protobuf:"bytes,2,opt,name=version_status,json=versionStatus,proto3" json:"version_status,omitempty"`
	RecommendedVersion   string   `protobuf:"bytes,3,opt,name=recommended_version,json=recommendedVersion,proto3" json:"recommended_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PingResponse) Reset()         { *m = PingResponse{} }
func (m *PingResponse) String() string { return proto.CompactTextString(m) }
func (*PingResponse) ProtoMessage()    {}
func (*PingResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{4}
}

func (m *PingResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PingResponse.Unmarshal(m, b)
}
func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PingResponse.Marshal(b, m, deterministic)
}
func (m *PingResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PingResponse.Merge(m, src)
}
func (m *PingResponse) XXX_Size() int {
	return xxx_messageInfo_PingResponse.Size(m)
}
func (m *PingResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_PingResponse.DiscardUnknown(m)
}

var xxx_messageInfo_PingResponse proto.InternalMessageInfo

func (m *PingResponse) GetAuthenticated() bool {
	if m != nil {
		return m.Authenticated
	}
	return false
}

func (m *PingResponse) GetVersionStatus() string {
	if m != nil {
		return m.VersionStatus
	}
	return ""
}

func (m *PingResponse) GetRecommendedVersion() string {
	if m != nil {
		return m.RecommendedVersion
	}
	return ""
}

type WriteRequest struct {
	InstanceRecords      []*InstanceRecords `protobuf:"bytes,1,rep,name=instance_records,json=instanceRecords,proto3" json:"instance_records,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (m *WriteRequest) Reset()         { *m = WriteRequest{} }
func (m *WriteRequest) String() string { return proto.CompactTextString(m) }
func (*WriteRequest) ProtoMessage()    {}
func (*WriteRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{5}
}

func (m *WriteRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WriteRequest.Unmarshal(m, b)
}
func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WriteRequest.Marshal(b, m, deterministic)
}
func (m *WriteRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WriteRequest.Merge(m, src)
}
func (m *WriteRequest) XXX_Size() int {
	return xxx_messageInfo_WriteRequest.Size(m)
}
func (m *WriteRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_WriteRequest.DiscardUnknown(m)
}

var xxx_messageInfo_WriteRequest proto.InternalMessageInfo

func (m *WriteRequest) GetInstanceRecords() []*InstanceRecords {
	if m != nil {
		return m.InstanceRecords
	}
	return nil
}

type WriteResponse struct {
	WriteId              []byte   `protobuf:"bytes,1,opt,name=write_id,json=writeId,proto3" json:"write_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *WriteResponse) Reset()         { *m = WriteResponse{} }
func (m *WriteResponse) String() string { return proto.CompactTextString(m) }
func (*WriteResponse) ProtoMessage()    {}
func (*WriteResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{6}
}

func (m *WriteResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WriteResponse.Unmarshal(m, b)
}
func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WriteResponse.Marshal(b, m, deterministic)
}
func (m *WriteResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WriteResponse.Merge(m, src)
}
func (m *WriteResponse) XXX_Size() int {
	return xxx_messageInfo_WriteResponse.Size(m)
}
func (m *WriteResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_WriteResponse.DiscardUnknown(m)
}

var xxx_messageInfo_WriteResponse proto.InternalMessageInfo

func (m *WriteResponse) GetWriteId() []byte {
	if m != nil {
		return m.WriteId
	}
	return nil
}

type QueryLogRequest struct {
	InstanceId           []byte   `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Partitions           int32    `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	Peek                 bool     `protobuf:"varint,3,opt,name=peek,proto3" json:"peek,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *QueryLogRequest) Reset()         { *m = QueryLogRequest{} }
func (m *QueryLogRequest) String() string { return proto.CompactTextString(m) }
func (*QueryLogRequest) ProtoMessage()    {}
func (*QueryLogRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{7}
}

func (m *QueryLogRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryLogRequest.Unmarshal(m, b)
}
func (m *QueryLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryLogRequest.Marshal(b, m, deterministic)
}
func (m *QueryLogRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryLogRequest.Merge(m, src)
}
func (m *QueryLogRequest) XXX_Size() int {
	return xxx_messageInfo_QueryLogRequest.Size(m)
}
func (m *QueryLogRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryLogRequest.DiscardUnknown(m)
}

var xxx_messageInfo_QueryLogRequest proto.InternalMessageInfo

func (m *QueryLogRequest) GetInstanceId() []byte {
	if m != nil {
		return m.InstanceId
	}
	return nil
}

func (m *QueryLogRequest) GetPartitions() int32 {
	if m != nil {
		return m.Partitions
	}
	return 0
}

func (m *QueryLogRequest) GetPeek() bool {
	if m != nil {
		return m.Peek
	}
	return false
}

type QueryLogResponse struct {
	ReplayCursors        [][]byte `protobuf:"bytes,1,rep,name=replay_cursors,json=replayCursors,proto3" json:"replay_cursors,omitempty"`
	ChangeCursors        [][]byte `protobuf:"bytes,2,rep,name=change_cursors,json=changeCursors,proto3" json:"change_cursors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *QueryLogResponse) Reset()         { *m = QueryLogResponse{} }
func (m *QueryLogResponse) String() string { return proto.CompactTextString(m) }
func (*QueryLogResponse) ProtoMessage()    {}
func (*QueryLogResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{8}
}

func (m *QueryLogResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryLogResponse.Unmarshal(m, b)
}
func (m *QueryLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryLogResponse.Marshal(b, m, deterministic)
}
func (m *QueryLogResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryLogResponse.Merge(m, src)
}
func (m *QueryLogResponse) XXX_Size() int {
	return xxx_messageInfo_QueryLogResponse.Size(m)
}
func (m *QueryLogResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryLogResponse.DiscardUnknown(m)
}

var xxx_messageInfo_QueryLogResponse proto.InternalMessageInfo

func (m *QueryLogResponse) GetReplayCursors() [][]byte {
	if m != nil {
		return m.ReplayCursors
	}
	return nil
}

func (m *QueryLogResponse) GetChangeCursors() [][]byte {
	if m != nil {
		return m.ChangeCursors
	}
	return nil
}

type QueryIndexRequest struct {
	InstanceId           []byte   `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Partitions           int32    `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	Filter               string   `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *QueryIndexRequest) Reset()         { *m = QueryIndexRequest{} }
func (m *QueryIndexRequest) String() string { return proto.CompactTextString(m) }
func (*QueryIndexRequest) ProtoMessage()    {}
func (*QueryIndexRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{9}
}

func (m *QueryIndexRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryIndexRequest.Unmarshal(m, b)
}
func (m *QueryIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryIndexRequest.Marshal(b, m, deterministic)
}
func (m *QueryIndexRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryIndexRequest.Merge(m, src)
}
func (m *QueryIndexRequest) XXX_Size() int {
	return xxx_messageInfo_QueryIndexRequest.Size(m)
}
func (m *QueryIndexRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryIndexRequest.DiscardUnknown(m)
}

var xxx_messageInfo_QueryIndexRequest proto.InternalMessageInfo

func (m *QueryIndexRequest) GetInstanceId() []byte {
	if m != nil {
		return m.InstanceId
	}
	return nil
}

func (m *QueryIndexRequest) GetPartitions() int32 {
	if m != nil {
		return m.Partitions
	}
	return 0
}

func (m *QueryIndexRequest) GetFilter() string {
	if m != nil {
		return m.Filter
	}
	return ""
}

type QueryIndexResponse struct {
	ReplayCursors        [][]byte `protobuf:"bytes,1,rep,name=replay_cursors,json=replayCursors,proto3" json:"replay_cursors,omitempty"`
	ChangeCursors        [][]byte `protobuf:"bytes,2,rep,name=change_cursors,json=changeCursors,proto3" json:"change_cursors,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *QueryIndexResponse) Reset()         { *m = QueryIndexResponse{} }
func (m *QueryIndexResponse) String() string { return proto.CompactTextString(m) }
func (*QueryIndexResponse) ProtoMessage()    {}
func (*QueryIndexResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{10}
}

func (m *QueryIndexResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryIndexResponse.Unmarshal(m, b)
}
func (m *QueryIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryIndexResponse.Marshal(b, m, deterministic)
}
func (m *QueryIndexResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryIndexResponse.Merge(m, src)
}
func (m *QueryIndexResponse) XXX_Size() int {
	return xxx_messageInfo_QueryIndexResponse.Size(m)
}
func (m *QueryIndexResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryIndexResponse.DiscardUnknown(m)
}

var xxx_messageInfo_QueryIndexResponse proto.InternalMessageInfo

func (m *QueryIndexResponse) GetReplayCursors() [][]byte {
	if m != nil {
		return m.ReplayCursors
	}
	return nil
}

func (m *QueryIndexResponse) GetChangeCursors() [][]byte {
	if m != nil {
		return m.ChangeCursors
	}
	return nil
}

type QueryWarehouseRequest struct {
	Query                string   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Partitions           int32    `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	DryRun               bool     `protobuf:"varint,3,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	TimeoutMs            int32    `protobuf:"varint,4,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	MaxBytesScanned      int64    `protobuf:"varint,5,opt,name=max_bytes_scanned,json=maxBytesScanned,proto3" json:"max_bytes_scanned,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *QueryWarehouseRequest) Reset()         { *m = QueryWarehouseRequest{} }
func (m *QueryWarehouseRequest) String() string { return proto.CompactTextString(m) }
func (*QueryWarehouseRequest) ProtoMessage()    {}
func (*QueryWarehouseRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{11}
}

func (m *QueryWarehouseRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryWarehouseRequest.Unmarshal(m, b)
}
func (m *QueryWarehouseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryWarehouseRequest.Marshal(b, m, deterministic)
}
func (m *QueryWarehouseRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryWarehouseRequest.Merge(m, src)
}
func (m *QueryWarehouseRequest) XXX_Size() int {
	return xxx_messageInfo_QueryWarehouseRequest.Size(m)
}
func (m *QueryWarehouseRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryWarehouseRequest.DiscardUnknown(m)
}

var xxx_messageInfo_QueryWarehouseRequest proto.InternalMessageInfo

func (m *QueryWarehouseRequest) GetQuery() string {
	if m != nil {
		return m.Query
	}
	return ""
}

func (m *QueryWarehouseRequest) GetPartitions() int32 {
	if m != nil {
		return m.Partitions
	}
	return 0
}

func (m *QueryWarehouseRequest) GetDryRun() bool {
	if m != nil {
		return m.DryRun
	}
	return false
}

func (m *QueryWarehouseRequest) GetTimeoutMs() int32 {
	if m != nil {
		return m.TimeoutMs
	}
	return 0
}

func (m *QueryWarehouseRequest) GetMaxBytesScanned() int64 {
	if m != nil {
		return m.MaxBytesScanned
	}
	return 0
}

type QueryWarehouseResponse struct {
	Job                  *WarehouseJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (m *QueryWarehouseResponse) Reset()         { *m = QueryWarehouseResponse{} }
func (m *QueryWarehouseResponse) String() string { return proto.CompactTextString(m) }
func (*QueryWarehouseResponse) ProtoMessage()    {}
func (*QueryWarehouseResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{12}
}

func (m *QueryWarehouseResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_QueryWarehouseResponse.Unmarshal(m, b)
}
func (m *QueryWarehouseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_QueryWarehouseResponse.Marshal(b, m, deterministic)
}
func (m *QueryWarehouseResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_QueryWarehouseResponse.Merge(m, src)
}
func (m *QueryWarehouseResponse) XXX_Size() int {
	return xxx_messageInfo_QueryWarehouseResponse.Size(m)
}
func (m *QueryWarehouseResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_QueryWarehouseResponse.DiscardUnknown(m)
}

var xxx_messageInfo_QueryWarehouseResponse proto.InternalMessageInfo

func (m *QueryWarehouseResponse) GetJob() *WarehouseJob {
	if m != nil {
		return m.Job
	}
	return nil
}

type PollWarehouseJobRequest struct {
	JobId                []byte   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PollWarehouseJobRequest) Reset()         { *m = PollWarehouseJobRequest{} }
func (m *PollWarehouseJobRequest) String() string { return proto.CompactTextString(m) }
func (*PollWarehouseJobRequest) ProtoMessage()    {}
func (*PollWarehouseJobRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{13}
}

func (m *PollWarehouseJobRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PollWarehouseJobRequest.Unmarshal(m, b)
}
func (m *PollWarehouseJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PollWarehouseJobRequest.Marshal(b, m, deterministic)
}
func (m *PollWarehouseJobRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PollWarehouseJobRequest.Merge(m, src)
}
func (m *PollWarehouseJobRequest) XXX_Size() int {
	return xxx_messageInfo_PollWarehouseJobRequest.Size(m)
}
func (m *PollWarehouseJobRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_PollWarehouseJobRequest.DiscardUnknown(m)
}

var xxx_messageInfo_PollWarehouseJobRequest proto.InternalMessageInfo

func (m *PollWarehouseJobRequest) GetJobId() []byte {
	if m != nil {
		return m.JobId
	}
	return nil
}

type PollWarehouseJobResponse struct {
	Job                  *WarehouseJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (m *PollWarehouseJobResponse) Reset()         { *m = PollWarehouseJobResponse{} }
func (m *PollWarehouseJobResponse) String() string { return proto.CompactTextString(m) }
func (*PollWarehouseJobResponse) ProtoMessage()    {}
func (*PollWarehouseJobResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{14}
}

func (m *PollWarehouseJobResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PollWarehouseJobResponse.Unmarshal(m, b)
}
func (m *PollWarehouseJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PollWarehouseJobResponse.Marshal(b, m, deterministic)
}
func (m *PollWarehouseJobResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PollWarehouseJobResponse.Merge(m, src)
}
func (m *PollWarehouseJobResponse) XXX_Size() int {
	return xxx_messageInfo_PollWarehouseJobResponse.Size(m)
}
func (m *PollWarehouseJobResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_PollWarehouseJobResponse.DiscardUnknown(m)
}

var xxx_messageInfo_PollWarehouseJobResponse proto.InternalMessageInfo

func (m *PollWarehouseJobResponse) GetJob() *WarehouseJob {
	if m != nil {
		return m.Job
	}
	return nil
}

type ReadRequest struct {
	Cursor               []byte   `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ReadRequest) Reset()         { *m = ReadRequest{} }
func (m *ReadRequest) String() string { return proto.CompactTextString(m) }
func (*ReadRequest) ProtoMessage()    {}
func (*ReadRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{15}
}

func (m *ReadRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ReadRequest.Unmarshal(m, b)
}
func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ReadRequest.Marshal(b, m, deterministic)
}
func (m *ReadRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ReadRequest.Merge(m, src)
}
func (m *ReadRequest) XXX_Size() int {
	return xxx_messageInfo_ReadRequest.Size(m)
}
func (m *ReadRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ReadRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ReadRequest proto.InternalMessageInfo

func (m *ReadRequest) GetCursor() []byte {
	if m != nil {
		return m.Cursor
	}
	return nil
}

func (m *ReadRequest) GetLimit() int32 {
	if m != nil {
		return m.Limit
	}
	return 0
}

type ReadResponse struct {
	Records              []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	NextCursor           []byte    `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *ReadResponse) Reset()         { *m = ReadResponse{} }
func (m *ReadResponse) String() string { return proto.CompactTextString(m) }
func (*ReadResponse) ProtoMessage()    {}
func (*ReadResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{16}
}

func (m *ReadResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ReadResponse.Unmarshal(m, b)
}
func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ReadResponse.Marshal(b, m, deterministic)
}
func (m *ReadResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ReadResponse.Merge(m, src)
}
func (m *ReadResponse) XXX_Size() int {
	return xxx_messageInfo_ReadResponse.Size(m)
}
func (m *ReadResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ReadResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ReadResponse proto.InternalMessageInfo

func (m *ReadResponse) GetRecords() []*Record {
	if m != nil {
		return m.Records
	}
	return nil
}

func (m *ReadResponse) GetNextCursor() []byte {
	if m != nil {
		return m.NextCursor
	}
	return nil
}

type SubscribeRequest struct {
	Cursor               []byte   `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SubscribeRequest) Reset()         { *m = SubscribeRequest{} }
func (m *SubscribeRequest) String() string { return proto.CompactTextString(m) }
func (*SubscribeRequest) ProtoMessage()    {}
func (*SubscribeRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{17}
}

func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SubscribeRequest.Unmarshal(m, b)
}
func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SubscribeRequest.Marshal(b, m, deterministic)
}
func (m *SubscribeRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SubscribeRequest.Merge(m, src)
}
func (m *SubscribeRequest) XXX_Size() int {
	return xxx_messageInfo_SubscribeRequest.Size(m)
}
func (m *SubscribeRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_SubscribeRequest.DiscardUnknown(m)
}

var xxx_messageInfo_SubscribeRequest proto.InternalMessageInfo

func (m *SubscribeRequest) GetCursor() []byte {
	if m != nil {
		return m.Cursor
	}
	return nil
}

type SubscribeResponse struct {
	WriteId              []byte   `protobuf:"bytes,1,opt,name=write_id,json=writeId,proto3" json:"write_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SubscribeResponse) Reset()         { *m = SubscribeResponse{} }
func (m *SubscribeResponse) String() string { return proto.CompactTextString(m) }
func (*SubscribeResponse) ProtoMessage()    {}
func (*SubscribeResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_7bc7b0f3637317a2, []int{18}
}

func (m *SubscribeResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SubscribeResponse.Unmarshal(m, b)
}
func (m *SubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SubscribeResponse.Marshal(b, m, deterministic)
}
func (m *SubscribeResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SubscribeResponse.Merge(m, src)
}
func (m *SubscribeResponse) XXX_Size() int {
	return xxx_messageInfo_SubscribeResponse.Size(m)
}
func (m *SubscribeResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_SubscribeResponse.DiscardUnknown(m)
}

var xxx_messageInfo_SubscribeResponse proto.InternalMessageInfo

func (m *SubscribeResponse) GetWriteId() []byte {
	if m != nil {
		return m.WriteId
	}
	return nil
}

func init() {
	proto.RegisterEnum("gateway.v1.WarehouseJob_Status", WarehouseJob_Status_name, WarehouseJob_Status_value)
	proto.RegisterType((*Record)(nil), "gateway.v1.Record")
	proto.RegisterType((*InstanceRecords)(nil), "gateway.v1.InstanceRecords")
	proto.RegisterType((*WarehouseJob)(nil), "gateway.v1.WarehouseJob")
	proto.RegisterType((*PingRequest)(nil), "gateway.v1.PingRequest")
	proto.RegisterType((*PingResponse)(nil), "gateway.v1.PingResponse")
	proto.RegisterType((*WriteRequest)(nil), "gateway.v1.WriteRequest")
	proto.RegisterType((*WriteResponse)(nil), "gateway.v1.WriteResponse")
	proto.RegisterType((*QueryLogRequest)(nil), "gateway.v1.QueryLogRequest")
	proto.RegisterType((*QueryLogResponse)(nil), "gateway.v1.QueryLogResponse")
	proto.RegisterType((*QueryIndexRequest)(nil), "gateway.v1.QueryIndexRequest")
	proto.RegisterType((*QueryIndexResponse)(nil), "gateway.v1.QueryIndexResponse")
	proto.RegisterType((*QueryWarehouseRequest)(nil), "gateway.v1.QueryWarehouseRequest")
	proto.RegisterType((*QueryWarehouseResponse)(nil), "gateway.v1.QueryWarehouseResponse")
	proto.RegisterType((*PollWarehouseJobRequest)(nil), "gateway.v1.PollWarehouseJobRequest")
	proto.RegisterType((*PollWarehouseJobResponse)(nil), "gateway.v1.PollWarehouseJobResponse")
	proto.RegisterType((*ReadRequest)(nil), "gateway.v1.ReadRequest")
	proto.RegisterType((*ReadResponse)(nil), "gateway.v1.ReadResponse")
	proto.RegisterType((*SubscribeRequest)(nil), "gateway.v1.SubscribeRequest")
	proto.RegisterType((*SubscribeResponse)(nil), "gateway.v1.SubscribeResponse")
}

func init() {
	proto.RegisterFile("server/data/grpc/proto/gateway.proto", fileDescriptor_7bc7b0f3637317a2)
}

var fileDescriptor_7bc7b0f3637317a2 = []byte{
	// 1050 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x56, 0xff, 0x4e, 0xdc, 0x46,
	0x10, 0xc6, 0xdc, 0xef, 0xb9, 0x3b, 0x38, 0xb6, 0x01, 0x9c, 0x4b, 0x48, 0xa8, 0x43, 0x25, 0x84,
	0xe8, 0x5d, 0x4a, 0xab, 0xf4, 0x0f, 0xa4, 0x4a, 0x25, 0x24, 0xe8, 0xaa, 0x84, 0x92, 0x45, 0x4d,
	0xd4, 0x4a, 0x95, 0xb3, 0xb6, 0x17, 0xce, 0xf4, 0xec, 0x3d, 0x76, 0xd7, 0x84, 0xcb, 0x33, 0xf4,
	0x61, 0xda, 0x87, 0xea, 0x7b, 0x54, 0xde, 0xb5, 0x7d, 0xf6, 0x71, 0x04, 0xa9, 0x6a, 0xfe, 0xe2,
	0xe6, 0x9b, 0x6f, 0x67, 0x66, 0x67, 0x66, 0x3f, 0x03, 0x5b, 0x82, 0xf2, 0x2b, 0xca, 0xfb, 0x1e,
	0x91, 0xa4, 0x7f, 0xce, 0xc7, 0x6e, 0x7f, 0xcc, 0x99, 0x64, 0xfd, 0x73, 0x22, 0xe9, 0x07, 0x32,
	0xe9, 0x29, 0x0b, 0x41, 0x6a, 0x5e, 0x7d, 0x63, 0x3d, 0x87, 0x2a, 0xa6, 0x2e, 0xe3, 0x1e, 0x7a,
	0x00, 0x0d, 0x72, 0xc5, 0x99, 0x1d, 0x9f, 0x35, 0x8d, 0x4d, 0x63, 0xbb, 0x85, 0xeb, 0x31, 0x70,
	0x48, 0x24, 0x41, 0x0f, 0xa1, 0x21, 0xfd, 0x80, 0x0a, 0x49, 0x82, 0xb1, 0xb9, 0xb8, 0x69, 0x6c,
	0x97, 0xf0, 0x14, 0xb0, 0xde, 0xc3, 0xf2, 0x20, 0x14, 0x92, 0x84, 0x2e, 0xd5, 0xc1, 0x04, 0x7a,
	0x0c, 0x4d, 0x3f, 0x81, 0x6c, 0xdf, 0x4b, 0xe2, 0x41, 0x0a, 0x0d, 0x3c, 0xb4, 0x0b, 0x35, 0xae,
	0xb9, 0xe6, 0xe2, 0x66, 0x69, 0xbb, 0xb9, 0x87, 0x7a, 0xd3, 0xb2, 0x7a, 0x3a, 0x0c, 0x4e, 0x29,
	0xd6, 0x5f, 0x25, 0x68, 0xbd, 0x23, 0x9c, 0x0e, 0x59, 0x24, 0xe8, 0x4f, 0xcc, 0x41, 0xab, 0x50,
	0xbd, 0x60, 0xce, 0x34, 0x74, 0xe5, 0x82, 0x39, 0x03, 0x0f, 0x7d, 0x0f, 0x55, 0x21, 0x89, 0x8c,
	0x84, 0x2a, 0x72, 0x69, 0xef, 0x71, 0x3e, 0x68, 0x3e, 0x40, 0xef, 0x54, 0xd1, 0x70, 0x42, 0x47,
	0xf7, 0xa0, 0x42, 0x39, 0x67, 0xdc, 0x2c, 0x6d, 0x1a, 0xdb, 0x0d, 0xac, 0x0d, 0xb4, 0x0b, 0x88,
	0x53, 0x11, 0x8d, 0xa4, 0xad, 0x5a, 0x23, 0xdc, 0x21, 0x0d, 0x88, 0x59, 0x56, 0x94, 0x8e, 0xf6,
	0xfc, 0x78, 0xc5, 0xd9, 0xa9, 0xc2, 0xd1, 0x57, 0xb0, 0xc4, 0xe9, 0x78, 0x44, 0x26, 0xb6, 0x1b,
	0x71, 0xc1, 0xb8, 0x30, 0x2b, 0x9b, 0xa5, 0xed, 0x16, 0x6e, 0x6b, 0xf4, 0xb9, 0x06, 0xd1, 0x33,
	0x58, 0xe7, 0xf4, 0x8c, 0x72, 0x1a, 0xba, 0xd4, 0xb3, 0x73, 0x5d, 0x12, 0x66, 0x55, 0xf1, 0x57,
	0xa7, 0xee, 0x41, 0xd6, 0x30, 0x81, 0x9e, 0x40, 0xdb, 0x99, 0x48, 0x2a, 0x6c, 0xe1, 0x92, 0x30,
	0xa4, 0x9e, 0x59, 0x53, 0x73, 0x68, 0x29, 0xf0, 0x54, 0x63, 0x68, 0x07, 0x56, 0x92, 0x8a, 0x85,
	0xff, 0x91, 0xda, 0xca, 0x67, 0xd6, 0x15, 0x71, 0x59, 0x3b, 0x4e, 0xfd, 0x8f, 0xf4, 0x20, 0x86,
	0x51, 0x0f, 0xbe, 0xc8, 0x73, 0xd3, 0x71, 0x34, 0x14, 0x7b, 0x65, 0xca, 0x4e, 0x66, 0x6a, 0xed,
	0x42, 0x55, 0x77, 0x0d, 0x35, 0xa1, 0x76, 0xf2, 0xe2, 0xf8, 0x70, 0x70, 0x7c, 0xd4, 0x59, 0x88,
	0x0d, 0xfc, 0xcb, 0xf1, 0x71, 0x6c, 0x18, 0xa8, 0x0e, 0xe5, 0xc3, 0x9f, 0x8f, 0x5f, 0x74, 0x16,
	0xad, 0x37, 0xd0, 0x3c, 0xf1, 0xc3, 0x73, 0x4c, 0x2f, 0x23, 0x2a, 0x64, 0xbc, 0x5e, 0xee, 0xc8,
	0xa7, 0xa1, 0x4c, 0x67, 0xd6, 0xc0, 0x75, 0x0d, 0x0c, 0xbc, 0xb8, 0x73, 0x89, 0xf3, 0x8a, 0x72,
	0xe1, 0xb3, 0x50, 0x8d, 0xaf, 0x81, 0xdb, 0x1a, 0x7d, 0xab, 0x41, 0xeb, 0x4f, 0x03, 0x5a, 0x3a,
	0xa6, 0x18, 0xb3, 0x50, 0x50, 0xb4, 0x05, 0x6d, 0x12, 0xc9, 0x21, 0x0d, 0xa5, 0xef, 0x12, 0x49,
	0x75, 0xe0, 0x3a, 0x2e, 0x82, 0x71, 0xf4, 0x24, 0xac, 0x9d, 0x5b, 0x8e, 0x06, 0x6e, 0x27, 0x68,
	0x72, 0xa9, 0x7e, 0xdc, 0x0e, 0x97, 0x05, 0x01, 0x0d, 0x3d, 0xea, 0x65, 0x95, 0xe8, 0x85, 0x40,
	0x39, 0x57, 0x5a, 0xce, 0x5b, 0x68, 0xbd, 0xe3, 0xbe, 0xa4, 0xe9, 0x15, 0x5f, 0x42, 0x27, 0x9b,
	0x66, 0xda, 0x4c, 0x43, 0xed, 0xf6, 0x83, 0xfc, 0x1a, 0xce, 0x3c, 0x15, 0xbc, 0xec, 0x17, 0x01,
	0x6b, 0x07, 0xda, 0x49, 0xdc, 0xe4, 0x9a, 0xf7, 0xa1, 0xfe, 0x21, 0x06, 0xa6, 0xeb, 0x5e, 0x53,
	0xf6, 0xc0, 0xb3, 0xce, 0x60, 0xf9, 0x4d, 0x44, 0xf9, 0xe4, 0x15, 0xcb, 0x3a, 0x7d, 0xe7, 0xd3,
	0x7b, 0x04, 0x30, 0x26, 0x5c, 0xfa, 0xd2, 0x67, 0xa1, 0xee, 0x45, 0x05, 0xe7, 0x10, 0x84, 0xa0,
	0x3c, 0xa6, 0xf4, 0x0f, 0x75, 0xf3, 0x3a, 0x56, 0xbf, 0xad, 0xf7, 0xd0, 0x99, 0xe6, 0x49, 0xca,
	0xba, 0xb9, 0xef, 0xc6, 0xbc, 0x7d, 0x8f, 0x87, 0x3b, 0x24, 0xe1, 0x39, 0xcd, 0x68, 0x8b, 0x9a,
	0xa6, 0xd1, 0x84, 0x66, 0x8d, 0x60, 0x45, 0x65, 0x18, 0x84, 0x1e, 0xbd, 0xfe, 0xdf, 0xee, 0xb2,
	0x06, 0xd5, 0x33, 0x7f, 0x24, 0x69, 0xfa, 0xb0, 0x13, 0xcb, 0x72, 0x00, 0xe5, 0xb3, 0x7d, 0x96,
	0x1b, 0xfd, 0x6d, 0xc0, 0xaa, 0x4a, 0x92, 0x09, 0x4f, 0x7a, 0xad, 0x7b, 0x50, 0xb9, 0x8c, 0x1d,
	0xc9, 0x43, 0xd0, 0xc6, 0x9d, 0x77, 0x59, 0x87, 0x9a, 0xc7, 0x27, 0x36, 0x8f, 0xc2, 0x64, 0x34,
	0x55, 0x8f, 0x4f, 0x70, 0x14, 0xa2, 0x0d, 0x80, 0x58, 0x8c, 0x59, 0x24, 0xed, 0x40, 0x28, 0x79,
	0xaa, 0x68, 0x79, 0x66, 0x91, 0x7c, 0x2d, 0x62, 0x4d, 0x08, 0xc8, 0xb5, 0x5d, 0x14, 0x8f, 0x8a,
	0xd6, 0x84, 0x80, 0x5c, 0x1f, 0xe4, 0xf4, 0xc3, 0x3a, 0x84, 0xb5, 0xd9, 0x92, 0x93, 0xde, 0xec,
	0x40, 0xe9, 0x82, 0x39, 0xaa, 0xe2, 0xe6, 0x9e, 0x79, 0x9b, 0xae, 0xe2, 0x98, 0x64, 0x3d, 0x85,
	0xf5, 0x13, 0x36, 0x1a, 0x15, 0x1c, 0xc9, 0xd5, 0xe7, 0x0b, 0xb7, 0xf5, 0x12, 0xcc, 0x9b, 0x27,
	0xfe, 0x43, 0xe6, 0x7d, 0x68, 0x62, 0x4a, 0xbc, 0x34, 0xdb, 0x1a, 0x54, 0xf5, 0x88, 0x54, 0x3b,
	0x5b, 0x38, 0xb1, 0xe2, 0x01, 0x8c, 0xfc, 0xc0, 0x97, 0xaa, 0x91, 0x15, 0xac, 0x0d, 0xeb, 0x77,
	0x68, 0xe9, 0xc3, 0x49, 0xe2, 0xdc, 0x37, 0xca, 0xb8, 0xf3, 0x1b, 0x15, 0xef, 0x6a, 0x48, 0xaf,
	0xa5, 0x5d, 0x48, 0x08, 0x31, 0xa4, 0x17, 0xc2, 0xda, 0x81, 0xce, 0x69, 0xe4, 0x08, 0x97, 0xfb,
	0x0e, 0xbd, 0xa3, 0x40, 0xab, 0x07, 0x2b, 0x39, 0xee, 0x9d, 0x3a, 0xb0, 0xf7, 0x4f, 0x19, 0x6a,
	0x47, 0xba, 0x36, 0xb4, 0x0f, 0xe5, 0x58, 0x25, 0xd1, 0x7a, 0xbe, 0xda, 0x9c, 0x16, 0x77, 0xcd,
	0x9b, 0x0e, 0x9d, 0xc1, 0x5a, 0x40, 0x3f, 0x40, 0x45, 0x89, 0x0f, 0x2a, 0x36, 0x3a, 0xa7, 0x73,
	0xdd, 0xfb, 0x73, 0x3c, 0xd9, 0xf9, 0x23, 0xa8, 0xa7, 0x42, 0x81, 0x0a, 0xb2, 0x37, 0x23, 0x53,
	0xdd, 0x87, 0xf3, 0x9d, 0x59, 0xa0, 0xd7, 0x00, 0xd3, 0x17, 0x8a, 0x36, 0x6e, 0xb0, 0xf3, 0x3a,
	0xd1, 0x7d, 0x74, 0x9b, 0x3b, 0x0b, 0xf7, 0x2b, 0x2c, 0x15, 0x17, 0x1b, 0x7d, 0x79, 0xe3, 0xcc,
	0xec, 0x3b, 0xed, 0x5a, 0x9f, 0xa2, 0x64, 0xa1, 0x6d, 0xe8, 0xcc, 0xee, 0x2e, 0x7a, 0x52, 0x68,
	0xf1, 0xfc, 0xb7, 0xd0, 0xdd, 0xfa, 0x34, 0x29, 0x4b, 0xb0, 0x0f, 0xe5, 0x78, 0x2f, 0x8b, 0x03,
	0xcd, 0xad, 0x79, 0x71, 0xa0, 0xf9, 0x15, 0xb6, 0x16, 0xd0, 0x2b, 0x68, 0x64, 0x9b, 0x84, 0x0a,
	0x4d, 0x9f, 0x5d, 0xc6, 0xee, 0xc6, 0x2d, 0xde, 0x34, 0xd6, 0x53, 0xe3, 0xe0, 0xd9, 0x6f, 0xdf,
	0x9d, 0xfb, 0x72, 0x44, 0x9c, 0x9e, 0xcb, 0x82, 0xbe, 0x43, 0x43, 0x4a, 0xe4, 0xf0, 0xeb, 0xe1,
	0x65, 0xfa, 0xb3, 0x3f, 0xff, 0x3f, 0x50, 0xa7, 0xaa, 0xfe, 0x7c, 0xfb, 0x6f, 0x00, 0x00, 0x00,
	0xff, 0xff, 0x14, 0x18, 0xee, 0x6e, 0xa2, 0x0a, 0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// GatewayClient is the client API for Gateway service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type GatewayClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	QueryLog(ctx context.Context, in *QueryLogRequest, opts ...grpc.CallOption) (*QueryLogResponse, error)
	QueryIndex(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (*QueryIndexResponse, error)
	QueryWarehouse(ctx context.Context, in *QueryWarehouseRequest, opts ...grpc.CallOption) (*QueryWarehouseResponse, error)
	PollWarehouseJob(ctx context.Context, in *PollWarehouseJobRequest, opts ...grpc.CallOption) (*PollWarehouseJobResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Gateway_SubscribeClient, error)
}

type gatewayClient struct {
	cc *grpc.ClientConn
}

func NewGatewayClient(cc *grpc.ClientConn) GatewayClient {
	return &gatewayClient{cc}
}

func (c *gatewayClient) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) {
	out := new(PingResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/Ping", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) {
	out := new(WriteResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/Write", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) QueryLog(ctx context.Context, in *QueryLogRequest, opts ...grpc.CallOption) (*QueryLogResponse, error) {
	out := new(QueryLogResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/QueryLog", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) QueryIndex(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (*QueryIndexResponse, error) {
	out := new(QueryIndexResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/QueryIndex", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) QueryWarehouse(ctx context.Context, in *QueryWarehouseRequest, opts ...grpc.CallOption) (*QueryWarehouseResponse, error) {
	out := new(QueryWarehouseResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/QueryWarehouse", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) PollWarehouseJob(ctx context.Context, in *PollWarehouseJobRequest, opts ...grpc.CallOption) (*PollWarehouseJobResponse, error) {
	out := new(PollWarehouseJobResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/PollWarehouseJob", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) {
	out := new(ReadResponse)
	err := c.cc.Invoke(ctx, "/gateway.v1.Gateway/Read", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *gatewayClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Gateway_SubscribeClient, error) {
	stream, err := c.cc.NewStream(ctx, &_Gateway_serviceDesc.Streams[0], "/gateway.v1.Gateway/Subscribe", opts...)
	if err != nil {
		return nil, err
	}
	x := &gatewaySubscribeClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

type Gateway_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type gatewaySubscribeClient struct {
	grpc.ClientStream
}

func (x *gatewaySubscribeClient) Recv() (*SubscribeResponse, error) {
	m := new(SubscribeResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

// GatewayServer is the server API for Gateway service.
type GatewayServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	QueryLog(context.Context, *QueryLogRequest) (*QueryLogResponse, error)
	QueryIndex(context.Context, *QueryIndexRequest) (*QueryIndexResponse, error)
	QueryWarehouse(context.Context, *QueryWarehouseRequest) (*QueryWarehouseResponse, error)
	PollWarehouseJob(context.Context, *PollWarehouseJobRequest) (*PollWarehouseJobResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Subscribe(*SubscribeRequest, Gateway_SubscribeServer) error
}

// UnimplementedGatewayServer can be embedded to have forward compatible implementations.
type UnimplementedGatewayServer struct {
}

func (*UnimplementedGatewayServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
}
func (*UnimplementedGatewayServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Write not implemented")
}
func (*UnimplementedGatewayServer) QueryLog(ctx context.Context, req *QueryLogRequest) (*QueryLogResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueryLog not implemented")
}
func (*UnimplementedGatewayServer) QueryIndex(ctx context.Context, req *QueryIndexRequest) (*QueryIndexResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueryIndex not implemented")
}
func (*UnimplementedGatewayServer) QueryWarehouse(ctx context.Context, req *QueryWarehouseRequest) (*QueryWarehouseResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueryWarehouse not implemented")
}
func (*UnimplementedGatewayServer) PollWarehouseJob(ctx context.Context, req *PollWarehouseJobRequest) (*PollWarehouseJobResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PollWarehouseJob not implemented")
}
func (*UnimplementedGatewayServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Read not implemented")
}
func (*UnimplementedGatewayServer) Subscribe(req *SubscribeRequest, srv Gateway_SubscribeServer) error {
	return status.Errorf(codes.Unimplemented, "method Subscribe not implemented")
}

func RegisterGatewayServer(s *grpc.Server, srv GatewayServer) {
	s.RegisterService(&_Gateway_serviceDesc, srv)
}

func _Gateway_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).Ping(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/Ping",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).Ping(ctx, req.(*PingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_Write_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WriteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).Write(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/Write",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).Write(ctx, req.(*WriteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_QueryLog_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryLogRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).QueryLog(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/QueryLog",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).QueryLog(ctx, req.(*QueryLogRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_QueryIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryIndexRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).QueryIndex(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/QueryIndex",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).QueryIndex(ctx, req.(*QueryIndexRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_QueryWarehouse_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryWarehouseRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).QueryWarehouse(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/QueryWarehouse",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).QueryWarehouse(ctx, req.(*QueryWarehouseRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_PollWarehouseJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PollWarehouseJobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).PollWarehouseJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/PollWarehouseJob",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).PollWarehouseJob(ctx, req.(*PollWarehouseJobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_Read_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReadRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(GatewayServer).Read(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/gateway.v1.Gateway/Read",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(GatewayServer).Read(ctx, req.(*ReadRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Gateway_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SubscribeRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(GatewayServer).Subscribe(m, &gatewaySubscribeServer{stream})
}

type Gateway_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type gatewaySubscribeServer struct {
	grpc.ServerStream
}

func (x *gatewaySubscribeServer) Send(m *SubscribeResponse) error {
	return x.ServerStream.SendMsg(m)
}

var _Gateway_serviceDesc = grpc.ServiceDesc{
	ServiceName: "gateway.v1.Gateway",
	HandlerType: (*GatewayServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Gateway_Ping_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _Gateway_Write_Handler,
		},
		{
			MethodName: "QueryLog",
			Handler:    _Gateway_QueryLog_Handler,
		},
		{
			MethodName: "QueryIndex",
			Handler:    _Gateway_QueryIndex_Handler,
		},
		{
			MethodName: "QueryWarehouse",
			Handler:    _Gateway_QueryWarehouse_Handler,
		},
		{
			MethodName: "PollWarehouseJob",
			Handler:    _Gateway_PollWarehouseJob_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _Gateway_Read_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Gateway_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "server/data/grpc/proto/gateway.proto",
}
