btrdb.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: v5api/btrdb.proto

package v5api

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import _ "google.golang.org/genproto/googleapis/api/annotations"

import (
	context "golang.org/x/net/context"
	grpc "google.golang.org/grpc"
)

// 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.ProtoPackageIsVersion2 // please upgrade the proto package

type GenerateCSVParams_QueryType int32

const (
	GenerateCSVParams_ALIGNED_WINDOWS_QUERY GenerateCSVParams_QueryType = 0
	GenerateCSVParams_WINDOWS_QUERY         GenerateCSVParams_QueryType = 1
	GenerateCSVParams_RAW_QUERY             GenerateCSVParams_QueryType = 2
)

var GenerateCSVParams_QueryType_name = map[int32]string{
	0: "ALIGNED_WINDOWS_QUERY",
	1: "WINDOWS_QUERY",
	2: "RAW_QUERY",
}
var GenerateCSVParams_QueryType_value = map[string]int32{
	"ALIGNED_WINDOWS_QUERY": 0,
	"WINDOWS_QUERY":         1,
	"RAW_QUERY":             2,
}

func (x GenerateCSVParams_QueryType) String() string {
	return proto.EnumName(GenerateCSVParams_QueryType_name, int32(x))
}
func (GenerateCSVParams_QueryType) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{49, 0}
}

type RawValuesParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *RawValuesParams) Reset()         { *m = RawValuesParams{} }
func (m *RawValuesParams) String() string { return proto.CompactTextString(m) }
func (*RawValuesParams) ProtoMessage()    {}
func (*RawValuesParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{0}
}
func (m *RawValuesParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RawValuesParams.Unmarshal(m, b)
}
func (m *RawValuesParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RawValuesParams.Marshal(b, m, deterministic)
}
func (dst *RawValuesParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RawValuesParams.Merge(dst, src)
}
func (m *RawValuesParams) XXX_Size() int {
	return xxx_messageInfo_RawValuesParams.Size(m)
}
func (m *RawValuesParams) XXX_DiscardUnknown() {
	xxx_messageInfo_RawValuesParams.DiscardUnknown(m)
}

var xxx_messageInfo_RawValuesParams proto.InternalMessageInfo

func (m *RawValuesParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *RawValuesParams) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *RawValuesParams) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

func (m *RawValuesParams) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

type RawValuesResponse struct {
	Stat                 *Status     `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64      `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64      `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values               []*RawPoint `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (m *RawValuesResponse) Reset()         { *m = RawValuesResponse{} }
func (m *RawValuesResponse) String() string { return proto.CompactTextString(m) }
func (*RawValuesResponse) ProtoMessage()    {}
func (*RawValuesResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{1}
}
func (m *RawValuesResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RawValuesResponse.Unmarshal(m, b)
}
func (m *RawValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RawValuesResponse.Marshal(b, m, deterministic)
}
func (dst *RawValuesResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RawValuesResponse.Merge(dst, src)
}
func (m *RawValuesResponse) XXX_Size() int {
	return xxx_messageInfo_RawValuesResponse.Size(m)
}
func (m *RawValuesResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_RawValuesResponse.DiscardUnknown(m)
}

var xxx_messageInfo_RawValuesResponse proto.InternalMessageInfo

func (m *RawValuesResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *RawValuesResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *RawValuesResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

func (m *RawValuesResponse) GetValues() []*RawPoint {
	if m != nil {
		return m.Values
	}
	return nil
}

type AlignedWindowsParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	PointWidth           uint32   `protobuf:"varint,5,opt,name=pointWidth,proto3" json:"pointWidth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *AlignedWindowsParams) Reset()         { *m = AlignedWindowsParams{} }
func (m *AlignedWindowsParams) String() string { return proto.CompactTextString(m) }
func (*AlignedWindowsParams) ProtoMessage()    {}
func (*AlignedWindowsParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{2}
}
func (m *AlignedWindowsParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_AlignedWindowsParams.Unmarshal(m, b)
}
func (m *AlignedWindowsParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_AlignedWindowsParams.Marshal(b, m, deterministic)
}
func (dst *AlignedWindowsParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_AlignedWindowsParams.Merge(dst, src)
}
func (m *AlignedWindowsParams) XXX_Size() int {
	return xxx_messageInfo_AlignedWindowsParams.Size(m)
}
func (m *AlignedWindowsParams) XXX_DiscardUnknown() {
	xxx_messageInfo_AlignedWindowsParams.DiscardUnknown(m)
}

var xxx_messageInfo_AlignedWindowsParams proto.InternalMessageInfo

func (m *AlignedWindowsParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *AlignedWindowsParams) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *AlignedWindowsParams) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

func (m *AlignedWindowsParams) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *AlignedWindowsParams) GetPointWidth() uint32 {
	if m != nil {
		return m.PointWidth
	}
	return 0
}

type AlignedWindowsResponse struct {
	Stat                 *Status      `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64       `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64       `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values               []*StatPoint `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (m *AlignedWindowsResponse) Reset()         { *m = AlignedWindowsResponse{} }
func (m *AlignedWindowsResponse) String() string { return proto.CompactTextString(m) }
func (*AlignedWindowsResponse) ProtoMessage()    {}
func (*AlignedWindowsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{3}
}
func (m *AlignedWindowsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_AlignedWindowsResponse.Unmarshal(m, b)
}
func (m *AlignedWindowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_AlignedWindowsResponse.Marshal(b, m, deterministic)
}
func (dst *AlignedWindowsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_AlignedWindowsResponse.Merge(dst, src)
}
func (m *AlignedWindowsResponse) XXX_Size() int {
	return xxx_messageInfo_AlignedWindowsResponse.Size(m)
}
func (m *AlignedWindowsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_AlignedWindowsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_AlignedWindowsResponse proto.InternalMessageInfo

func (m *AlignedWindowsResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *AlignedWindowsResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *AlignedWindowsResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

func (m *AlignedWindowsResponse) GetValues() []*StatPoint {
	if m != nil {
		return m.Values
	}
	return nil
}

type WindowsParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,4,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	Width                uint64   `protobuf:"varint,5,opt,name=width,proto3" json:"width,omitempty"`
	Depth                uint32   `protobuf:"varint,6,opt,name=depth,proto3" json:"depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *WindowsParams) Reset()         { *m = WindowsParams{} }
func (m *WindowsParams) String() string { return proto.CompactTextString(m) }
func (*WindowsParams) ProtoMessage()    {}
func (*WindowsParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{4}
}
func (m *WindowsParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WindowsParams.Unmarshal(m, b)
}
func (m *WindowsParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WindowsParams.Marshal(b, m, deterministic)
}
func (dst *WindowsParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WindowsParams.Merge(dst, src)
}
func (m *WindowsParams) XXX_Size() int {
	return xxx_messageInfo_WindowsParams.Size(m)
}
func (m *WindowsParams) XXX_DiscardUnknown() {
	xxx_messageInfo_WindowsParams.DiscardUnknown(m)
}

var xxx_messageInfo_WindowsParams proto.InternalMessageInfo

func (m *WindowsParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *WindowsParams) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *WindowsParams) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

func (m *WindowsParams) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *WindowsParams) GetWidth() uint64 {
	if m != nil {
		return m.Width
	}
	return 0
}

func (m *WindowsParams) GetDepth() uint32 {
	if m != nil {
		return m.Depth
	}
	return 0
}

