v1

type Chunk struct {

	// The partition key of this chunk
	PartitionKey string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// The table of this chunk
	TableName string `protobuf:"bytes,8,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// The id of this chunk
	Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Which storage system the chunk is located in
	Storage ChunkStorage `protobuf:"varint,3,opt,name=storage,proto3,enum=influxdata.iox.management.v1.ChunkStorage" json:"storage,omitempty"`
	// Is there any outstanding lifecycle action for this chunk?
	LifecycleAction ChunkLifecycleAction `` /* 163-byte string literal not displayed */
	// The number of bytes used to store this chunk in memory
	MemoryBytes uint64 `protobuf:"varint,4,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	// The number of bytes used to store this chunk in object storage
	ObjectStoreBytes uint64 `protobuf:"varint,11,opt,name=object_store_bytes,json=objectStoreBytes,proto3" json:"object_store_bytes,omitempty"`
	// The number of rows in this chunk
	RowCount uint64 `protobuf:"varint,9,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// The time at which the chunk data was accessed, by a query or a write
	TimeOfLastAccess *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=time_of_last_access,json=timeOfLastAccess,proto3" json:"time_of_last_access,omitempty"`
	// The earliest time at which data contained within this chunk was written
	// into IOx. Note due to the compaction, etc... this may not be the chunk
	// that data was originally written into
	TimeOfFirstWrite *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time_of_first_write,json=timeOfFirstWrite,proto3" json:"time_of_first_write,omitempty"`
	// The latest time at which data contained within this chunk was written
	// into IOx. Note due to the compaction, etc... this may not be the chunk
	// that data was originally written into
	TimeOfLastWrite *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=time_of_last_write,json=timeOfLastWrite,proto3" json:"time_of_last_write,omitempty"`
	// Time at which this chunk was marked as closed. Note this is not
	// the same as the timestamps on the data itself
	TimeClosed *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=time_closed,json=timeClosed,proto3" json:"time_closed,omitempty"`
	// Order of this chunk relative to other overlapping chunks.
	Order uint32 `protobuf:"varint,13,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

type ChunkLifecycleAction int32

type ChunkStorage int32

type CloseChunk struct {

	// name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// table name
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// chunk_id
	ChunkId uint32 `protobuf:"varint,3,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	// contains filtered or unexported fields
}

type ClosePartitionChunkRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// the partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// the table name
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// the chunk id
	ChunkId uint32 `protobuf:"varint,3,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	// contains filtered or unexported fields
}

type ClosePartitionChunkResponse struct {

	// The operation that tracks the work for migrating the chunk
	Operation *longrunning.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type CompactChunks struct {

	// name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// table name
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// chunk_id
	Chunks []uint32 `protobuf:"varint,3,rep,packed,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

