v1

type ColumnSchema struct {

	// Column ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Column type
	ColumnType ColumnSchema_ColumnType `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ColumnSchema_ColumnType int32

type GetSchemaRequest struct {

	// The namespace for which to fetch the schema
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type GetSchemaResponse struct {
	Schema *NamespaceSchema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

type Namespace struct {

	// Namespace ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the Namespace
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Retention period ns
	RetentionPeriodNs *int64 `protobuf:"varint,3,opt,name=retention_period_ns,json=retentionPeriodNs,proto3,oneof" json:"retention_period_ns,omitempty"`
	// contains filtered or unexported fields
}

type NamespaceSchema struct {

	// Namespace ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Topic ID
	TopicId int64 `protobuf:"varint,5,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	// Query Pool ID
	QueryPoolId int64 `protobuf:"varint,3,opt,name=query_pool_id,json=queryPoolId,proto3" json:"query_pool_id,omitempty"`
	// Map of Table Name -> Table Schema
	Tables map[string]*TableSchema `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SchemaServiceClient interface {
	// Get the schema for a namespace
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	// update retention period
	UpdateNamespaceRetention(ctx context.Context, in *UpdateNamespaceRetentionRequest, opts ...grpc.CallOption) (*UpdateNamespaceRetentionResponse, error)
}

type SchemaServiceServer interface {
	// Get the schema for a namespace
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	// update retention period
	UpdateNamespaceRetention(context.Context, *UpdateNamespaceRetentionRequest) (*UpdateNamespaceRetentionResponse, error)
	// contains filtered or unexported methods
}

type TableSchema struct {

	// Table ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Map of Column Name -> Table Schema
	Columns map[string]*ColumnSchema `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type UnimplementedSchemaServiceServer struct {
}

type UnsafeSchemaServiceServer interface {
	// contains filtered or unexported methods
}

type UpdateNamespaceRetentionRequest struct {

	// Name of the namespace to be set
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Number of hours of the retention period
	RetentionHours int64 `protobuf:"varint,2,opt,name=retention_hours,json=retentionHours,proto3" json:"retention_hours,omitempty"`
	// contains filtered or unexported fields
}

type UpdateNamespaceRetentionResponse struct {
	Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}