type WindowsResponse struct {
	Stat                 *Status      `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64       `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64       `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Values               []*StatPoint `protobuf:"bytes,4,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (m *WindowsResponse) Reset()         { *m = WindowsResponse{} }
func (m *WindowsResponse) String() string { return proto.CompactTextString(m) }
func (*WindowsResponse) ProtoMessage()    {}
func (*WindowsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{5}
}
func (m *WindowsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WindowsResponse.Unmarshal(m, b)
}
func (m *WindowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WindowsResponse.Marshal(b, m, deterministic)
}
func (dst *WindowsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WindowsResponse.Merge(dst, src)
}
func (m *WindowsResponse) XXX_Size() int {
	return xxx_messageInfo_WindowsResponse.Size(m)
}
func (m *WindowsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_WindowsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_WindowsResponse proto.InternalMessageInfo

func (m *WindowsResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *WindowsResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *WindowsResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

func (m *WindowsResponse) GetValues() []*StatPoint {
	if m != nil {
		return m.Values
	}
	return nil
}

type StreamInfoParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	OmitVersion          bool     `protobuf:"varint,2,opt,name=omitVersion,proto3" json:"omitVersion,omitempty"`
	OmitDescriptor       bool     `protobuf:"varint,3,opt,name=omitDescriptor,proto3" json:"omitDescriptor,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *StreamInfoParams) Reset()         { *m = StreamInfoParams{} }
func (m *StreamInfoParams) String() string { return proto.CompactTextString(m) }
func (*StreamInfoParams) ProtoMessage()    {}
func (*StreamInfoParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{6}
}
func (m *StreamInfoParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StreamInfoParams.Unmarshal(m, b)
}
func (m *StreamInfoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StreamInfoParams.Marshal(b, m, deterministic)
}
func (dst *StreamInfoParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StreamInfoParams.Merge(dst, src)
}
func (m *StreamInfoParams) XXX_Size() int {
	return xxx_messageInfo_StreamInfoParams.Size(m)
}
func (m *StreamInfoParams) XXX_DiscardUnknown() {
	xxx_messageInfo_StreamInfoParams.DiscardUnknown(m)
}

var xxx_messageInfo_StreamInfoParams proto.InternalMessageInfo

func (m *StreamInfoParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *StreamInfoParams) GetOmitVersion() bool {
	if m != nil {
		return m.OmitVersion
	}
	return false
}

func (m *StreamInfoParams) GetOmitDescriptor() bool {
	if m != nil {
		return m.OmitDescriptor
	}
	return false
}

func (m *StreamInfoParams) GetRole() *Role {
	if m != nil {
		return m.Role
	}
	return nil
}

type StreamInfoResponse struct {
	Stat                 *Status           `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64            `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64            `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Descriptor_          *StreamDescriptor `protobuf:"bytes,4,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *StreamInfoResponse) Reset()         { *m = StreamInfoResponse{} }
func (m *StreamInfoResponse) String() string { return proto.CompactTextString(m) }
func (*StreamInfoResponse) ProtoMessage()    {}
func (*StreamInfoResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{7}
}
func (m *StreamInfoResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StreamInfoResponse.Unmarshal(m, b)
}
func (m *StreamInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StreamInfoResponse.Marshal(b, m, deterministic)
}
func (dst *StreamInfoResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StreamInfoResponse.Merge(dst, src)
}
func (m *StreamInfoResponse) XXX_Size() int {
	return xxx_messageInfo_StreamInfoResponse.Size(m)
}
func (m *StreamInfoResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_StreamInfoResponse.DiscardUnknown(m)
}

var xxx_messageInfo_StreamInfoResponse proto.InternalMessageInfo

func (m *StreamInfoResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *StreamInfoResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *StreamInfoResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

func (m *StreamInfoResponse) GetDescriptor_() *StreamDescriptor {
	if m != nil {
		return m.Descriptor_
	}
	return nil
}

type StreamDescriptor struct {
	Uuid                 []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Collection           string         `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty"`
	PropertyVersion      uint64         `protobuf:"varint,5,opt,name=propertyVersion,proto3" json:"propertyVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *StreamDescriptor) Reset()         { *m = StreamDescriptor{} }
func (m *StreamDescriptor) String() string { return proto.CompactTextString(m) }
func (*StreamDescriptor) ProtoMessage()    {}
func (*StreamDescriptor) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{8}
}
func (m *StreamDescriptor) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StreamDescriptor.Unmarshal(m, b)
}
func (m *StreamDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StreamDescriptor.Marshal(b, m, deterministic)
}
func (dst *StreamDescriptor) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StreamDescriptor.Merge(dst, src)
}
func (m *StreamDescriptor) XXX_Size() int {
	return xxx_messageInfo_StreamDescriptor.Size(m)
}
func (m *StreamDescriptor) XXX_DiscardUnknown() {
	xxx_messageInfo_StreamDescriptor.DiscardUnknown(m)
}

var xxx_messageInfo_StreamDescriptor proto.InternalMessageInfo

func (m *StreamDescriptor) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *StreamDescriptor) GetCollection() string {
	if m != nil {
		return m.Collection
	}
	return ""
}

func (m *StreamDescriptor) GetTags() []*KeyOptValue {
	if m != nil {
		return m.Tags
	}
	return nil
}

func (m *StreamDescriptor) GetAnnotations() []*KeyOptValue {
	if m != nil {
		return m.Annotations
	}
	return nil
}

func (m *StreamDescriptor) GetPropertyVersion() uint64 {
	if m != nil {
		return m.PropertyVersion
	}
	return 0
}

type SetStreamAnnotationsParams struct {
	Uuid                    []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ExpectedPropertyVersion uint64         `protobuf:"varint,2,opt,name=expectedPropertyVersion,proto3" json:"expectedPropertyVersion,omitempty"`
	Changes                 []*KeyOptValue `protobuf:"bytes,3,rep,name=changes,proto3" json:"changes,omitempty"`
	Removals                []string       `protobuf:"bytes,4,rep,name=removals,proto3" json:"removals,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}       `json:"-"`
	XXX_unrecognized        []byte         `json:"-"`
	XXX_sizecache           int32          `json:"-"`
}

func (m *SetStreamAnnotationsParams) Reset()         { *m = SetStreamAnnotationsParams{} }
func (m *SetStreamAnnotationsParams) String() string { return proto.CompactTextString(m) }
func (*SetStreamAnnotationsParams) ProtoMessage()    {}
func (*SetStreamAnnotationsParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{9}
}
func (m *SetStreamAnnotationsParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetStreamAnnotationsParams.Unmarshal(m, b)
}
func (m *SetStreamAnnotationsParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetStreamAnnotationsParams.Marshal(b, m, deterministic)
}
func (dst *SetStreamAnnotationsParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetStreamAnnotationsParams.Merge(dst, src)
}
func (m *SetStreamAnnotationsParams) XXX_Size() int {
	return xxx_messageInfo_SetStreamAnnotationsParams.Size(m)
}
func (m *SetStreamAnnotationsParams) XXX_DiscardUnknown() {
	xxx_messageInfo_SetStreamAnnotationsParams.DiscardUnknown(m)
}

var xxx_messageInfo_SetStreamAnnotationsParams proto.InternalMessageInfo

func (m *SetStreamAnnotationsParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *SetStreamAnnotationsParams) GetExpectedPropertyVersion() uint64 {
	if m != nil {
		return m.ExpectedPropertyVersion
	}
	return 0
}

func (m *SetStreamAnnotationsParams) GetChanges() []*KeyOptValue {
	if m != nil {
		return m.Changes
	}
	return nil
}

func (m *SetStreamAnnotationsParams) GetRemovals() []string {
	if m != nil {
		return m.Removals
	}
	return nil
}

type SetStreamAnnotationsResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetStreamAnnotationsResponse) Reset()         { *m = SetStreamAnnotationsResponse{} }
func (m *SetStreamAnnotationsResponse) String() string { return proto.CompactTextString(m) }
func (*SetStreamAnnotationsResponse) ProtoMessage()    {}
func (*SetStreamAnnotationsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{10}
}
func (m *SetStreamAnnotationsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetStreamAnnotationsResponse.Unmarshal(m, b)
}
func (m *SetStreamAnnotationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetStreamAnnotationsResponse.Marshal(b, m, deterministic)
}
func (dst *SetStreamAnnotationsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetStreamAnnotationsResponse.Merge(dst, src)
}
func (m *SetStreamAnnotationsResponse) XXX_Size() int {
	return xxx_messageInfo_SetStreamAnnotationsResponse.Size(m)
}
func (m *SetStreamAnnotationsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_SetStreamAnnotationsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_SetStreamAnnotationsResponse proto.InternalMessageInfo

func (m *SetStreamAnnotationsResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

type SetStreamTagsParams struct {
	Uuid                    []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ExpectedPropertyVersion uint64         `protobuf:"varint,2,opt,name=expectedPropertyVersion,proto3" json:"expectedPropertyVersion,omitempty"`
	Tags                    []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Collection              string         `protobuf:"bytes,4,opt,name=collection,proto3" json:"collection,omitempty"`
	Remove                  []string       `protobuf:"bytes,5,rep,name=remove,proto3" json:"remove,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}       `json:"-"`
	XXX_unrecognized        []byte         `json:"-"`
	XXX_sizecache           int32          `json:"-"`
}

func (m *SetStreamTagsParams) Reset()         { *m = SetStreamTagsParams{} }
func (m *SetStreamTagsParams) String() string { return proto.CompactTextString(m) }
func (*SetStreamTagsParams) ProtoMessage()    {}
func (*SetStreamTagsParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{11}
}
func (m *SetStreamTagsParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetStreamTagsParams.Unmarshal(m, b)
}
func (m *SetStreamTagsParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetStreamTagsParams.Marshal(b, m, deterministic)
}
func (dst *SetStreamTagsParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetStreamTagsParams.Merge(dst, src)
}
func (m *SetStreamTagsParams) XXX_Size() int {
	return xxx_messageInfo_SetStreamTagsParams.Size(m)
}
func (m *SetStreamTagsParams) XXX_DiscardUnknown() {
	xxx_messageInfo_SetStreamTagsParams.DiscardUnknown(m)
}

var xxx_messageInfo_SetStreamTagsParams proto.InternalMessageInfo

func (m *SetStreamTagsParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *SetStreamTagsParams) GetExpectedPropertyVersion() uint64 {
	if m != nil {
		return m.ExpectedPropertyVersion
	}
	return 0
}

func (m *SetStreamTagsParams) GetTags() []*KeyOptValue {
	if m != nil {
		return m.Tags
	}
	return nil
}

func (m *SetStreamTagsParams) GetCollection() string {
	if m != nil {
		return m.Collection
	}
	return ""
}

func (m *SetStreamTagsParams) GetRemove() []string {
	if m != nil {
		return m.Remove
	}
	return nil
}

type SetStreamTagsResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetStreamTagsResponse) Reset()         { *m = SetStreamTagsResponse{} }
func (m *SetStreamTagsResponse) String() string { return proto.CompactTextString(m) }
func (*SetStreamTagsResponse) ProtoMessage()    {}
func (*SetStreamTagsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{12}
}
func (m *SetStreamTagsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetStreamTagsResponse.Unmarshal(m, b)
}
func (m *SetStreamTagsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetStreamTagsResponse.Marshal(b, m, deterministic)
}
func (dst *SetStreamTagsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetStreamTagsResponse.Merge(dst, src)
}
func (m *SetStreamTagsResponse) XXX_Size() int {
	return xxx_messageInfo_SetStreamTagsResponse.Size(m)
}
func (m *SetStreamTagsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_SetStreamTagsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_SetStreamTagsResponse proto.InternalMessageInfo

func (m *SetStreamTagsResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

type CreateParams struct {
	Uuid                 []byte         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Collection           string         `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *CreateParams) Reset()         { *m = CreateParams{} }
func (m *CreateParams) String() string { return proto.CompactTextString(m) }
func (*CreateParams) ProtoMessage()    {}
func (*CreateParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{13}
}
func (m *CreateParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateParams.Unmarshal(m, b)
}
func (m *CreateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateParams.Marshal(b, m, deterministic)
}
func (dst *CreateParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateParams.Merge(dst, src)
}
func (m *CreateParams) XXX_Size() int {
	return xxx_messageInfo_CreateParams.Size(m)
}
func (m *CreateParams) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateParams.DiscardUnknown(m)
}

var xxx_messageInfo_CreateParams proto.InternalMessageInfo

func (m *CreateParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *CreateParams) GetCollection() string {
	if m != nil {
		return m.Collection
	}
	return ""
}

func (m *CreateParams) GetTags() []*KeyOptValue {
	if m != nil {
		return m.Tags
	}
	return nil
}

func (m *CreateParams) GetAnnotations() []*KeyOptValue {
	if m != nil {
		return m.Annotations
	}
	return nil
}

type CreateResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *CreateResponse) Reset()         { *m = CreateResponse{} }
func (m *CreateResponse) String() string { return proto.CompactTextString(m) }
func (*CreateResponse) ProtoMessage()    {}
func (*CreateResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{14}
}
func (m *CreateResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreateResponse.Unmarshal(m, b)
}
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreateResponse.Marshal(b, m, deterministic)
}
func (dst *CreateResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreateResponse.Merge(dst, src)
}
func (m *CreateResponse) XXX_Size() int {
	return xxx_messageInfo_CreateResponse.Size(m)
}
func (m *CreateResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CreateResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CreateResponse proto.InternalMessageInfo

func (m *CreateResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

type MetadataUsageParams struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MetadataUsageParams) Reset()         { *m = MetadataUsageParams{} }
func (m *MetadataUsageParams) String() string { return proto.CompactTextString(m) }
func (*MetadataUsageParams) ProtoMessage()    {}
func (*MetadataUsageParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{15}
}
func (m *MetadataUsageParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MetadataUsageParams.Unmarshal(m, b)
}
func (m *MetadataUsageParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MetadataUsageParams.Marshal(b, m, deterministic)
}
func (dst *MetadataUsageParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MetadataUsageParams.Merge(dst, src)
}
func (m *MetadataUsageParams) XXX_Size() int {
	return xxx_messageInfo_MetadataUsageParams.Size(m)
}
func (m *MetadataUsageParams) XXX_DiscardUnknown() {
	xxx_messageInfo_MetadataUsageParams.DiscardUnknown(m)
}

var xxx_messageInfo_MetadataUsageParams proto.InternalMessageInfo

func (m *MetadataUsageParams) GetPrefix() string {
	if m != nil {
		return m.Prefix
	}
	return ""
}

func (m *MetadataUsageParams) GetRole() *Role {
	if m != nil {
		return m.Role
	}
	return nil
}

type MetadataUsageResponse struct {
	Stat                 *Status     `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Tags                 []*KeyCount `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyCount `protobuf:"bytes,3,rep,name=annotations,proto3" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (m *MetadataUsageResponse) Reset()         { *m = MetadataUsageResponse{} }
func (m *MetadataUsageResponse) String() string { return proto.CompactTextString(m) }
func (*MetadataUsageResponse) ProtoMessage()    {}
func (*MetadataUsageResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{16}
}
func (m *MetadataUsageResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MetadataUsageResponse.Unmarshal(m, b)
}
func (m *MetadataUsageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MetadataUsageResponse.Marshal(b, m, deterministic)
}
func (dst *MetadataUsageResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MetadataUsageResponse.Merge(dst, src)
}
func (m *MetadataUsageResponse) XXX_Size() int {
	return xxx_messageInfo_MetadataUsageResponse.Size(m)
}
func (m *MetadataUsageResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_MetadataUsageResponse.DiscardUnknown(m)
}

var xxx_messageInfo_MetadataUsageResponse proto.InternalMessageInfo

func (m *MetadataUsageResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *MetadataUsageResponse) GetTags() []*KeyCount {
	if m != nil {
		return m.Tags
	}
	return nil
}

func (m *MetadataUsageResponse) GetAnnotations() []*KeyCount {
	if m != nil {
		return m.Annotations
	}
	return nil
}

type KeyCount struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Count                uint64   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *KeyCount) Reset()         { *m = KeyCount{} }
func (m *KeyCount) String() string { return proto.CompactTextString(m) }
func (*KeyCount) ProtoMessage()    {}
func (*KeyCount) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{17}
}
func (m *KeyCount) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_KeyCount.Unmarshal(m, b)
}
func (m *KeyCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_KeyCount.Marshal(b, m, deterministic)
}
func (dst *KeyCount) XXX_Merge(src proto.Message) {
	xxx_messageInfo_KeyCount.Merge(dst, src)
}
func (m *KeyCount) XXX_Size() int {
	return xxx_messageInfo_KeyCount.Size(m)
}
func (m *KeyCount) XXX_DiscardUnknown() {
	xxx_messageInfo_KeyCount.DiscardUnknown(m)
}

var xxx_messageInfo_KeyCount proto.InternalMessageInfo

func (m *KeyCount) GetKey() string {
	if m != nil {
		return m.Key
	}
	return ""
}

func (m *KeyCount) GetCount() uint64 {
	if m != nil {
		return m.Count
	}
	return 0
}

type ListCollectionsParams struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListCollectionsParams) Reset()         { *m = ListCollectionsParams{} }
func (m *ListCollectionsParams) String() string { return proto.CompactTextString(m) }
func (*ListCollectionsParams) ProtoMessage()    {}
func (*ListCollectionsParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{18}
}
func (m *ListCollectionsParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListCollectionsParams.Unmarshal(m, b)
}
func (m *ListCollectionsParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListCollectionsParams.Marshal(b, m, deterministic)
}
func (dst *ListCollectionsParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListCollectionsParams.Merge(dst, src)
}
func (m *ListCollectionsParams) XXX_Size() int {
	return xxx_messageInfo_ListCollectionsParams.Size(m)
}
func (m *ListCollectionsParams) XXX_DiscardUnknown() {
	xxx_messageInfo_ListCollectionsParams.DiscardUnknown(m)
}

var xxx_messageInfo_ListCollectionsParams proto.InternalMessageInfo

func (m *ListCollectionsParams) GetPrefix() string {
	if m != nil {
		return m.Prefix
	}
	return ""
}

func (m *ListCollectionsParams) GetRole() *Role {
	if m != nil {
		return m.Role
	}
	return nil
}

type ListCollectionsResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Collections          []string `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListCollectionsResponse) Reset()         { *m = ListCollectionsResponse{} }
func (m *ListCollectionsResponse) String() string { return proto.CompactTextString(m) }
func (*ListCollectionsResponse) ProtoMessage()    {}
func (*ListCollectionsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{19}
}
func (m *ListCollectionsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListCollectionsResponse.Unmarshal(m, b)
}
func (m *ListCollectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListCollectionsResponse.Marshal(b, m, deterministic)
}
func (dst *ListCollectionsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListCollectionsResponse.Merge(dst, src)
}
func (m *ListCollectionsResponse) XXX_Size() int {
	return xxx_messageInfo_ListCollectionsResponse.Size(m)
}
func (m *ListCollectionsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListCollectionsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListCollectionsResponse proto.InternalMessageInfo

func (m *ListCollectionsResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *ListCollectionsResponse) GetCollections() []string {
	if m != nil {
		return m.Collections
	}
	return nil
}

type LookupStreamsParams struct {
	Collection           string         `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	IsCollectionPrefix   bool           `protobuf:"varint,2,opt,name=isCollectionPrefix,proto3" json:"isCollectionPrefix,omitempty"`
	Tags                 []*KeyOptValue `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Annotations          []*KeyOptValue `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty"`
	Role                 *Role          `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *LookupStreamsParams) Reset()         { *m = LookupStreamsParams{} }
func (m *LookupStreamsParams) String() string { return proto.CompactTextString(m) }
func (*LookupStreamsParams) ProtoMessage()    {}
func (*LookupStreamsParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{20}
}
func (m *LookupStreamsParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_LookupStreamsParams.Unmarshal(m, b)
}
func (m *LookupStreamsParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_LookupStreamsParams.Marshal(b, m, deterministic)
}
func (dst *LookupStreamsParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_LookupStreamsParams.Merge(dst, src)
}
func (m *LookupStreamsParams) XXX_Size() int {
	return xxx_messageInfo_LookupStreamsParams.Size(m)
}
func (m *LookupStreamsParams) XXX_DiscardUnknown() {
	xxx_messageInfo_LookupStreamsParams.DiscardUnknown(m)
}

var xxx_messageInfo_LookupStreamsParams proto.InternalMessageInfo

func (m *LookupStreamsParams) GetCollection() string {
	if m != nil {
		return m.Collection
	}
	return ""
}

func (m *LookupStreamsParams) GetIsCollectionPrefix() bool {
	if m != nil {
		return m.IsCollectionPrefix
	}
	return false
}

func (m *LookupStreamsParams) GetTags() []*KeyOptValue {
	if m != nil {
		return m.Tags
	}
	return nil
}

func (m *LookupStreamsParams) GetAnnotations() []*KeyOptValue {
	if m != nil {
		return m.Annotations
	}
	return nil
}

func (m *LookupStreamsParams) GetRole() *Role {
	if m != nil {
		return m.Role
	}
	return nil
}

type LookupStreamsResponse struct {
	Stat                 *Status             `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Results              []*StreamDescriptor `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (m *LookupStreamsResponse) Reset()         { *m = LookupStreamsResponse{} }
func (m *LookupStreamsResponse) String() string { return proto.CompactTextString(m) }
func (*LookupStreamsResponse) ProtoMessage()    {}
func (*LookupStreamsResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{21}
}
func (m *LookupStreamsResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_LookupStreamsResponse.Unmarshal(m, b)
}
func (m *LookupStreamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_LookupStreamsResponse.Marshal(b, m, deterministic)
}
func (dst *LookupStreamsResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_LookupStreamsResponse.Merge(dst, src)
}
func (m *LookupStreamsResponse) XXX_Size() int {
	return xxx_messageInfo_LookupStreamsResponse.Size(m)
}
func (m *LookupStreamsResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_LookupStreamsResponse.DiscardUnknown(m)
}

var xxx_messageInfo_LookupStreamsResponse proto.InternalMessageInfo

func (m *LookupStreamsResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *LookupStreamsResponse) GetResults() []*StreamDescriptor {
	if m != nil {
		return m.Results
	}
	return nil
}

type NearestParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Time                 int64    `protobuf:"fixed64,2,opt,name=time,proto3" json:"time,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,3,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	Backward             bool     `protobuf:"varint,4,opt,name=backward,proto3" json:"backward,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *NearestParams) Reset()         { *m = NearestParams{} }
func (m *NearestParams) String() string { return proto.CompactTextString(m) }
func (*NearestParams) ProtoMessage()    {}
func (*NearestParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{22}
}
func (m *NearestParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_NearestParams.Unmarshal(m, b)
}
func (m *NearestParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_NearestParams.Marshal(b, m, deterministic)
}
func (dst *NearestParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_NearestParams.Merge(dst, src)
}
func (m *NearestParams) XXX_Size() int {
	return xxx_messageInfo_NearestParams.Size(m)
}
func (m *NearestParams) XXX_DiscardUnknown() {
	xxx_messageInfo_NearestParams.DiscardUnknown(m)
}

var xxx_messageInfo_NearestParams proto.InternalMessageInfo

func (m *NearestParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *NearestParams) GetTime() int64 {
	if m != nil {
		return m.Time
	}
	return 0
}

func (m *NearestParams) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *NearestParams) GetBackward() bool {
	if m != nil {
		return m.Backward
	}
	return false
}

type NearestResponse struct {
	Stat                 *Status   `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64    `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64    `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Value                *RawPoint `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *NearestResponse) Reset()         { *m = NearestResponse{} }
func (m *NearestResponse) String() string { return proto.CompactTextString(m) }
func (*NearestResponse) ProtoMessage()    {}
func (*NearestResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{23}
}
func (m *NearestResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_NearestResponse.Unmarshal(m, b)
}
func (m *NearestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_NearestResponse.Marshal(b, m, deterministic)
}
func (dst *NearestResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_NearestResponse.Merge(dst, src)
}
func (m *NearestResponse) XXX_Size() int {
	return xxx_messageInfo_NearestResponse.Size(m)
}
func (m *NearestResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_NearestResponse.DiscardUnknown(m)
}

var xxx_messageInfo_NearestResponse proto.InternalMessageInfo

func (m *NearestResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *NearestResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *NearestResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

func (m *NearestResponse) GetValue() *RawPoint {
	if m != nil {
		return m.Value
	}
	return nil
}

type ChangesParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	FromMajor            uint64   `protobuf:"varint,2,opt,name=fromMajor,proto3" json:"fromMajor,omitempty"`
	ToMajor              uint64   `protobuf:"varint,3,opt,name=toMajor,proto3" json:"toMajor,omitempty"`
	Resolution           uint32   `protobuf:"varint,4,opt,name=resolution,proto3" json:"resolution,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ChangesParams) Reset()         { *m = ChangesParams{} }
func (m *ChangesParams) String() string { return proto.CompactTextString(m) }
func (*ChangesParams) ProtoMessage()    {}
func (*ChangesParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{24}
}
func (m *ChangesParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ChangesParams.Unmarshal(m, b)
}
func (m *ChangesParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ChangesParams.Marshal(b, m, deterministic)
}
func (dst *ChangesParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ChangesParams.Merge(dst, src)
}
func (m *ChangesParams) XXX_Size() int {
	return xxx_messageInfo_ChangesParams.Size(m)
}
func (m *ChangesParams) XXX_DiscardUnknown() {
	xxx_messageInfo_ChangesParams.DiscardUnknown(m)
}

var xxx_messageInfo_ChangesParams proto.InternalMessageInfo

func (m *ChangesParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *ChangesParams) GetFromMajor() uint64 {
	if m != nil {
		return m.FromMajor
	}
	return 0
}

func (m *ChangesParams) GetToMajor() uint64 {
	if m != nil {
		return m.ToMajor
	}
	return 0
}

func (m *ChangesParams) GetResolution() uint32 {
	if m != nil {
		return m.Resolution
	}
	return 0
}

type ChangesResponse struct {
	Stat                 *Status         `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64          `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64          `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	Ranges               []*ChangedRange `protobuf:"bytes,4,rep,name=ranges,proto3" json:"ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *ChangesResponse) Reset()         { *m = ChangesResponse{} }
func (m *ChangesResponse) String() string { return proto.CompactTextString(m) }
func (*ChangesResponse) ProtoMessage()    {}
func (*ChangesResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{25}
}
func (m *ChangesResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ChangesResponse.Unmarshal(m, b)
}
func (m *ChangesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ChangesResponse.Marshal(b, m, deterministic)
}
func (dst *ChangesResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ChangesResponse.Merge(dst, src)
}
func (m *ChangesResponse) XXX_Size() int {
	return xxx_messageInfo_ChangesResponse.Size(m)
}
func (m *ChangesResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ChangesResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ChangesResponse proto.InternalMessageInfo

func (m *ChangesResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *ChangesResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *ChangesResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

func (m *ChangesResponse) GetRanges() []*ChangedRange {
	if m != nil {
		return m.Ranges
	}
	return nil
}

type InsertParams struct {
	Uuid                 []byte      `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Sync                 bool        `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
	Values               []*RawPoint `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (m *InsertParams) Reset()         { *m = InsertParams{} }
func (m *InsertParams) String() string { return proto.CompactTextString(m) }
func (*InsertParams) ProtoMessage()    {}
func (*InsertParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{26}
}
func (m *InsertParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InsertParams.Unmarshal(m, b)
}
func (m *InsertParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InsertParams.Marshal(b, m, deterministic)
}
func (dst *InsertParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InsertParams.Merge(dst, src)
}
func (m *InsertParams) XXX_Size() int {
	return xxx_messageInfo_InsertParams.Size(m)
}
func (m *InsertParams) XXX_DiscardUnknown() {
	xxx_messageInfo_InsertParams.DiscardUnknown(m)
}

var xxx_messageInfo_InsertParams proto.InternalMessageInfo

func (m *InsertParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *InsertParams) GetSync() bool {
	if m != nil {
		return m.Sync
	}
	return false
}

func (m *InsertParams) GetValues() []*RawPoint {
	if m != nil {
		return m.Values
	}
	return nil
}

type InsertResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *InsertResponse) Reset()         { *m = InsertResponse{} }
func (m *InsertResponse) String() string { return proto.CompactTextString(m) }
func (*InsertResponse) ProtoMessage()    {}
func (*InsertResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{27}
}
func (m *InsertResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InsertResponse.Unmarshal(m, b)
}
func (m *InsertResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InsertResponse.Marshal(b, m, deterministic)
}
func (dst *InsertResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InsertResponse.Merge(dst, src)
}
func (m *InsertResponse) XXX_Size() int {
	return xxx_messageInfo_InsertResponse.Size(m)
}
func (m *InsertResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_InsertResponse.DiscardUnknown(m)
}

var xxx_messageInfo_InsertResponse proto.InternalMessageInfo

func (m *InsertResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *InsertResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *InsertResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

type DeleteParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Start                int64    `protobuf:"fixed64,2,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,3,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DeleteParams) Reset()         { *m = DeleteParams{} }
func (m *DeleteParams) String() string { return proto.CompactTextString(m) }
func (*DeleteParams) ProtoMessage()    {}
func (*DeleteParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{28}
}
func (m *DeleteParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeleteParams.Unmarshal(m, b)
}
func (m *DeleteParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeleteParams.Marshal(b, m, deterministic)
}
func (dst *DeleteParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeleteParams.Merge(dst, src)
}
func (m *DeleteParams) XXX_Size() int {
	return xxx_messageInfo_DeleteParams.Size(m)
}
func (m *DeleteParams) XXX_DiscardUnknown() {
	xxx_messageInfo_DeleteParams.DiscardUnknown(m)
}

var xxx_messageInfo_DeleteParams proto.InternalMessageInfo

func (m *DeleteParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *DeleteParams) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *DeleteParams) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

type DeleteResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *DeleteResponse) Reset()         { *m = DeleteResponse{} }
func (m *DeleteResponse) String() string { return proto.CompactTextString(m) }
func (*DeleteResponse) ProtoMessage()    {}
func (*DeleteResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{29}
}
func (m *DeleteResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeleteResponse.Unmarshal(m, b)
}
func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeleteResponse.Marshal(b, m, deterministic)
}
func (dst *DeleteResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeleteResponse.Merge(dst, src)
}
func (m *DeleteResponse) XXX_Size() int {
	return xxx_messageInfo_DeleteResponse.Size(m)
}
func (m *DeleteResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DeleteResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DeleteResponse proto.InternalMessageInfo

func (m *DeleteResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *DeleteResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *DeleteResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

type InfoParams struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *InfoParams) Reset()         { *m = InfoParams{} }
func (m *InfoParams) String() string { return proto.CompactTextString(m) }
func (*InfoParams) ProtoMessage()    {}
func (*InfoParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{30}
}
func (m *InfoParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InfoParams.Unmarshal(m, b)
}
func (m *InfoParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InfoParams.Marshal(b, m, deterministic)
}
func (dst *InfoParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InfoParams.Merge(dst, src)
}
func (m *InfoParams) XXX_Size() int {
	return xxx_messageInfo_InfoParams.Size(m)
}
func (m *InfoParams) XXX_DiscardUnknown() {
	xxx_messageInfo_InfoParams.DiscardUnknown(m)
}

var xxx_messageInfo_InfoParams proto.InternalMessageInfo

type InfoResponse struct {
	Stat                 *Status    `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Mash                 *Mash      `protobuf:"bytes,2,opt,name=mash,proto3" json:"mash,omitempty"`
	MajorVersion         uint32     `protobuf:"varint,3,opt,name=majorVersion,proto3" json:"majorVersion,omitempty"`
	MinorVersion         uint32     `protobuf:"varint,4,opt,name=minorVersion,proto3" json:"minorVersion,omitempty"`
	Build                string     `protobuf:"bytes,5,opt,name=build,proto3" json:"build,omitempty"`
	Proxy                *ProxyInfo `protobuf:"bytes,6,opt,name=proxy,proto3" json:"proxy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (m *InfoResponse) Reset()         { *m = InfoResponse{} }
func (m *InfoResponse) String() string { return proto.CompactTextString(m) }
func (*InfoResponse) ProtoMessage()    {}
func (*InfoResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{31}
}
func (m *InfoResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InfoResponse.Unmarshal(m, b)
}
func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InfoResponse.Marshal(b, m, deterministic)
}
func (dst *InfoResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InfoResponse.Merge(dst, src)
}
func (m *InfoResponse) XXX_Size() int {
	return xxx_messageInfo_InfoResponse.Size(m)
}
func (m *InfoResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_InfoResponse.DiscardUnknown(m)
}

var xxx_messageInfo_InfoResponse proto.InternalMessageInfo

func (m *InfoResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *InfoResponse) GetMash() *Mash {
	if m != nil {
		return m.Mash
	}
	return nil
}

func (m *InfoResponse) GetMajorVersion() uint32 {
	if m != nil {
		return m.MajorVersion
	}
	return 0
}

func (m *InfoResponse) GetMinorVersion() uint32 {
	if m != nil {
		return m.MinorVersion
	}
	return 0
}

func (m *InfoResponse) GetBuild() string {
	if m != nil {
		return m.Build
	}
	return ""
}

func (m *InfoResponse) GetProxy() *ProxyInfo {
	if m != nil {
		return m.Proxy
	}
	return nil
}

type ProxyInfo struct {
	ProxyEndpoints       []string `protobuf:"bytes,1,rep,name=proxyEndpoints,proto3" json:"proxyEndpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ProxyInfo) Reset()         { *m = ProxyInfo{} }
func (m *ProxyInfo) String() string { return proto.CompactTextString(m) }
func (*ProxyInfo) ProtoMessage()    {}
func (*ProxyInfo) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{32}
}
func (m *ProxyInfo) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ProxyInfo.Unmarshal(m, b)
}
func (m *ProxyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ProxyInfo.Marshal(b, m, deterministic)
}
func (dst *ProxyInfo) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ProxyInfo.Merge(dst, src)
}
func (m *ProxyInfo) XXX_Size() int {
	return xxx_messageInfo_ProxyInfo.Size(m)
}
func (m *ProxyInfo) XXX_DiscardUnknown() {
	xxx_messageInfo_ProxyInfo.DiscardUnknown(m)
}