type CreateDatabaseRequest struct {
	Rules *DatabaseRules `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

type CreateDatabaseResponse struct {
	// contains filtered or unexported fields
}

type CreateDummyJobRequest struct {
	Nanos []uint64 `protobuf:"varint,1,rep,packed,name=nanos,proto3" json:"nanos,omitempty"`
	// contains filtered or unexported fields
}

type CreateDummyJobResponse struct {
	Operation *longrunning.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseRules struct {

	// The unencoded name of the database
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Template that generates a partition key for each row inserted into the database
	PartitionTemplate *PartitionTemplate `protobuf:"bytes,2,opt,name=partition_template,json=partitionTemplate,proto3" json:"partition_template,omitempty"`
	// Configures how data flows through the system
	LifecycleRules *LifecycleRules `protobuf:"bytes,3,opt,name=lifecycle_rules,json=lifecycleRules,proto3" json:"lifecycle_rules,omitempty"`
	// Types that are assignable to RoutingRules:
	//	*DatabaseRules_ShardConfig
	//	*DatabaseRules_RoutingConfig
	RoutingRules isDatabaseRules_RoutingRules `protobuf_oneof:"routing_rules"`
	// Duration for which the cleanup loop should sleep on average.
	// Defaults to 500 seconds.
	WorkerCleanupAvgSleep *durationpb.Duration `` /* 129-byte string literal not displayed */
	// Optionally, the connection for the write buffer for writing or reading/restoring data.
	WriteBufferConnection *WriteBufferConnection `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DatabaseRules_RoutingConfig struct {
	// Routing config
	RoutingConfig *RoutingConfig `protobuf:"bytes,9,opt,name=routing_config,json=routingConfig,proto3,oneof"`
}

type DatabaseRules_ShardConfig struct {
	// Shard config
	ShardConfig *ShardConfig `protobuf:"bytes,8,opt,name=shard_config,json=shardConfig,proto3,oneof"`
}

type DatabaseStatus struct {

	// The name of the database.
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// If present, the database reports an error condition.
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Current initialization state of the database.
	State DatabaseStatus_DatabaseState `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DatabaseStatus_DatabaseState int32

type Delete struct {

	// name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// table name
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// delete predicate
	// Ideally, this can be any complicated expressions that DataFusion supports
	// but in our first version, we only support what our read buffer does which is
	// conjunctive expressions with columns being compared to literals using = or != operators.
	// Also, to avoid user from making mistake to delete the whole table, we will force them to
	// include delete time range start and stop in different fields defined below
	DeletePredicate string `protobuf:"bytes,3,opt,name=delete_predicate,json=deletePredicate,proto3" json:"delete_predicate,omitempty"`
	// start time range of deleting data
	StartTime string `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// stop time range of deleting data
	StopTime string `protobuf:"bytes,5,opt,name=stop_time,json=stopTime,proto3" json:"stop_time,omitempty"`
	// contains filtered or unexported fields
}

type DeleteBinaryExpr struct {

	// Left hand side which is a column name
	Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	// Operator
	Op DeleteOp `protobuf:"varint,2,opt,name=op,proto3,enum=influxdata.iox.management.v1.DeleteOp" json:"op,omitempty"`
	// Right hand side which is literal/constant
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type DeleteDatabaseRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteDatabaseResponse struct {
	// contains filtered or unexported fields
}

type DeleteOp int32

type DeleteRemoteRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRemoteResponse struct {
	// contains filtered or unexported fields
}

type DeleteRequest struct {

	// name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// table name
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// start time range
	StartTime string `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// stop time range
	StopTime string `protobuf:"bytes,4,opt,name=stop_time,json=stopTime,proto3" json:"stop_time,omitempty"`
	// predicate
	// conjunctive expressions of binary 'column_name = literal' or 'column_ame != literal'
	Predicate string `protobuf:"bytes,5,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	// contains filtered or unexported fields
}

type DetailedDatabase struct {

	// The generation ID of the database.
	GenerationId uint64 `protobuf:"varint,1,opt,name=generation_id,json=generationId,proto3" json:"generation_id,omitempty"`
	// The UTC datetime at which this database was deleted, if applicable.
	DeletedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// The name of the database.
	DbName string `protobuf:"bytes,3,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

type DevNull struct {
	// contains filtered or unexported fields
}

type DropChunk struct {

	// name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// table name
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// chunk_id
	ChunkId uint32 `protobuf:"varint,3,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	// contains filtered or unexported fields
}

type DropPartition struct {

	// name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// table name
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

type DropPartitionRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// the partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// the table name
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

type DropPartitionResponse struct {
	// contains filtered or unexported fields
}

type Dummy struct {

	// How long the job should sleep for before returning
	Nanos []uint64 `protobuf:"varint,1,rep,packed,name=nanos,proto3" json:"nanos,omitempty"`
	// Name of the database, if any
	DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

type Error struct {

	// Message descripting the error.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type GetDatabaseRequest struct {

	// The name of the database to retrieve
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// If false, or unspecified: return the current configuration that is being used by
	// the server, with all default values filled in.
	//
	// If true, returns only the persisted configuration (aka only
	// fields which were was supplied when the database was created or
	// last modified via UpdateDatabase)
	OmitDefaults bool `protobuf:"varint,2,opt,name=omit_defaults,json=omitDefaults,proto3" json:"omit_defaults,omitempty"`
	// contains filtered or unexported fields
}

type GetDatabaseResponse struct {
	Rules *DatabaseRules `protobuf:"bytes,1,opt,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

type GetPartitionRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// the partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// contains filtered or unexported fields
}

type GetPartitionResponse struct {

	// Detailed information about a partition
	Partition *Partition `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

type GetServerIdRequest struct {
	// contains filtered or unexported fields
}

type GetServerIdResponse struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetServerStatusRequest struct {
	// contains filtered or unexported fields
}

type GetServerStatusResponse struct {

	// Server status.
	ServerStatus *ServerStatus `protobuf:"bytes,1,opt,name=server_status,json=serverStatus,proto3" json:"server_status,omitempty"`
	// contains filtered or unexported fields
}

type HashRing struct {

	// If true the table name will be included in the hash key
	TableName bool `protobuf:"varint,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// include the values of these columns in the hash key
	Columns []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// ring of shards.
	Shards []uint32 `protobuf:"varint,3,rep,packed,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

type KafkaProducer struct {
	// contains filtered or unexported fields
}

type LifecycleRules struct {

	// Once the total amount of buffered data in memory reaches this size start
	// dropping data from memory
	BufferSizeSoft uint64 `protobuf:"varint,4,opt,name=buffer_size_soft,json=bufferSizeSoft,proto3" json:"buffer_size_soft,omitempty"`
	// Once the amount of data in memory reaches this size start
	// rejecting writes
	BufferSizeHard uint64 `protobuf:"varint,5,opt,name=buffer_size_hard,json=bufferSizeHard,proto3" json:"buffer_size_hard,omitempty"`
	// Persists chunks to object storage.
	Persist bool `protobuf:"varint,9,opt,name=persist,proto3" json:"persist,omitempty"`
	// Do not allow writing new data to this database
	Immutable bool `protobuf:"varint,8,opt,name=immutable,proto3" json:"immutable,omitempty"`
	// If the background worker doesn't find any work to do it will
	// sleep for this many milliseconds before looking again
	//
	// If 0, the default backoff is used
	// See server::db::lifecycle::DEFAULT_LIFECYCLE_BACKOFF
	WorkerBackoffMillis uint64 `protobuf:"varint,10,opt,name=worker_backoff_millis,json=workerBackoffMillis,proto3" json:"worker_backoff_millis,omitempty"`
	// After how many transactions should IOx write a new checkpoint?
	//
	// If 0 / absent, this default to 100.
	CatalogTransactionsUntilCheckpoint uint64 `` /* 169-byte string literal not displayed */
	// Prune catalog transactions older than the given age.
	//
	// Keeping old transaction can be useful for debugging.
	//
	// Defaults to 1 day.
	CatalogTransactionPruneAge *durationpb.Duration `` /* 144-byte string literal not displayed */
	/// Once a partition hasn't received a write for this period of time,
	/// it will be compacted and, if set, persisted. Writers will generally
	/// have this amount of time to send late arriving writes or this could
	/// be their clock skew.
	LateArriveWindowSeconds uint32 `` /* 136-byte string literal not displayed */
	// Maximum number of rows before triggering persistence
	PersistRowThreshold uint64 `protobuf:"varint,13,opt,name=persist_row_threshold,json=persistRowThreshold,proto3" json:"persist_row_threshold,omitempty"`
	// Maximum age of a write before triggering persistence
	PersistAgeThresholdSeconds uint32 `` /* 145-byte string literal not displayed */
	// Maximum number of rows to buffer in a MUB chunk before compacting it
	MubRowThreshold uint64 `protobuf:"varint,15,opt,name=mub_row_threshold,json=mubRowThreshold,proto3" json:"mub_row_threshold,omitempty"`
	// Types that are assignable to MaxActiveCompactionsCfg:
	//	*LifecycleRules_MaxActiveCompactions
	//	*LifecycleRules_MaxActiveCompactionsCpuFraction
	MaxActiveCompactionsCfg isLifecycleRules_MaxActiveCompactionsCfg `protobuf_oneof:"max_active_compactions_cfg"`
	// Use up to this amount of space in bytes for caching Parquet files.
	// A value of 0 disables Parquet caching
	ParquetCacheLimit uint64 `protobuf:"varint,17,opt,name=parquet_cache_limit,json=parquetCacheLimit,proto3" json:"parquet_cache_limit,omitempty"`
	// contains filtered or unexported fields
}

type LifecycleRules_MaxActiveCompactions struct {
	// The maximum number of concurrent active compactions that can run.
	MaxActiveCompactions uint32 `protobuf:"varint,16,opt,name=max_active_compactions,json=maxActiveCompactions,proto3,oneof"`
}

type LifecycleRules_MaxActiveCompactionsCpuFraction struct {
	// The maximum number of concurrent active compactions that can run
	// expressed as a fraction of the available cpus (rounded to the next smallest non-zero integer).
	MaxActiveCompactionsCpuFraction float32 `protobuf:"fixed32,18,opt,name=max_active_compactions_cpu_fraction,json=maxActiveCompactionsCpuFraction,proto3,oneof"`
}

type ListChunksRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

type ListChunksResponse struct {
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

type ListDatabasesRequest struct {

	// If true, returns only explciitly defined values. See additional
	// details on `GetDatabaseRequest`.
	OmitDefaults bool `protobuf:"varint,1,opt,name=omit_defaults,json=omitDefaults,proto3" json:"omit_defaults,omitempty"`
	// contains filtered or unexported fields
}

type ListDatabasesResponse struct {

	/// database rules (configuration) for each database
	Rules []*DatabaseRules `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

type ListDeletedDatabasesRequest struct {
	// contains filtered or unexported fields
}

type ListDeletedDatabasesResponse struct {
	DeletedDatabases []*DetailedDatabase `protobuf:"bytes,1,rep,name=deleted_databases,json=deletedDatabases,proto3" json:"deleted_databases,omitempty"`
	// contains filtered or unexported fields
}

type ListDetailedDatabasesRequest struct {
	// contains filtered or unexported fields
}

type ListDetailedDatabasesResponse struct {
	Databases []*DetailedDatabase `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

type ListPartitionChunksRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// the partition key
	PartitionKey string `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	// contains filtered or unexported fields
}

type ListPartitionChunksResponse struct {

	// All chunks in a partition
	Chunks []*Chunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

type ListPartitionsRequest struct {

	// the name of the database
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

type ListPartitionsResponse struct {

	// All partitions in a database
	Partitions []*Partition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

type ListRemotesRequest struct {
	// contains filtered or unexported fields
}

type ListRemotesResponse struct {
	Remotes []*Remote `protobuf:"bytes,1,rep,name=remotes,proto3" json:"remotes,omitempty"`
	// contains filtered or unexported fields
}

type ManagementServiceClient interface {
	GetServerId(ctx context.Context, in *GetServerIdRequest, opts ...grpc.CallOption) (*GetServerIdResponse, error)
	UpdateServerId(ctx context.Context, in *UpdateServerIdRequest, opts ...grpc.CallOption) (*UpdateServerIdResponse, error)
	SetServingReadiness(ctx context.Context, in *SetServingReadinessRequest, opts ...grpc.CallOption) (*SetServingReadinessResponse, error)
	// List all databases on this server.
	//
	// Roughly follows the <https://google.aip.dev/132> pattern, except we wrap the response
	ListDatabases(ctx context.Context, in *ListDatabasesRequest, opts ...grpc.CallOption) (*ListDatabasesResponse, error)
	// Return a specific database by name
	//
	// Roughly follows the <https://google.aip.dev/131> pattern, except
	// we wrap the response
	GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*GetDatabaseResponse, error)
	CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseResponse, error)
	// Update a database.
	//
	// Roughly follows the <https://google.aip.dev/134> pattern, except we wrap the response
	UpdateDatabase(ctx context.Context, in *UpdateDatabaseRequest, opts ...grpc.CallOption) (*UpdateDatabaseResponse, error)
	DeleteDatabase(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*DeleteDatabaseResponse, error)
	RestoreDatabase(ctx context.Context, in *RestoreDatabaseRequest, opts ...grpc.CallOption) (*RestoreDatabaseResponse, error)
	// List deleted databases and their metadata.
	ListDeletedDatabases(ctx context.Context, in *ListDeletedDatabasesRequest, opts ...grpc.CallOption) (*ListDeletedDatabasesResponse, error)
	// List all databases and their metadata.
	ListDetailedDatabases(ctx context.Context, in *ListDetailedDatabasesRequest, opts ...grpc.CallOption) (*ListDetailedDatabasesResponse, error)
	// List chunks available on this database
	ListChunks(ctx context.Context, in *ListChunksRequest, opts ...grpc.CallOption) (*ListChunksResponse, error)
	// List remote IOx servers we know about.
	ListRemotes(ctx context.Context, in *ListRemotesRequest, opts ...grpc.CallOption) (*ListRemotesResponse, error)
	// Update information about a remote IOx server (upsert).
	UpdateRemote(ctx context.Context, in *UpdateRemoteRequest, opts ...grpc.CallOption) (*UpdateRemoteResponse, error)
	// Delete a reference to remote IOx server.
	DeleteRemote(ctx context.Context, in *DeleteRemoteRequest, opts ...grpc.CallOption) (*DeleteRemoteResponse, error)
	// Creates a dummy job that for each value of the nanos field
	// spawns a task that sleeps for that number of nanoseconds before returning
	CreateDummyJob(ctx context.Context, in *CreateDummyJobRequest, opts ...grpc.CallOption) (*CreateDummyJobResponse, error)
	// List partitions in a database
	ListPartitions(ctx context.Context, in *ListPartitionsRequest, opts ...grpc.CallOption) (*ListPartitionsResponse, error)
	// Get detail information about a partition
	GetPartition(ctx context.Context, in *GetPartitionRequest, opts ...grpc.CallOption) (*GetPartitionResponse, error)
	// List chunks in a partition
	ListPartitionChunks(ctx context.Context, in *ListPartitionChunksRequest, opts ...grpc.CallOption) (*ListPartitionChunksResponse, error)
	// Create a new chunk in the mutable buffer
	NewPartitionChunk(ctx context.Context, in *NewPartitionChunkRequest, opts ...grpc.CallOption) (*NewPartitionChunkResponse, error)
	// Close a chunk and move it to the read buffer
	ClosePartitionChunk(ctx context.Context, in *ClosePartitionChunkRequest, opts ...grpc.CallOption) (*ClosePartitionChunkResponse, error)
	// Unload chunk from read buffer but keep it in object store
	UnloadPartitionChunk(ctx context.Context, in *UnloadPartitionChunkRequest, opts ...grpc.CallOption) (*UnloadPartitionChunkResponse, error)
	// Get server status
	GetServerStatus(ctx context.Context, in *GetServerStatusRequest, opts ...grpc.CallOption) (*GetServerStatusResponse, error)
	// Wipe preserved catalog for given DB.
	WipePreservedCatalog(ctx context.Context, in *WipePreservedCatalogRequest, opts ...grpc.CallOption) (*WipePreservedCatalogResponse, error)
	// Skip replay for given DB.
	SkipReplay(ctx context.Context, in *SkipReplayRequest, opts ...grpc.CallOption) (*SkipReplayResponse, error)
	// Persist given partition.
	//
	// Errors if there is nothing to persist at the moment as per the lifecycle rules. If successful it returns the
	// chunk that contains the persisted data.
	PersistPartition(ctx context.Context, in *PersistPartitionRequest, opts ...grpc.CallOption) (*PersistPartitionResponse, error)
	// Drop partition from memory and (if persisted) from object store.
	DropPartition(ctx context.Context, in *DropPartitionRequest, opts ...grpc.CallOption) (*DropPartitionResponse, error)
	// Delete data for a table on a specified predicate
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}

type ManagementServiceServer interface {
	GetServerId(context.Context, *GetServerIdRequest) (*GetServerIdResponse, error)
	UpdateServerId(context.Context, *UpdateServerIdRequest) (*UpdateServerIdResponse, error)
	SetServingReadiness(context.Context, *SetServingReadinessRequest) (*SetServingReadinessResponse, error)
	// List all databases on this server.
	//
	// Roughly follows the <https://google.aip.dev/132> pattern, except we wrap the response
	ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error)
	// Return a specific database by name
	//
	// Roughly follows the <https://google.aip.dev/131> pattern, except
	// we wrap the response
	GetDatabase(context.Context, *GetDatabaseRequest) (*GetDatabaseResponse, error)
	CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
	// Update a database.
	//
	// Roughly follows the <https://google.aip.dev/134> pattern, except we wrap the response
	UpdateDatabase(context.Context, *UpdateDatabaseRequest) (*UpdateDatabaseResponse, error)
	DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)
	RestoreDatabase(context.Context, *RestoreDatabaseRequest) (*RestoreDatabaseResponse, error)
	// List deleted databases and their metadata.
	ListDeletedDatabases(context.Context, *ListDeletedDatabasesRequest) (*ListDeletedDatabasesResponse, error)
	// List all databases and their metadata.
	ListDetailedDatabases(context.Context, *ListDetailedDatabasesRequest) (*ListDetailedDatabasesResponse, error)
	// List chunks available on this database
	ListChunks(context.Context, *ListChunksRequest) (*ListChunksResponse, error)
	// List remote IOx servers we know about.
	ListRemotes(context.Context, *ListRemotesRequest) (*ListRemotesResponse, error)
	// Update information about a remote IOx server (upsert).
	UpdateRemote(context.Context, *UpdateRemoteRequest) (*UpdateRemoteResponse, error)
	// Delete a reference to remote IOx server.
	DeleteRemote(context.Context, *DeleteRemoteRequest) (*DeleteRemoteResponse, error)
	// Creates a dummy job that for each value of the nanos field
	// spawns a task that sleeps for that number of nanoseconds before returning
	CreateDummyJob(context.Context, *CreateDummyJobRequest) (*CreateDummyJobResponse, error)
	// List partitions in a database
	ListPartitions(context.Context, *ListPartitionsRequest) (*ListPartitionsResponse, error)
	// Get detail information about a partition
	GetPartition(context.Context, *GetPartitionRequest) (*GetPartitionResponse, error)
	// List chunks in a partition
	ListPartitionChunks(context.Context, *ListPartitionChunksRequest) (*ListPartitionChunksResponse, error)
	// Create a new chunk in the mutable buffer
	NewPartitionChunk(context.Context, *NewPartitionChunkRequest) (*NewPartitionChunkResponse, error)
	// Close a chunk and move it to the read buffer
	ClosePartitionChunk(context.Context, *ClosePartitionChunkRequest) (*ClosePartitionChunkResponse, error)
	// Unload chunk from read buffer but keep it in object store
	UnloadPartitionChunk(context.Context, *UnloadPartitionChunkRequest) (*UnloadPartitionChunkResponse, error)
	// Get server status
	GetServerStatus(context.Context, *GetServerStatusRequest) (*GetServerStatusResponse, error)
	// Wipe preserved catalog for given DB.
	WipePreservedCatalog(context.Context, *WipePreservedCatalogRequest) (*WipePreservedCatalogResponse, error)
	// Skip replay for given DB.
	SkipReplay(context.Context, *SkipReplayRequest) (*SkipReplayResponse, error)
	// Persist given partition.
	//
	// Errors if there is nothing to persist at the moment as per the lifecycle rules. If successful it returns the
	// chunk that contains the persisted data.
	PersistPartition(context.Context, *PersistPartitionRequest) (*PersistPartitionResponse, error)
	// Drop partition from memory and (if persisted) from object store.
	DropPartition(context.Context, *DropPartitionRequest) (*DropPartitionResponse, error)
	// Delete data for a table on a specified predicate
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// contains filtered or unexported methods
}

type Matcher struct {

	// if provided, match if the table name matches against the regex
	TableNameRegex string `protobuf:"bytes,1,opt,name=table_name_regex,json=tableNameRegex,proto3" json:"table_name_regex,omitempty"`
	// paul: what should we use for predicate matching here against a single row/line?
	Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}