metastorev1

type AddBlockRequest struct {
	Block *BlockMeta `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

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

type BlockMeta struct {
	FormatVersion   uint64 `protobuf:"varint,1,opt,name=format_version,json=formatVersion,proto3" json:"format_version,omitempty"`
	Id              string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	MinTime         int64  `protobuf:"varint,3,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime         int64  `protobuf:"varint,4,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Shard           uint32 `protobuf:"varint,5,opt,name=shard,proto3" json:"shard,omitempty"`
	CompactionLevel uint32 `protobuf:"varint,6,opt,name=compaction_level,json=compactionLevel,proto3" json:"compaction_level,omitempty"`
	// Optional. Empty if compaction level is 0.
	TenantId string     `protobuf:"bytes,7,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Datasets []*Dataset `protobuf:"bytes,8,rep,name=datasets,proto3" json:"datasets,omitempty"`
	Size     uint64     `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type Dataset struct {
	Labels   []*v1.Labels `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty"`
	TenantId string       `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Name     string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	MinTime  int64        `protobuf:"varint,3,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime  int64        `protobuf:"varint,4,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	// Table of contents lists data sections within the tenant
	// service region. The offsets are absolute.
	//
	// The interpretation of the table of contents is specific
	// to the metadata format version. By default, the sections are:
	//   - 0: profiles.parquet
	//   - 1: index.tsdb
	//   - 2: symbols.symdb
	TableOfContents []uint64 `protobuf:"varint,5,rep,packed,name=table_of_contents,json=tableOfContents,proto3" json:"table_of_contents,omitempty"`
	// Size of the section in bytes.
	Size uint64 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	// TODO: delete
	// Profile types present in the tenant service data.
	ProfileTypes []string `protobuf:"bytes,7,rep,name=profile_types,json=profileTypes,proto3" json:"profile_types,omitempty"`
	// contains filtered or unexported fields
}

type GetProfileStatsRequest struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

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

type InfoResponse struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State    State  `protobuf:"varint,2,opt,name=state,proto3,enum=metastore.v1.State" json:"state,omitempty"`
	LeaderId string `protobuf:"bytes,3,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	// True if the state reported by this node matches the state the cluster
	// reports. For example, if this node claims to be a leader, but the rest of
	// the cluster disagrees, this value will be false.
	IsStateVerified bool `protobuf:"varint,4,opt,name=is_state_verified,json=isStateVerified,proto3" json:"is_state_verified,omitempty"`
	// Unix timestamp in milliseconds of when the leader last contacted this node.
	LastLeaderContact int64     `protobuf:"varint,5,opt,name=last_leader_contact,json=lastLeaderContact,proto3" json:"last_leader_contact,omitempty"`
	Term              uint64    `protobuf:"varint,6,opt,name=term,proto3" json:"term,omitempty"`
	Suffrage          Suffrage  `protobuf:"varint,7,opt,name=suffrage,proto3,enum=metastore.v1.Suffrage" json:"suffrage,omitempty"`
	Log               *Log      `protobuf:"bytes,8,opt,name=log,proto3" json:"log,omitempty"`
	Snapshot          *Snapshot `protobuf:"bytes,9,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	Protocol          *Protocol `protobuf:"bytes,10,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Peers             []*Peer   `protobuf:"bytes,11,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

type Log struct {
	CommitIndex      uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	AppliedIndex     uint64 `protobuf:"varint,2,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	LastIndex        uint64 `protobuf:"varint,3,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
	FsmPendingLength uint64 `protobuf:"varint,4,opt,name=fsm_pending_length,json=fsmPendingLength,proto3" json:"fsm_pending_length,omitempty"`
	// contains filtered or unexported fields
}

type MetastoreServiceClient interface {
	AddBlock(ctx context.Context, in *AddBlockRequest, opts ...grpc.CallOption) (*AddBlockResponse, error)
	QueryMetadata(ctx context.Context, in *QueryMetadataRequest, opts ...grpc.CallOption) (*QueryMetadataResponse, error)
	ReadIndex(ctx context.Context, in *ReadIndexRequest, opts ...grpc.CallOption) (*ReadIndexResponse, error)
	GetProfileStats(ctx context.Context, in *GetProfileStatsRequest, opts ...grpc.CallOption) (*v1.GetProfileStatsResponse, error)
}

type MetastoreServiceServer interface {
	AddBlock(context.Context, *AddBlockRequest) (*AddBlockResponse, error)
	QueryMetadata(context.Context, *QueryMetadataRequest) (*QueryMetadataResponse, error)
	ReadIndex(context.Context, *ReadIndexRequest) (*ReadIndexResponse, error)
	GetProfileStats(context.Context, *GetProfileStatsRequest) (*v1.GetProfileStatsResponse, error)
	// contains filtered or unexported methods
}

type OperatorServiceClient interface {
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
}

type OperatorServiceServer interface {
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	// contains filtered or unexported methods
}

type Peer struct {
	Id       string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address  string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Suffrage Suffrage `protobuf:"varint,3,opt,name=suffrage,proto3,enum=metastore.v1.Suffrage" json:"suffrage,omitempty"`
	// contains filtered or unexported fields
}

type Protocol struct {
	Version            uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	MinVersion         uint64 `protobuf:"varint,2,opt,name=min_version,json=minVersion,proto3" json:"min_version,omitempty"`
	MaxVersion         uint64 `protobuf:"varint,3,opt,name=max_version,json=maxVersion,proto3" json:"max_version,omitempty"`
	MinSnapshotVersion uint64 `protobuf:"varint,4,opt,name=min_snapshot_version,json=minSnapshotVersion,proto3" json:"min_snapshot_version,omitempty"`
	MaxSnapshotVersion uint64 `protobuf:"varint,5,opt,name=max_snapshot_version,json=maxSnapshotVersion,proto3" json:"max_snapshot_version,omitempty"`
	// contains filtered or unexported fields
}

type QueryMetadataRequest struct {
	TenantId  []string `protobuf:"bytes,1,rep,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	StartTime int64    `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   int64    `protobuf:"varint,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Query     string   `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type QueryMetadataResponse struct {
	Blocks []*BlockMeta `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

type ReadIndexRequest struct {
	DebugRequestId string `protobuf:"bytes,1,opt,name=debug_request_id,json=debugRequestId,proto3" json:"debug_request_id,omitempty"` // for debug logging, // todo delete
	// contains filtered or unexported fields
}

type ReadIndexResponse struct {
	ReadIndex uint64 `protobuf:"varint,1,opt,name=read_index,json=readIndex,proto3" json:"read_index,omitempty"`
	// contains filtered or unexported fields
}

type Snapshot struct {
	LastIndex uint64 `protobuf:"varint,1,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
	LastTerm  uint64 `protobuf:"varint,2,opt,name=last_term,json=lastTerm,proto3" json:"last_term,omitempty"`
	// contains filtered or unexported fields
}

type State int32

type Suffrage int32

type UnimplementedMetastoreServiceServer struct {
}

type UnimplementedOperatorServiceServer struct {
}

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

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