var xxx_messageInfo_ProxyInfo proto.InternalMessageInfo

func (m *ProxyInfo) GetProxyEndpoints() []string {
	if m != nil {
		return m.ProxyEndpoints
	}
	return nil
}

type FaultInjectParams struct {
	Type                 uint64   `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Params               []byte   `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *FaultInjectParams) Reset()         { *m = FaultInjectParams{} }
func (m *FaultInjectParams) String() string { return proto.CompactTextString(m) }
func (*FaultInjectParams) ProtoMessage()    {}
func (*FaultInjectParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{33}
}
func (m *FaultInjectParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_FaultInjectParams.Unmarshal(m, b)
}
func (m *FaultInjectParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_FaultInjectParams.Marshal(b, m, deterministic)
}
func (dst *FaultInjectParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_FaultInjectParams.Merge(dst, src)
}
func (m *FaultInjectParams) XXX_Size() int {
	return xxx_messageInfo_FaultInjectParams.Size(m)
}
func (m *FaultInjectParams) XXX_DiscardUnknown() {
	xxx_messageInfo_FaultInjectParams.DiscardUnknown(m)
}

var xxx_messageInfo_FaultInjectParams proto.InternalMessageInfo

func (m *FaultInjectParams) GetType() uint64 {
	if m != nil {
		return m.Type
	}
	return 0
}

func (m *FaultInjectParams) GetParams() []byte {
	if m != nil {
		return m.Params
	}
	return nil
}

type FaultInjectResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	Rv                   []byte   `protobuf:"bytes,2,opt,name=rv,proto3" json:"rv,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *FaultInjectResponse) Reset()         { *m = FaultInjectResponse{} }
func (m *FaultInjectResponse) String() string { return proto.CompactTextString(m) }
func (*FaultInjectResponse) ProtoMessage()    {}
func (*FaultInjectResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{34}
}
func (m *FaultInjectResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_FaultInjectResponse.Unmarshal(m, b)
}
func (m *FaultInjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_FaultInjectResponse.Marshal(b, m, deterministic)
}
func (dst *FaultInjectResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_FaultInjectResponse.Merge(dst, src)
}
func (m *FaultInjectResponse) XXX_Size() int {
	return xxx_messageInfo_FaultInjectResponse.Size(m)
}
func (m *FaultInjectResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_FaultInjectResponse.DiscardUnknown(m)
}

var xxx_messageInfo_FaultInjectResponse proto.InternalMessageInfo

func (m *FaultInjectResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *FaultInjectResponse) GetRv() []byte {
	if m != nil {
		return m.Rv
	}
	return nil
}

type FlushParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *FlushParams) Reset()         { *m = FlushParams{} }
func (m *FlushParams) String() string { return proto.CompactTextString(m) }
func (*FlushParams) ProtoMessage()    {}
func (*FlushParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{35}
}
func (m *FlushParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_FlushParams.Unmarshal(m, b)
}
func (m *FlushParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_FlushParams.Marshal(b, m, deterministic)
}
func (dst *FlushParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_FlushParams.Merge(dst, src)
}
func (m *FlushParams) XXX_Size() int {
	return xxx_messageInfo_FlushParams.Size(m)
}
func (m *FlushParams) XXX_DiscardUnknown() {
	xxx_messageInfo_FlushParams.DiscardUnknown(m)
}

var xxx_messageInfo_FlushParams proto.InternalMessageInfo

func (m *FlushParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

type FlushResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	VersionMajor         uint64   `protobuf:"varint,2,opt,name=versionMajor,proto3" json:"versionMajor,omitempty"`
	VersionMinor         uint64   `protobuf:"varint,3,opt,name=versionMinor,proto3" json:"versionMinor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *FlushResponse) Reset()         { *m = FlushResponse{} }
func (m *FlushResponse) String() string { return proto.CompactTextString(m) }
func (*FlushResponse) ProtoMessage()    {}
func (*FlushResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{36}
}
func (m *FlushResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_FlushResponse.Unmarshal(m, b)
}
func (m *FlushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_FlushResponse.Marshal(b, m, deterministic)
}
func (dst *FlushResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_FlushResponse.Merge(dst, src)
}
func (m *FlushResponse) XXX_Size() int {
	return xxx_messageInfo_FlushResponse.Size(m)
}
func (m *FlushResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_FlushResponse.DiscardUnknown(m)
}

var xxx_messageInfo_FlushResponse proto.InternalMessageInfo

func (m *FlushResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *FlushResponse) GetVersionMajor() uint64 {
	if m != nil {
		return m.VersionMajor
	}
	return 0
}

func (m *FlushResponse) GetVersionMinor() uint64 {
	if m != nil {
		return m.VersionMinor
	}
	return 0
}

type ObliterateParams struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ObliterateParams) Reset()         { *m = ObliterateParams{} }
func (m *ObliterateParams) String() string { return proto.CompactTextString(m) }
func (*ObliterateParams) ProtoMessage()    {}
func (*ObliterateParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{37}
}
func (m *ObliterateParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ObliterateParams.Unmarshal(m, b)
}
func (m *ObliterateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ObliterateParams.Marshal(b, m, deterministic)
}
func (dst *ObliterateParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ObliterateParams.Merge(dst, src)
}
func (m *ObliterateParams) XXX_Size() int {
	return xxx_messageInfo_ObliterateParams.Size(m)
}
func (m *ObliterateParams) XXX_DiscardUnknown() {
	xxx_messageInfo_ObliterateParams.DiscardUnknown(m)
}

var xxx_messageInfo_ObliterateParams proto.InternalMessageInfo

func (m *ObliterateParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

type ObliterateResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ObliterateResponse) Reset()         { *m = ObliterateResponse{} }
func (m *ObliterateResponse) String() string { return proto.CompactTextString(m) }
func (*ObliterateResponse) ProtoMessage()    {}
func (*ObliterateResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{38}
}
func (m *ObliterateResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ObliterateResponse.Unmarshal(m, b)
}
func (m *ObliterateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ObliterateResponse.Marshal(b, m, deterministic)
}
func (dst *ObliterateResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ObliterateResponse.Merge(dst, src)
}
func (m *ObliterateResponse) XXX_Size() int {
	return xxx_messageInfo_ObliterateResponse.Size(m)
}
func (m *ObliterateResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ObliterateResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ObliterateResponse proto.InternalMessageInfo

func (m *ObliterateResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

type RawPoint struct {
	Time                 int64    `protobuf:"fixed64,1,opt,name=time,proto3" json:"time,omitempty"`
	Value                float64  `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *RawPoint) Reset()         { *m = RawPoint{} }
func (m *RawPoint) String() string { return proto.CompactTextString(m) }
func (*RawPoint) ProtoMessage()    {}
func (*RawPoint) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{39}
}
func (m *RawPoint) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RawPoint.Unmarshal(m, b)
}
func (m *RawPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RawPoint.Marshal(b, m, deterministic)
}
func (dst *RawPoint) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RawPoint.Merge(dst, src)
}
func (m *RawPoint) XXX_Size() int {
	return xxx_messageInfo_RawPoint.Size(m)
}
func (m *RawPoint) XXX_DiscardUnknown() {
	xxx_messageInfo_RawPoint.DiscardUnknown(m)
}

var xxx_messageInfo_RawPoint proto.InternalMessageInfo

func (m *RawPoint) GetTime() int64 {
	if m != nil {
		return m.Time
	}
	return 0
}

func (m *RawPoint) GetValue() float64 {
	if m != nil {
		return m.Value
	}
	return 0
}

type StatPoint struct {
	Time                 int64    `protobuf:"fixed64,1,opt,name=time,proto3" json:"time,omitempty"`
	Min                  float64  `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	Mean                 float64  `protobuf:"fixed64,3,opt,name=mean,proto3" json:"mean,omitempty"`
	Max                  float64  `protobuf:"fixed64,4,opt,name=max,proto3" json:"max,omitempty"`
	Count                uint64   `protobuf:"fixed64,5,opt,name=count,proto3" json:"count,omitempty"`
	Stddev               float64  `protobuf:"fixed64,6,opt,name=stddev,proto3" json:"stddev,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *StatPoint) Reset()         { *m = StatPoint{} }
func (m *StatPoint) String() string { return proto.CompactTextString(m) }
func (*StatPoint) ProtoMessage()    {}
func (*StatPoint) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{40}
}
func (m *StatPoint) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StatPoint.Unmarshal(m, b)
}
func (m *StatPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StatPoint.Marshal(b, m, deterministic)
}
func (dst *StatPoint) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StatPoint.Merge(dst, src)
}
func (m *StatPoint) XXX_Size() int {
	return xxx_messageInfo_StatPoint.Size(m)
}
func (m *StatPoint) XXX_DiscardUnknown() {
	xxx_messageInfo_StatPoint.DiscardUnknown(m)
}

var xxx_messageInfo_StatPoint proto.InternalMessageInfo

func (m *StatPoint) GetTime() int64 {
	if m != nil {
		return m.Time
	}
	return 0
}

func (m *StatPoint) GetMin() float64 {
	if m != nil {
		return m.Min
	}
	return 0
}

func (m *StatPoint) GetMean() float64 {
	if m != nil {
		return m.Mean
	}
	return 0
}

func (m *StatPoint) GetMax() float64 {
	if m != nil {
		return m.Max
	}
	return 0
}

func (m *StatPoint) GetCount() uint64 {
	if m != nil {
		return m.Count
	}
	return 0
}

func (m *StatPoint) GetStddev() float64 {
	if m != nil {
		return m.Stddev
	}
	return 0
}

type ChangedRange struct {
	Start                int64    `protobuf:"fixed64,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"fixed64,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ChangedRange) Reset()         { *m = ChangedRange{} }
func (m *ChangedRange) String() string { return proto.CompactTextString(m) }
func (*ChangedRange) ProtoMessage()    {}
func (*ChangedRange) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{41}
}
func (m *ChangedRange) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ChangedRange.Unmarshal(m, b)
}
func (m *ChangedRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ChangedRange.Marshal(b, m, deterministic)
}
func (dst *ChangedRange) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ChangedRange.Merge(dst, src)
}
func (m *ChangedRange) XXX_Size() int {
	return xxx_messageInfo_ChangedRange.Size(m)
}
func (m *ChangedRange) XXX_DiscardUnknown() {
	xxx_messageInfo_ChangedRange.DiscardUnknown(m)
}

var xxx_messageInfo_ChangedRange proto.InternalMessageInfo

func (m *ChangedRange) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *ChangedRange) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

type Status struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Mash                 *Mash    `protobuf:"bytes,3,opt,name=mash,proto3" json:"mash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *Status) Reset()         { *m = Status{} }
func (m *Status) String() string { return proto.CompactTextString(m) }
func (*Status) ProtoMessage()    {}
func (*Status) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{42}
}
func (m *Status) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Status.Unmarshal(m, b)
}
func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Status.Marshal(b, m, deterministic)
}
func (dst *Status) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Status.Merge(dst, src)
}
func (m *Status) XXX_Size() int {
	return xxx_messageInfo_Status.Size(m)
}
func (m *Status) XXX_DiscardUnknown() {
	xxx_messageInfo_Status.DiscardUnknown(m)
}

var xxx_messageInfo_Status proto.InternalMessageInfo

func (m *Status) GetCode() uint32 {
	if m != nil {
		return m.Code
	}
	return 0
}

func (m *Status) GetMsg() string {
	if m != nil {
		return m.Msg
	}
	return ""
}

func (m *Status) GetMash() *Mash {
	if m != nil {
		return m.Mash
	}
	return nil
}

type Mash struct {
	Revision             int64     `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	Leader               string    `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	LeaderRevision       int64     `protobuf:"varint,3,opt,name=leaderRevision,proto3" json:"leaderRevision,omitempty"`
	TotalWeight          int64     `protobuf:"varint,4,opt,name=totalWeight,proto3" json:"totalWeight,omitempty"`
	Healthy              bool      `protobuf:"varint,5,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Unmapped             float64   `protobuf:"fixed64,6,opt,name=unmapped,proto3" json:"unmapped,omitempty"`
	Members              []*Member `protobuf:"bytes,7,rep,name=members,proto3" json:"members,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *Mash) Reset()         { *m = Mash{} }
func (m *Mash) String() string { return proto.CompactTextString(m) }
func (*Mash) ProtoMessage()    {}
func (*Mash) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{43}
}
func (m *Mash) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Mash.Unmarshal(m, b)
}
func (m *Mash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Mash.Marshal(b, m, deterministic)
}
func (dst *Mash) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Mash.Merge(dst, src)
}
func (m *Mash) XXX_Size() int {
	return xxx_messageInfo_Mash.Size(m)
}
func (m *Mash) XXX_DiscardUnknown() {
	xxx_messageInfo_Mash.DiscardUnknown(m)
}

var xxx_messageInfo_Mash proto.InternalMessageInfo

func (m *Mash) GetRevision() int64 {
	if m != nil {
		return m.Revision
	}
	return 0
}

func (m *Mash) GetLeader() string {
	if m != nil {
		return m.Leader
	}
	return ""
}

func (m *Mash) GetLeaderRevision() int64 {
	if m != nil {
		return m.LeaderRevision
	}
	return 0
}

func (m *Mash) GetTotalWeight() int64 {
	if m != nil {
		return m.TotalWeight
	}
	return 0
}

func (m *Mash) GetHealthy() bool {
	if m != nil {
		return m.Healthy
	}
	return false
}

func (m *Mash) GetUnmapped() float64 {
	if m != nil {
		return m.Unmapped
	}
	return 0
}

func (m *Mash) GetMembers() []*Member {
	if m != nil {
		return m.Members
	}
	return nil
}

type Member struct {
	Hash                 uint32   `protobuf:"varint,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Nodename             string   `protobuf:"bytes,2,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Up                   bool     `protobuf:"varint,3,opt,name=up,proto3" json:"up,omitempty"`
	In                   bool     `protobuf:"varint,4,opt,name=in,proto3" json:"in,omitempty"`
	Enabled              bool     `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Start                int64    `protobuf:"varint,6,opt,name=start,proto3" json:"start,omitempty"`
	End                  int64    `protobuf:"varint,7,opt,name=end,proto3" json:"end,omitempty"`
	Weight               int64    `protobuf:"varint,8,opt,name=weight,proto3" json:"weight,omitempty"`
	ReadPreference       float64  `protobuf:"fixed64,9,opt,name=readPreference,proto3" json:"readPreference,omitempty"`
	HttpEndpoints        string   `protobuf:"bytes,10,opt,name=httpEndpoints,proto3" json:"httpEndpoints,omitempty"`
	GrpcEndpoints        string   `protobuf:"bytes,11,opt,name=grpcEndpoints,proto3" json:"grpcEndpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *Member) Reset()         { *m = Member{} }
func (m *Member) String() string { return proto.CompactTextString(m) }
func (*Member) ProtoMessage()    {}
func (*Member) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{44}
}
func (m *Member) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Member.Unmarshal(m, b)
}
func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Member.Marshal(b, m, deterministic)
}
func (dst *Member) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Member.Merge(dst, src)
}
func (m *Member) XXX_Size() int {
	return xxx_messageInfo_Member.Size(m)
}
func (m *Member) XXX_DiscardUnknown() {
	xxx_messageInfo_Member.DiscardUnknown(m)
}

var xxx_messageInfo_Member proto.InternalMessageInfo

func (m *Member) GetHash() uint32 {
	if m != nil {
		return m.Hash
	}
	return 0
}

func (m *Member) GetNodename() string {
	if m != nil {
		return m.Nodename
	}
	return ""
}

func (m *Member) GetUp() bool {
	if m != nil {
		return m.Up
	}
	return false
}

func (m *Member) GetIn() bool {
	if m != nil {
		return m.In
	}
	return false
}

func (m *Member) GetEnabled() bool {
	if m != nil {
		return m.Enabled
	}
	return false
}

func (m *Member) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *Member) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

func (m *Member) GetWeight() int64 {
	if m != nil {
		return m.Weight
	}
	return 0
}

func (m *Member) GetReadPreference() float64 {
	if m != nil {
		return m.ReadPreference
	}
	return 0
}

func (m *Member) GetHttpEndpoints() string {
	if m != nil {
		return m.HttpEndpoints
	}
	return ""
}

func (m *Member) GetGrpcEndpoints() string {
	if m != nil {
		return m.GrpcEndpoints
	}
	return ""
}

type KeyOptValue struct {
	Key                  string    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val                  *OptValue `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *KeyOptValue) Reset()         { *m = KeyOptValue{} }
func (m *KeyOptValue) String() string { return proto.CompactTextString(m) }
func (*KeyOptValue) ProtoMessage()    {}
func (*KeyOptValue) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{45}
}
func (m *KeyOptValue) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_KeyOptValue.Unmarshal(m, b)
}
func (m *KeyOptValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_KeyOptValue.Marshal(b, m, deterministic)
}
func (dst *KeyOptValue) XXX_Merge(src proto.Message) {
	xxx_messageInfo_KeyOptValue.Merge(dst, src)
}
func (m *KeyOptValue) XXX_Size() int {
	return xxx_messageInfo_KeyOptValue.Size(m)
}
func (m *KeyOptValue) XXX_DiscardUnknown() {
	xxx_messageInfo_KeyOptValue.DiscardUnknown(m)
}

var xxx_messageInfo_KeyOptValue proto.InternalMessageInfo

func (m *KeyOptValue) GetKey() string {
	if m != nil {
		return m.Key
	}
	return ""
}

func (m *KeyOptValue) GetVal() *OptValue {
	if m != nil {
		return m.Val
	}
	return nil
}

type OptValue struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *OptValue) Reset()         { *m = OptValue{} }
func (m *OptValue) String() string { return proto.CompactTextString(m) }
func (*OptValue) ProtoMessage()    {}
func (*OptValue) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{46}
}
func (m *OptValue) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_OptValue.Unmarshal(m, b)
}
func (m *OptValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_OptValue.Marshal(b, m, deterministic)
}
func (dst *OptValue) XXX_Merge(src proto.Message) {
	xxx_messageInfo_OptValue.Merge(dst, src)
}
func (m *OptValue) XXX_Size() int {
	return xxx_messageInfo_OptValue.Size(m)
}
func (m *OptValue) XXX_DiscardUnknown() {
	xxx_messageInfo_OptValue.DiscardUnknown(m)
}

var xxx_messageInfo_OptValue proto.InternalMessageInfo

func (m *OptValue) GetValue() string {
	if m != nil {
		return m.Value
	}
	return ""
}

type KeyValue struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *KeyValue) Reset()         { *m = KeyValue{} }
func (m *KeyValue) String() string { return proto.CompactTextString(m) }
func (*KeyValue) ProtoMessage()    {}
func (*KeyValue) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{47}
}
func (m *KeyValue) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_KeyValue.Unmarshal(m, b)
}
func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_KeyValue.Marshal(b, m, deterministic)
}
func (dst *KeyValue) XXX_Merge(src proto.Message) {
	xxx_messageInfo_KeyValue.Merge(dst, src)
}
func (m *KeyValue) XXX_Size() int {
	return xxx_messageInfo_KeyValue.Size(m)
}
func (m *KeyValue) XXX_DiscardUnknown() {
	xxx_messageInfo_KeyValue.DiscardUnknown(m)
}

var xxx_messageInfo_KeyValue proto.InternalMessageInfo

func (m *KeyValue) GetKey() string {
	if m != nil {
		return m.Key
	}
	return ""
}

func (m *KeyValue) GetValue() string {
	if m != nil {
		return m.Value
	}
	return ""
}

type StreamCSVConfig struct {
	Version              uint64   `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Label                string   `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Uuid                 []byte   `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *StreamCSVConfig) Reset()         { *m = StreamCSVConfig{} }
func (m *StreamCSVConfig) String() string { return proto.CompactTextString(m) }
func (*StreamCSVConfig) ProtoMessage()    {}
func (*StreamCSVConfig) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{48}
}
func (m *StreamCSVConfig) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StreamCSVConfig.Unmarshal(m, b)
}
func (m *StreamCSVConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StreamCSVConfig.Marshal(b, m, deterministic)
}
func (dst *StreamCSVConfig) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StreamCSVConfig.Merge(dst, src)
}
func (m *StreamCSVConfig) XXX_Size() int {
	return xxx_messageInfo_StreamCSVConfig.Size(m)
}
func (m *StreamCSVConfig) XXX_DiscardUnknown() {
	xxx_messageInfo_StreamCSVConfig.DiscardUnknown(m)
}

var xxx_messageInfo_StreamCSVConfig proto.InternalMessageInfo

func (m *StreamCSVConfig) GetVersion() uint64 {
	if m != nil {
		return m.Version
	}
	return 0
}

func (m *StreamCSVConfig) GetLabel() string {
	if m != nil {
		return m.Label
	}
	return ""
}

func (m *StreamCSVConfig) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

type GenerateCSVParams struct {
	QueryType            GenerateCSVParams_QueryType `protobuf:"varint,1,opt,name=queryType,proto3,enum=v5api.GenerateCSVParams_QueryType" json:"queryType,omitempty"`
	StartTime            int64                       `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime              int64                       `protobuf:"varint,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
	WindowSize           uint64                      `protobuf:"varint,4,opt,name=windowSize,proto3" json:"windowSize,omitempty"`
	Depth                uint32                      `protobuf:"varint,5,opt,name=depth,proto3" json:"depth,omitempty"`
	IncludeVersions      bool                        `protobuf:"varint,6,opt,name=includeVersions,proto3" json:"includeVersions,omitempty"`
	Streams              []*StreamCSVConfig          `protobuf:"bytes,7,rep,name=streams,proto3" json:"streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (m *GenerateCSVParams) Reset()         { *m = GenerateCSVParams{} }
func (m *GenerateCSVParams) String() string { return proto.CompactTextString(m) }
func (*GenerateCSVParams) ProtoMessage()    {}
func (*GenerateCSVParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{49}
}
func (m *GenerateCSVParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GenerateCSVParams.Unmarshal(m, b)
}
func (m *GenerateCSVParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GenerateCSVParams.Marshal(b, m, deterministic)
}
func (dst *GenerateCSVParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GenerateCSVParams.Merge(dst, src)
}
func (m *GenerateCSVParams) XXX_Size() int {
	return xxx_messageInfo_GenerateCSVParams.Size(m)
}
func (m *GenerateCSVParams) XXX_DiscardUnknown() {
	xxx_messageInfo_GenerateCSVParams.DiscardUnknown(m)
}

var xxx_messageInfo_GenerateCSVParams proto.InternalMessageInfo

func (m *GenerateCSVParams) GetQueryType() GenerateCSVParams_QueryType {
	if m != nil {
		return m.QueryType
	}
	return GenerateCSVParams_ALIGNED_WINDOWS_QUERY
}

func (m *GenerateCSVParams) GetStartTime() int64 {
	if m != nil {
		return m.StartTime
	}
	return 0
}

func (m *GenerateCSVParams) GetEndTime() int64 {
	if m != nil {
		return m.EndTime
	}
	return 0
}

func (m *GenerateCSVParams) GetWindowSize() uint64 {
	if m != nil {
		return m.WindowSize
	}
	return 0
}

func (m *GenerateCSVParams) GetDepth() uint32 {
	if m != nil {
		return m.Depth
	}
	return 0
}

func (m *GenerateCSVParams) GetIncludeVersions() bool {
	if m != nil {
		return m.IncludeVersions
	}
	return false
}

func (m *GenerateCSVParams) GetStreams() []*StreamCSVConfig {
	if m != nil {
		return m.Streams
	}
	return nil
}

type GenerateCSVResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	IsHeader             bool     `protobuf:"varint,2,opt,name=isHeader,proto3" json:"isHeader,omitempty"`
	Row                  []string `protobuf:"bytes,3,rep,name=row,proto3" json:"row,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *GenerateCSVResponse) Reset()         { *m = GenerateCSVResponse{} }
func (m *GenerateCSVResponse) String() string { return proto.CompactTextString(m) }
func (*GenerateCSVResponse) ProtoMessage()    {}
func (*GenerateCSVResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{50}
}
func (m *GenerateCSVResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GenerateCSVResponse.Unmarshal(m, b)
}
func (m *GenerateCSVResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GenerateCSVResponse.Marshal(b, m, deterministic)
}
func (dst *GenerateCSVResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GenerateCSVResponse.Merge(dst, src)
}
func (m *GenerateCSVResponse) XXX_Size() int {
	return xxx_messageInfo_GenerateCSVResponse.Size(m)
}
func (m *GenerateCSVResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GenerateCSVResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GenerateCSVResponse proto.InternalMessageInfo

func (m *GenerateCSVResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *GenerateCSVResponse) GetIsHeader() bool {
	if m != nil {
		return m.IsHeader
	}
	return false
}

func (m *GenerateCSVResponse) GetRow() []string {
	if m != nil {
		return m.Row
	}
	return nil
}

type SQLQueryParams struct {
	Query                string   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Params               []string `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	Role                 *Role    `protobuf:"bytes,100,opt,name=role,proto3" json:"role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SQLQueryParams) Reset()         { *m = SQLQueryParams{} }
func (m *SQLQueryParams) String() string { return proto.CompactTextString(m) }
func (*SQLQueryParams) ProtoMessage()    {}
func (*SQLQueryParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{51}
}
func (m *SQLQueryParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SQLQueryParams.Unmarshal(m, b)
}
func (m *SQLQueryParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SQLQueryParams.Marshal(b, m, deterministic)
}
func (dst *SQLQueryParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SQLQueryParams.Merge(dst, src)
}
func (m *SQLQueryParams) XXX_Size() int {
	return xxx_messageInfo_SQLQueryParams.Size(m)
}
func (m *SQLQueryParams) XXX_DiscardUnknown() {
	xxx_messageInfo_SQLQueryParams.DiscardUnknown(m)
}

var xxx_messageInfo_SQLQueryParams proto.InternalMessageInfo

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

func (m *SQLQueryParams) GetParams() []string {
	if m != nil {
		return m.Params
	}
	return nil
}

func (m *SQLQueryParams) GetRole() *Role {
	if m != nil {
		return m.Role
	}
	return nil
}

type SQLQueryResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	SQLQueryRow          [][]byte `protobuf:"bytes,2,rep,name=SQLQueryRow,proto3" json:"SQLQueryRow,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SQLQueryResponse) Reset()         { *m = SQLQueryResponse{} }
func (m *SQLQueryResponse) String() string { return proto.CompactTextString(m) }
func (*SQLQueryResponse) ProtoMessage()    {}
func (*SQLQueryResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{52}
}
func (m *SQLQueryResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SQLQueryResponse.Unmarshal(m, b)
}
func (m *SQLQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SQLQueryResponse.Marshal(b, m, deterministic)
}
func (dst *SQLQueryResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SQLQueryResponse.Merge(dst, src)
}
func (m *SQLQueryResponse) XXX_Size() int {
	return xxx_messageInfo_SQLQueryResponse.Size(m)
}
func (m *SQLQueryResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_SQLQueryResponse.DiscardUnknown(m)
}

var xxx_messageInfo_SQLQueryResponse proto.InternalMessageInfo

func (m *SQLQueryResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *SQLQueryResponse) GetSQLQueryRow() [][]byte {
	if m != nil {
		return m.SQLQueryRow
	}
	return nil
}

type Role struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *Role) Reset()         { *m = Role{} }
func (m *Role) String() string { return proto.CompactTextString(m) }
func (*Role) ProtoMessage()    {}
func (*Role) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{53}
}
func (m *Role) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Role.Unmarshal(m, b)
}
func (m *Role) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Role.Marshal(b, m, deterministic)
}
func (dst *Role) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Role.Merge(dst, src)
}
func (m *Role) XXX_Size() int {
	return xxx_messageInfo_Role.Size(m)
}
func (m *Role) XXX_DiscardUnknown() {
	xxx_messageInfo_Role.DiscardUnknown(m)
}

var xxx_messageInfo_Role proto.InternalMessageInfo

func (m *Role) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

type SetCompactionConfigParams struct {
	// Which stream to configure
	Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Accessing versions LESS than this is not allowed
	CompactedVersion uint64 `protobuf:"varint,2,opt,name=CompactedVersion,proto3" json:"CompactedVersion,omitempty"`
	// For every timestamp >= Start and < End in this list,
	// we cannot traverse the tree < Resolution.
	// These ranges are the new ones you want to add, not the full list
	ReducedResolutionRanges []*ReducedResolutionRange `protobuf:"bytes,3,rep,name=reducedResolutionRanges,proto3" json:"reducedResolutionRanges,omitempty"`
	// Addresses less than this will be moved to the archive storage soon
	// You can't set this to less than it is, so zero means leave as is
	TargetArchiveHorizon uint64   `protobuf:"varint,4,opt,name=targetArchiveHorizon,proto3" json:"targetArchiveHorizon,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetCompactionConfigParams) Reset()         { *m = SetCompactionConfigParams{} }
func (m *SetCompactionConfigParams) String() string { return proto.CompactTextString(m) }
func (*SetCompactionConfigParams) ProtoMessage()    {}
func (*SetCompactionConfigParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{54}
}
func (m *SetCompactionConfigParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetCompactionConfigParams.Unmarshal(m, b)
}
func (m *SetCompactionConfigParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetCompactionConfigParams.Marshal(b, m, deterministic)
}
func (dst *SetCompactionConfigParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetCompactionConfigParams.Merge(dst, src)
}
func (m *SetCompactionConfigParams) XXX_Size() int {
	return xxx_messageInfo_SetCompactionConfigParams.Size(m)
}
func (m *SetCompactionConfigParams) XXX_DiscardUnknown() {
	xxx_messageInfo_SetCompactionConfigParams.DiscardUnknown(m)
}

var xxx_messageInfo_SetCompactionConfigParams proto.InternalMessageInfo

func (m *SetCompactionConfigParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

func (m *SetCompactionConfigParams) GetCompactedVersion() uint64 {
	if m != nil {
		return m.CompactedVersion
	}
	return 0
}

func (m *SetCompactionConfigParams) GetReducedResolutionRanges() []*ReducedResolutionRange {
	if m != nil {
		return m.ReducedResolutionRanges
	}
	return nil
}

func (m *SetCompactionConfigParams) GetTargetArchiveHorizon() uint64 {
	if m != nil {
		return m.TargetArchiveHorizon
	}
	return 0
}

type SetCompactionConfigResponse struct {
	Stat                 *Status  `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetCompactionConfigResponse) Reset()         { *m = SetCompactionConfigResponse{} }
func (m *SetCompactionConfigResponse) String() string { return proto.CompactTextString(m) }
func (*SetCompactionConfigResponse) ProtoMessage()    {}
func (*SetCompactionConfigResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{55}
}
func (m *SetCompactionConfigResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SetCompactionConfigResponse.Unmarshal(m, b)
}
func (m *SetCompactionConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SetCompactionConfigResponse.Marshal(b, m, deterministic)
}
func (dst *SetCompactionConfigResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SetCompactionConfigResponse.Merge(dst, src)
}
func (m *SetCompactionConfigResponse) XXX_Size() int {
	return xxx_messageInfo_SetCompactionConfigResponse.Size(m)
}
func (m *SetCompactionConfigResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_SetCompactionConfigResponse.DiscardUnknown(m)
}

var xxx_messageInfo_SetCompactionConfigResponse proto.InternalMessageInfo

func (m *SetCompactionConfigResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

type GetCompactionConfigParams struct {
	// Which stream to query
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *GetCompactionConfigParams) Reset()         { *m = GetCompactionConfigParams{} }
func (m *GetCompactionConfigParams) String() string { return proto.CompactTextString(m) }
func (*GetCompactionConfigParams) ProtoMessage()    {}
func (*GetCompactionConfigParams) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{56}
}
func (m *GetCompactionConfigParams) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetCompactionConfigParams.Unmarshal(m, b)
}
func (m *GetCompactionConfigParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetCompactionConfigParams.Marshal(b, m, deterministic)
}
func (dst *GetCompactionConfigParams) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetCompactionConfigParams.Merge(dst, src)
}
func (m *GetCompactionConfigParams) XXX_Size() int {
	return xxx_messageInfo_GetCompactionConfigParams.Size(m)
}
func (m *GetCompactionConfigParams) XXX_DiscardUnknown() {
	xxx_messageInfo_GetCompactionConfigParams.DiscardUnknown(m)
}

var xxx_messageInfo_GetCompactionConfigParams proto.InternalMessageInfo

func (m *GetCompactionConfigParams) GetUuid() []byte {
	if m != nil {
		return m.Uuid
	}
	return nil
}

type GetCompactionConfigResponse struct {
	Stat *Status `protobuf:"bytes,1,opt,name=stat,proto3" json:"stat,omitempty"`
	// The latest version of the stream, as returned by StreamInfo
	LatestMajorVersion uint64 `protobuf:"varint,2,opt,name=LatestMajorVersion,proto3" json:"LatestMajorVersion,omitempty"`
	// Accessing versions LESS than this is not allowed
	CompactedVersion uint64 `protobuf:"varint,3,opt,name=CompactedVersion,proto3" json:"CompactedVersion,omitempty"`
	// For every timestamp >= Start and < End in this list,
	// we cannot traverse the tree < Resolution.
	ReducedResolutionRanges []*ReducedResolutionRange `protobuf:"bytes,4,rep,name=reducedResolutionRanges,proto3" json:"reducedResolutionRanges,omitempty"`
	// Addresses less than this will be moved to the archive storage soon
	TargetArchiveHorizon uint64   `protobuf:"varint,5,opt,name=targetArchiveHorizon,proto3" json:"targetArchiveHorizon,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *GetCompactionConfigResponse) Reset()         { *m = GetCompactionConfigResponse{} }
func (m *GetCompactionConfigResponse) String() string { return proto.CompactTextString(m) }
func (*GetCompactionConfigResponse) ProtoMessage()    {}
func (*GetCompactionConfigResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{57}
}
func (m *GetCompactionConfigResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetCompactionConfigResponse.Unmarshal(m, b)
}
func (m *GetCompactionConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetCompactionConfigResponse.Marshal(b, m, deterministic)
}
func (dst *GetCompactionConfigResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetCompactionConfigResponse.Merge(dst, src)
}
func (m *GetCompactionConfigResponse) XXX_Size() int {
	return xxx_messageInfo_GetCompactionConfigResponse.Size(m)
}
func (m *GetCompactionConfigResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GetCompactionConfigResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GetCompactionConfigResponse proto.InternalMessageInfo

func (m *GetCompactionConfigResponse) GetStat() *Status {
	if m != nil {
		return m.Stat
	}
	return nil
}

func (m *GetCompactionConfigResponse) GetLatestMajorVersion() uint64 {
	if m != nil {
		return m.LatestMajorVersion
	}
	return 0
}

func (m *GetCompactionConfigResponse) GetCompactedVersion() uint64 {
	if m != nil {
		return m.CompactedVersion
	}
	return 0
}

func (m *GetCompactionConfigResponse) GetReducedResolutionRanges() []*ReducedResolutionRange {
	if m != nil {
		return m.ReducedResolutionRanges
	}
	return nil
}

func (m *GetCompactionConfigResponse) GetTargetArchiveHorizon() uint64 {
	if m != nil {
		return m.TargetArchiveHorizon
	}
	return 0
}

type ReducedResolutionRange struct {
	Start                int64    `protobuf:"varint,1,opt,name=Start,proto3" json:"Start,omitempty"`
	End                  int64    `protobuf:"varint,2,opt,name=End,proto3" json:"End,omitempty"`
	Resolution           uint32   `protobuf:"varint,3,opt,name=Resolution,proto3" json:"Resolution,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ReducedResolutionRange) Reset()         { *m = ReducedResolutionRange{} }
func (m *ReducedResolutionRange) String() string { return proto.CompactTextString(m) }
func (*ReducedResolutionRange) ProtoMessage()    {}
func (*ReducedResolutionRange) Descriptor() ([]byte, []int) {
	return fileDescriptor_btrdb_74c7a38683560440, []int{58}
}
func (m *ReducedResolutionRange) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ReducedResolutionRange.Unmarshal(m, b)
}
func (m *ReducedResolutionRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ReducedResolutionRange.Marshal(b, m, deterministic)
}
func (dst *ReducedResolutionRange) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ReducedResolutionRange.Merge(dst, src)
}
func (m *ReducedResolutionRange) XXX_Size() int {
	return xxx_messageInfo_ReducedResolutionRange.Size(m)
}
func (m *ReducedResolutionRange) XXX_DiscardUnknown() {
	xxx_messageInfo_ReducedResolutionRange.DiscardUnknown(m)
}

var xxx_messageInfo_ReducedResolutionRange proto.InternalMessageInfo

func (m *ReducedResolutionRange) GetStart() int64 {
	if m != nil {
		return m.Start
	}
	return 0
}

func (m *ReducedResolutionRange) GetEnd() int64 {
	if m != nil {
		return m.End
	}
	return 0
}

func (m *ReducedResolutionRange) GetResolution() uint32 {
	if m != nil {
		return m.Resolution
	}
	return 0
}

func init() {
	proto.RegisterType((*RawValuesParams)(nil), "v5api.RawValuesParams")
	proto.RegisterType((*RawValuesResponse)(nil), "v5api.RawValuesResponse")
	proto.RegisterType((*AlignedWindowsParams)(nil), "v5api.AlignedWindowsParams")
	proto.RegisterType((*AlignedWindowsResponse)(nil), "v5api.AlignedWindowsResponse")
	proto.RegisterType((*WindowsParams)(nil), "v5api.WindowsParams")
	proto.RegisterType((*WindowsResponse)(nil), "v5api.WindowsResponse")
	proto.RegisterType((*StreamInfoParams)(nil), "v5api.StreamInfoParams")
	proto.RegisterType((*StreamInfoResponse)(nil), "v5api.StreamInfoResponse")
	proto.RegisterType((*StreamDescriptor)(nil), "v5api.StreamDescriptor")
	proto.RegisterType((*SetStreamAnnotationsParams)(nil), "v5api.SetStreamAnnotationsParams")
	proto.RegisterType((*SetStreamAnnotationsResponse)(nil), "v5api.SetStreamAnnotationsResponse")
	proto.RegisterType((*SetStreamTagsParams)(nil), "v5api.SetStreamTagsParams")
	proto.RegisterType((*SetStreamTagsResponse)(nil), "v5api.SetStreamTagsResponse")
	proto.RegisterType((*CreateParams)(nil), "v5api.CreateParams")
	proto.RegisterType((*CreateResponse)(nil), "v5api.CreateResponse")
	proto.RegisterType((*MetadataUsageParams)(nil), "v5api.MetadataUsageParams")
	proto.RegisterType((*MetadataUsageResponse)(nil), "v5api.MetadataUsageResponse")
	proto.RegisterType((*KeyCount)(nil), "v5api.KeyCount")
	proto.RegisterType((*ListCollectionsParams)(nil), "v5api.ListCollectionsParams")
	proto.RegisterType((*ListCollectionsResponse)(nil), "v5api.ListCollectionsResponse")
	proto.RegisterType((*LookupStreamsParams)(nil), "v5api.LookupStreamsParams")
	proto.RegisterType((*LookupStreamsResponse)(nil), "v5api.LookupStreamsResponse")
	proto.RegisterType((*NearestParams)(nil), "v5api.NearestParams")
	proto.RegisterType((*NearestResponse)(nil), "v5api.NearestResponse")
	proto.RegisterType((*ChangesParams)(nil), "v5api.ChangesParams")
	proto.RegisterType((*ChangesResponse)(nil), "v5api.ChangesResponse")
	proto.RegisterType((*InsertParams)(nil), "v5api.InsertParams")
	proto.RegisterType((*InsertResponse)(nil), "v5api.InsertResponse")
	proto.RegisterType((*DeleteParams)(nil), "v5api.DeleteParams")
	proto.RegisterType((*DeleteResponse)(nil), "v5api.DeleteResponse")
	proto.RegisterType((*InfoParams)(nil), "v5api.InfoParams")
	proto.RegisterType((*InfoResponse)(nil), "v5api.InfoResponse")
	proto.RegisterType((*ProxyInfo)(nil), "v5api.ProxyInfo")
	proto.RegisterType((*FaultInjectParams)(nil), "v5api.FaultInjectParams")
	proto.RegisterType((*FaultInjectResponse)(nil), "v5api.FaultInjectResponse")
	proto.RegisterType((*FlushParams)(nil), "v5api.FlushParams")
	proto.RegisterType((*FlushResponse)(nil), "v5api.FlushResponse")
	proto.RegisterType((*ObliterateParams)(nil), "v5api.ObliterateParams")
	proto.RegisterType((*ObliterateResponse)(nil), "v5api.ObliterateResponse")
	proto.RegisterType((*RawPoint)(nil), "v5api.RawPoint")
	proto.RegisterType((*StatPoint)(nil), "v5api.StatPoint")
	proto.RegisterType((*ChangedRange)(nil), "v5api.ChangedRange")
	proto.RegisterType((*Status)(nil), "v5api.Status")
	proto.RegisterType((*Mash)(nil), "v5api.Mash")
	proto.RegisterType((*Member)(nil), "v5api.Member")
	proto.RegisterType((*KeyOptValue)(nil), "v5api.KeyOptValue")
	proto.RegisterType((*OptValue)(nil), "v5api.OptValue")
	proto.RegisterType((*KeyValue)(nil), "v5api.KeyValue")
	proto.RegisterType((*StreamCSVConfig)(nil), "v5api.StreamCSVConfig")
	proto.RegisterType((*GenerateCSVParams)(nil), "v5api.GenerateCSVParams")
	proto.RegisterType((*GenerateCSVResponse)(nil), "v5api.GenerateCSVResponse")
	proto.RegisterType((*SQLQueryParams)(nil), "v5api.SQLQueryParams")
	proto.RegisterType((*SQLQueryResponse)(nil), "v5api.SQLQueryResponse")
	proto.RegisterType((*Role)(nil), "v5api.Role")
	proto.RegisterType((*SetCompactionConfigParams)(nil), "v5api.SetCompactionConfigParams")
	proto.RegisterType((*SetCompactionConfigResponse)(nil), "v5api.SetCompactionConfigResponse")
	proto.RegisterType((*GetCompactionConfigParams)(nil), "v5api.GetCompactionConfigParams")
	proto.RegisterType((*GetCompactionConfigResponse)(nil), "v5api.GetCompactionConfigResponse")
	proto.RegisterType((*ReducedResolutionRange)(nil), "v5api.ReducedResolutionRange")
	proto.RegisterEnum("v5api.GenerateCSVParams_QueryType", GenerateCSVParams_QueryType_name, GenerateCSVParams_QueryType_value)
}

// 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

// BTrDBClient is the client API for BTrDB service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type BTrDBClient interface {
	RawValues(ctx context.Context, in *RawValuesParams, opts ...grpc.CallOption) (BTrDB_RawValuesClient, error)
	AlignedWindows(ctx context.Context, in *AlignedWindowsParams, opts ...grpc.CallOption) (BTrDB_AlignedWindowsClient, error)
	Windows(ctx context.Context, in *WindowsParams, opts ...grpc.CallOption) (BTrDB_WindowsClient, error)
	StreamInfo(ctx context.Context, in *StreamInfoParams, opts ...grpc.CallOption) (*StreamInfoResponse, error)
	SetStreamAnnotations(ctx context.Context, in *SetStreamAnnotationsParams, opts ...grpc.CallOption) (*SetStreamAnnotationsResponse, error)
	SetStreamTags(ctx context.Context, in *SetStreamTagsParams, opts ...grpc.CallOption) (*SetStreamTagsResponse, error)
	Create(ctx context.Context, in *CreateParams, opts ...grpc.CallOption) (*CreateResponse, error)
	ListCollections(ctx context.Context, in *ListCollectionsParams, opts ...grpc.CallOption) (BTrDB_ListCollectionsClient, error)
	LookupStreams(ctx context.Context, in *LookupStreamsParams, opts ...grpc.CallOption) (BTrDB_LookupStreamsClient, error)
	Nearest(ctx context.Context, in *NearestParams, opts ...grpc.CallOption) (*NearestResponse, error)
	Changes(ctx context.Context, in *ChangesParams, opts ...grpc.CallOption) (BTrDB_ChangesClient, error)
	Insert(ctx context.Context, in *InsertParams, opts ...grpc.CallOption) (*InsertResponse, error)
	Delete(ctx context.Context, in *DeleteParams, opts ...grpc.CallOption) (*DeleteResponse, error)
	Info(ctx context.Context, in *InfoParams, opts ...grpc.CallOption) (*InfoResponse, error)
	FaultInject(ctx context.Context, in *FaultInjectParams, opts ...grpc.CallOption) (*FaultInjectResponse, error)
	Flush(ctx context.Context, in *FlushParams, opts ...grpc.CallOption) (*FlushResponse, error)
	Obliterate(ctx context.Context, in *ObliterateParams, opts ...grpc.CallOption) (*ObliterateResponse, error)
	GetMetadataUsage(ctx context.Context, in *MetadataUsageParams, opts ...grpc.CallOption) (*MetadataUsageResponse, error)
	GenerateCSV(ctx context.Context, in *GenerateCSVParams, opts ...grpc.CallOption) (BTrDB_GenerateCSVClient, error)
	SQLQuery(ctx context.Context, in *SQLQueryParams, opts ...grpc.CallOption) (BTrDB_SQLQueryClient, error)
	SetCompactionConfig(ctx context.Context, in *SetCompactionConfigParams, opts ...grpc.CallOption) (*SetCompactionConfigResponse, error)
	GetCompactionConfig(ctx context.Context, in *GetCompactionConfigParams, opts ...grpc.CallOption) (*GetCompactionConfigResponse, error)
}

type bTrDBClient struct {
	cc *grpc.ClientConn
}

func NewBTrDBClient(cc *grpc.ClientConn) BTrDBClient {
	return &bTrDBClient{cc}
}

func (c *bTrDBClient) RawValues(ctx context.Context, in *RawValuesParams, opts ...grpc.CallOption) (BTrDB_RawValuesClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[0], "/v5api.BTrDB/RawValues", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBRawValuesClient{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 BTrDB_RawValuesClient interface {
	Recv() (*RawValuesResponse, error)
	grpc.ClientStream
}

type bTrDBRawValuesClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) AlignedWindows(ctx context.Context, in *AlignedWindowsParams, opts ...grpc.CallOption) (BTrDB_AlignedWindowsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[1], "/v5api.BTrDB/AlignedWindows", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBAlignedWindowsClient{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 BTrDB_AlignedWindowsClient interface {
	Recv() (*AlignedWindowsResponse, error)
	grpc.ClientStream
}

type bTrDBAlignedWindowsClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) Windows(ctx context.Context, in *WindowsParams, opts ...grpc.CallOption) (BTrDB_WindowsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[2], "/v5api.BTrDB/Windows", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBWindowsClient{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 BTrDB_WindowsClient interface {
	Recv() (*WindowsResponse, error)
	grpc.ClientStream
}

type bTrDBWindowsClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) StreamInfo(ctx context.Context, in *StreamInfoParams, opts ...grpc.CallOption) (*StreamInfoResponse, error) {
	out := new(StreamInfoResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/StreamInfo", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) SetStreamAnnotations(ctx context.Context, in *SetStreamAnnotationsParams, opts ...grpc.CallOption) (*SetStreamAnnotationsResponse, error) {
	out := new(SetStreamAnnotationsResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/SetStreamAnnotations", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) SetStreamTags(ctx context.Context, in *SetStreamTagsParams, opts ...grpc.CallOption) (*SetStreamTagsResponse, error) {
	out := new(SetStreamTagsResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/SetStreamTags", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) Create(ctx context.Context, in *CreateParams, opts ...grpc.CallOption) (*CreateResponse, error) {
	out := new(CreateResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Create", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) ListCollections(ctx context.Context, in *ListCollectionsParams, opts ...grpc.CallOption) (BTrDB_ListCollectionsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[3], "/v5api.BTrDB/ListCollections", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBListCollectionsClient{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 BTrDB_ListCollectionsClient interface {
	Recv() (*ListCollectionsResponse, error)
	grpc.ClientStream
}

type bTrDBListCollectionsClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) LookupStreams(ctx context.Context, in *LookupStreamsParams, opts ...grpc.CallOption) (BTrDB_LookupStreamsClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[4], "/v5api.BTrDB/LookupStreams", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBLookupStreamsClient{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 BTrDB_LookupStreamsClient interface {
	Recv() (*LookupStreamsResponse, error)
	grpc.ClientStream
}

type bTrDBLookupStreamsClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) Nearest(ctx context.Context, in *NearestParams, opts ...grpc.CallOption) (*NearestResponse, error) {
	out := new(NearestResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Nearest", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) Changes(ctx context.Context, in *ChangesParams, opts ...grpc.CallOption) (BTrDB_ChangesClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[5], "/v5api.BTrDB/Changes", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBChangesClient{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 BTrDB_ChangesClient interface {
	Recv() (*ChangesResponse, error)
	grpc.ClientStream
}

type bTrDBChangesClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) Insert(ctx context.Context, in *InsertParams, opts ...grpc.CallOption) (*InsertResponse, error) {
	out := new(InsertResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Insert", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) Delete(ctx context.Context, in *DeleteParams, opts ...grpc.CallOption) (*DeleteResponse, error) {
	out := new(DeleteResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Delete", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) Info(ctx context.Context, in *InfoParams, opts ...grpc.CallOption) (*InfoResponse, error) {
	out := new(InfoResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Info", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) FaultInject(ctx context.Context, in *FaultInjectParams, opts ...grpc.CallOption) (*FaultInjectResponse, error) {
	out := new(FaultInjectResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/FaultInject", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) Flush(ctx context.Context, in *FlushParams, opts ...grpc.CallOption) (*FlushResponse, error) {
	out := new(FlushResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Flush", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) Obliterate(ctx context.Context, in *ObliterateParams, opts ...grpc.CallOption) (*ObliterateResponse, error) {
	out := new(ObliterateResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/Obliterate", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) GetMetadataUsage(ctx context.Context, in *MetadataUsageParams, opts ...grpc.CallOption) (*MetadataUsageResponse, error) {
	out := new(MetadataUsageResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/GetMetadataUsage", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) GenerateCSV(ctx context.Context, in *GenerateCSVParams, opts ...grpc.CallOption) (BTrDB_GenerateCSVClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[6], "/v5api.BTrDB/GenerateCSV", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBGenerateCSVClient{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 BTrDB_GenerateCSVClient interface {
	Recv() (*GenerateCSVResponse, error)
	grpc.ClientStream
}

type bTrDBGenerateCSVClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) SQLQuery(ctx context.Context, in *SQLQueryParams, opts ...grpc.CallOption) (BTrDB_SQLQueryClient, error) {
	stream, err := c.cc.NewStream(ctx, &_BTrDB_serviceDesc.Streams[7], "/v5api.BTrDB/SQLQuery", opts...)
	if err != nil {
		return nil, err
	}
	x := &bTrDBSQLQueryClient{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 BTrDB_SQLQueryClient interface {
	Recv() (*SQLQueryResponse, error)
	grpc.ClientStream
}

type bTrDBSQLQueryClient struct {
	grpc.ClientStream
}

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

func (c *bTrDBClient) SetCompactionConfig(ctx context.Context, in *SetCompactionConfigParams, opts ...grpc.CallOption) (*SetCompactionConfigResponse, error) {
	out := new(SetCompactionConfigResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/SetCompactionConfig", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *bTrDBClient) GetCompactionConfig(ctx context.Context, in *GetCompactionConfigParams, opts ...grpc.CallOption) (*GetCompactionConfigResponse, error) {
	out := new(GetCompactionConfigResponse)
	err := c.cc.Invoke(ctx, "/v5api.BTrDB/GetCompactionConfig", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// BTrDBServer is the server API for BTrDB service.
type BTrDBServer interface {
	RawValues(*RawValuesParams, BTrDB_RawValuesServer) error
	AlignedWindows(*AlignedWindowsParams, BTrDB_AlignedWindowsServer) error
	Windows(*WindowsParams, BTrDB_WindowsServer) error
	StreamInfo(context.Context, *StreamInfoParams) (*StreamInfoResponse, error)
	SetStreamAnnotations(context.Context, *SetStreamAnnotationsParams) (*SetStreamAnnotationsResponse, error)
	SetStreamTags(context.Context, *SetStreamTagsParams) (*SetStreamTagsResponse, error)
	Create(context.Context, *CreateParams) (*CreateResponse, error)
	ListCollections(*ListCollectionsParams, BTrDB_ListCollectionsServer) error
	LookupStreams(*LookupStreamsParams, BTrDB_LookupStreamsServer) error
	Nearest(context.Context, *NearestParams) (*NearestResponse, error)
	Changes(*ChangesParams, BTrDB_ChangesServer) error
	Insert(context.Context, *InsertParams) (*InsertResponse, error)
	Delete(context.Context, *DeleteParams) (*DeleteResponse, error)
	Info(context.Context, *InfoParams) (*InfoResponse, error)
	FaultInject(context.Context, *FaultInjectParams) (*FaultInjectResponse, error)
	Flush(context.Context, *FlushParams) (*FlushResponse, error)
	Obliterate(context.Context, *ObliterateParams) (*ObliterateResponse, error)
	GetMetadataUsage(context.Context, *MetadataUsageParams) (*MetadataUsageResponse, error)
	GenerateCSV(*GenerateCSVParams, BTrDB_GenerateCSVServer) error
	SQLQuery(*SQLQueryParams, BTrDB_SQLQueryServer) error
	SetCompactionConfig(context.Context, *SetCompactionConfigParams) (*SetCompactionConfigResponse, error)
	GetCompactionConfig(context.Context, *GetCompactionConfigParams) (*GetCompactionConfigResponse, error)
}

func RegisterBTrDBServer(s *grpc.Server, srv BTrDBServer) {
	s.RegisterService(&_BTrDB_serviceDesc, srv)
}

func _BTrDB_RawValues_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(RawValuesParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).RawValues(m, &bTrDBRawValuesServer{stream})
}

type BTrDB_RawValuesServer interface {
	Send(*RawValuesResponse) error
	grpc.ServerStream
}

type bTrDBRawValuesServer struct {
	grpc.ServerStream
}

func (x *bTrDBRawValuesServer) Send(m *RawValuesResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_AlignedWindows_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(AlignedWindowsParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).AlignedWindows(m, &bTrDBAlignedWindowsServer{stream})
}

type BTrDB_AlignedWindowsServer interface {
	Send(*AlignedWindowsResponse) error
	grpc.ServerStream
}

type bTrDBAlignedWindowsServer struct {
	grpc.ServerStream
}

func (x *bTrDBAlignedWindowsServer) Send(m *AlignedWindowsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_Windows_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(WindowsParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).Windows(m, &bTrDBWindowsServer{stream})
}

type BTrDB_WindowsServer interface {
	Send(*WindowsResponse) error
	grpc.ServerStream
}

type bTrDBWindowsServer struct {
	grpc.ServerStream
}

func (x *bTrDBWindowsServer) Send(m *WindowsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_StreamInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StreamInfoParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).StreamInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/StreamInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).StreamInfo(ctx, req.(*StreamInfoParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_SetStreamAnnotations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetStreamAnnotationsParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).SetStreamAnnotations(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/SetStreamAnnotations",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).SetStreamAnnotations(ctx, req.(*SetStreamAnnotationsParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_SetStreamTags_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetStreamTagsParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).SetStreamTags(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/SetStreamTags",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).SetStreamTags(ctx, req.(*SetStreamTagsParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Create(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Create",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Create(ctx, req.(*CreateParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_ListCollections_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ListCollectionsParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).ListCollections(m, &bTrDBListCollectionsServer{stream})
}

type BTrDB_ListCollectionsServer interface {
	Send(*ListCollectionsResponse) error
	grpc.ServerStream
}

type bTrDBListCollectionsServer struct {
	grpc.ServerStream
}

func (x *bTrDBListCollectionsServer) Send(m *ListCollectionsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_LookupStreams_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(LookupStreamsParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).LookupStreams(m, &bTrDBLookupStreamsServer{stream})
}

type BTrDB_LookupStreamsServer interface {
	Send(*LookupStreamsResponse) error
	grpc.ServerStream
}

type bTrDBLookupStreamsServer struct {
	grpc.ServerStream
}

func (x *bTrDBLookupStreamsServer) Send(m *LookupStreamsResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_Nearest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(NearestParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Nearest(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Nearest",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Nearest(ctx, req.(*NearestParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_Changes_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ChangesParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).Changes(m, &bTrDBChangesServer{stream})
}

type BTrDB_ChangesServer interface {
	Send(*ChangesResponse) error
	grpc.ServerStream
}

type bTrDBChangesServer struct {
	grpc.ServerStream
}

func (x *bTrDBChangesServer) Send(m *ChangesResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_Insert_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InsertParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Insert(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Insert",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Insert(ctx, req.(*InsertParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Delete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Delete",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Delete(ctx, req.(*DeleteParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_Info_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InfoParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Info(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Info",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Info(ctx, req.(*InfoParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_FaultInject_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FaultInjectParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).FaultInject(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/FaultInject",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).FaultInject(ctx, req.(*FaultInjectParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_Flush_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FlushParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Flush(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Flush",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Flush(ctx, req.(*FlushParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_Obliterate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ObliterateParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).Obliterate(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/Obliterate",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).Obliterate(ctx, req.(*ObliterateParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_GetMetadataUsage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MetadataUsageParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).GetMetadataUsage(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/GetMetadataUsage",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).GetMetadataUsage(ctx, req.(*MetadataUsageParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_GenerateCSV_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(GenerateCSVParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).GenerateCSV(m, &bTrDBGenerateCSVServer{stream})
}

type BTrDB_GenerateCSVServer interface {
	Send(*GenerateCSVResponse) error
	grpc.ServerStream
}

type bTrDBGenerateCSVServer struct {
	grpc.ServerStream
}

func (x *bTrDBGenerateCSVServer) Send(m *GenerateCSVResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_SQLQuery_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SQLQueryParams)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(BTrDBServer).SQLQuery(m, &bTrDBSQLQueryServer{stream})
}

type BTrDB_SQLQueryServer interface {
	Send(*SQLQueryResponse) error
	grpc.ServerStream
}

type bTrDBSQLQueryServer struct {
	grpc.ServerStream
}

func (x *bTrDBSQLQueryServer) Send(m *SQLQueryResponse) error {
	return x.ServerStream.SendMsg(m)
}

func _BTrDB_SetCompactionConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetCompactionConfigParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).SetCompactionConfig(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/SetCompactionConfig",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).SetCompactionConfig(ctx, req.(*SetCompactionConfigParams))
	}
	return interceptor(ctx, in, info, handler)
}

func _BTrDB_GetCompactionConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetCompactionConfigParams)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(BTrDBServer).GetCompactionConfig(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/v5api.BTrDB/GetCompactionConfig",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(BTrDBServer).GetCompactionConfig(ctx, req.(*GetCompactionConfigParams))
	}
	return interceptor(ctx, in, info, handler)
}

var _BTrDB_serviceDesc = grpc.ServiceDesc{
	ServiceName: "v5api.BTrDB",
	HandlerType: (*BTrDBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StreamInfo",
			Handler:    _BTrDB_StreamInfo_Handler,
		},
		{
			MethodName: "SetStreamAnnotations",
			Handler:    _BTrDB_SetStreamAnnotations_Handler,
		},
		{
			MethodName: "SetStreamTags",
			Handler:    _BTrDB_SetStreamTags_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _BTrDB_Create_Handler,
		},
		{
			MethodName: "Nearest",
			Handler:    _BTrDB_Nearest_Handler,
		},
		{
			MethodName: "Insert",
			Handler:    _BTrDB_Insert_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _BTrDB_Delete_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _BTrDB_Info_Handler,
		},
		{
			MethodName: "FaultInject",
			Handler:    _BTrDB_FaultInject_Handler,
		},
		{
			MethodName: "Flush",
			Handler:    _BTrDB_Flush_Handler,
		},
		{
			MethodName: "Obliterate",
			Handler:    _BTrDB_Obliterate_Handler,
		},
		{
			MethodName: "GetMetadataUsage",
			Handler:    _BTrDB_GetMetadataUsage_Handler,
		},
		{
			MethodName: "SetCompactionConfig",
			Handler:    _BTrDB_SetCompactionConfig_Handler,
		},
		{
			MethodName: "GetCompactionConfig",
			Handler:    _BTrDB_GetCompactionConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RawValues",
			Handler:       _BTrDB_RawValues_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AlignedWindows",
			Handler:       _BTrDB_AlignedWindows_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Windows",
			Handler:       _BTrDB_Windows_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListCollections",
			Handler:       _BTrDB_ListCollections_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "LookupStreams",
			Handler:       _BTrDB_LookupStreams_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Changes",
			Handler:       _BTrDB_Changes_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GenerateCSV",
			Handler:       _BTrDB_GenerateCSV_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SQLQuery",
			Handler:       _BTrDB_SQLQuery_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "v5api/btrdb.proto",
}

func init() { proto.RegisterFile("v5api/btrdb.proto", fileDescriptor_btrdb_74c7a38683560440) }

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