remotesapi

package
v0.40.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ManifestAppendixOption_name = map[int32]string{
		0: "MANIFEST_APPENDIX_OPTION_UNSPECIFIED",
		1: "MANIFEST_APPENDIX_OPTION_SET",
		2: "MANIFEST_APPENDIX_OPTION_APPEND",
	}
	ManifestAppendixOption_value = map[string]int32{
		"MANIFEST_APPENDIX_OPTION_UNSPECIFIED": 0,
		"MANIFEST_APPENDIX_OPTION_SET":         1,
		"MANIFEST_APPENDIX_OPTION_APPEND":      2,
	}
)

Enum value maps for ManifestAppendixOption.

View Source 
var ChunkStoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dolt.services.remotesapi.v1alpha1.ChunkStoreService",
	HandlerType: (*ChunkStoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRepoMetadata",
			Handler:    _ChunkStoreService_GetRepoMetadata_Handler,
		},
		{
			MethodName: "HasChunks",
			Handler:    _ChunkStoreService_HasChunks_Handler,
		},
		{
			MethodName: "GetDownloadLocations",
			Handler:    _ChunkStoreService_GetDownloadLocations_Handler,
		},
		{
			MethodName: "GetUploadLocations",
			Handler:    _ChunkStoreService_GetUploadLocations_Handler,
		},
		{
			MethodName: "Rebase",
			Handler:    _ChunkStoreService_Rebase_Handler,
		},
		{
			MethodName: "Root",
			Handler:    _ChunkStoreService_Root_Handler,
		},
		{
			MethodName: "Commit",
			Handler:    _ChunkStoreService_Commit_Handler,
		},
		{
			MethodName: "ListTableFiles",
			Handler:    _ChunkStoreService_ListTableFiles_Handler,
		},
		{
			MethodName: "RefreshTableFileUrl",
			Handler:    _ChunkStoreService_RefreshTableFileUrl_Handler,
		},
		{
			MethodName: "AddTableFiles",
			Handler:    _ChunkStoreService_AddTableFiles_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamDownloadLocations",
			Handler:       _ChunkStoreService_StreamDownloadLocations_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "dolt/services/remotesapi/v1alpha1/chunkstore.proto",
}

ChunkStoreService_ServiceDesc is the grpc.ServiceDesc for ChunkStoreService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var CredentialsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dolt.services.remotesapi.v1alpha1.CredentialsService",
	HandlerType: (*CredentialsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WhoAmI",
			Handler:    _CredentialsService_WhoAmI_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dolt/services/remotesapi/v1alpha1/credentials.proto",
}

CredentialsService_ServiceDesc is the grpc.ServiceDesc for CredentialsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_dolt_services_remotesapi_v1alpha1_chunkstore_proto protoreflect.FileDescriptor
View Source 
var File_dolt_services_remotesapi_v1alpha1_credentials_proto protoreflect.FileDescriptor

Functions

func RegisterChunkStoreServiceServer 

func RegisterChunkStoreServiceServer(s grpc.ServiceRegistrar, srv ChunkStoreServiceServer)

func RegisterCredentialsServiceServer 

func RegisterCredentialsServiceServer(s grpc.ServiceRegistrar, srv CredentialsServiceServer)

Types

type AddTableFilesRequest 

type AddTableFilesRequest struct {
	RepoId           *RepoId           `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	ClientRepoFormat *ClientRepoFormat `protobuf:"bytes,2,opt,name=client_repo_format,json=clientRepoFormat,proto3" json:"client_repo_format,omitempty"`
	ChunkTableInfo   []*ChunkTableInfo `protobuf:"bytes,3,rep,name=chunk_table_info,json=chunkTableInfo,proto3" json:"chunk_table_info,omitempty"`
	// If set, this is a write for the manifest appendix, not just the manifest table file specs.
	// The table files appearing in `chunk_table_info` are added to `specs` and are also set
	// in the manifest appendix. If `appendix_option` is `SET`, then the value of the appendix
	// becomes the full list provided in `chunk_table_info` and any prior specs in the appendix
	// are removed from the manifest specs. If `append_option` is `APPEND`, then the
	// supplied table files are added to the appendix and to specs.
	AppendixOption ManifestAppendixOption `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AddTableFilesRequest) Descriptor deprecated 

func (*AddTableFilesRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddTableFilesRequest.ProtoReflect.Descriptor instead.

func (*AddTableFilesRequest) GetAppendixOption 

func (x *AddTableFilesRequest) GetAppendixOption() ManifestAppendixOption

func (*AddTableFilesRequest) GetChunkTableInfo 

func (x *AddTableFilesRequest) GetChunkTableInfo() []*ChunkTableInfo

func (*AddTableFilesRequest) GetClientRepoFormat 

func (x *AddTableFilesRequest) GetClientRepoFormat() *ClientRepoFormat

func (*AddTableFilesRequest) GetRepoId 

func (x *AddTableFilesRequest) GetRepoId() *RepoId

func (*AddTableFilesRequest) ProtoMessage 

func (*AddTableFilesRequest) ProtoMessage()

func (*AddTableFilesRequest) ProtoReflect 

func (x *AddTableFilesRequest) ProtoReflect() protoreflect.Message

func (*AddTableFilesRequest) Reset 

func (x *AddTableFilesRequest) Reset()

func (*AddTableFilesRequest) String 

func (x *AddTableFilesRequest) String() string

type AddTableFilesResponse 

type AddTableFilesResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTableFilesResponse) Descriptor deprecated 

func (*AddTableFilesResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddTableFilesResponse.ProtoReflect.Descriptor instead.

func (*AddTableFilesResponse) GetSuccess 

func (x *AddTableFilesResponse) GetSuccess() bool

func (*AddTableFilesResponse) ProtoMessage 

func (*AddTableFilesResponse) ProtoMessage()

func (*AddTableFilesResponse) ProtoReflect 

func (x *AddTableFilesResponse) ProtoReflect() protoreflect.Message

func (*AddTableFilesResponse) Reset 

func (x *AddTableFilesResponse) Reset()

func (*AddTableFilesResponse) String 

func (x *AddTableFilesResponse) String() string

type ChunkStoreServiceClient 

type ChunkStoreServiceClient interface {
	GetRepoMetadata(ctx context.Context, in *GetRepoMetadataRequest, opts ...grpc.CallOption) (*GetRepoMetadataResponse, error)
	HasChunks(ctx context.Context, in *HasChunksRequest, opts ...grpc.CallOption) (*HasChunksResponse, error)
	// Get the download locations for a list of chunk hashes.
	// Deprecated. Use StreamDownloadLocations.
	GetDownloadLocations(ctx context.Context, in *GetDownloadLocsRequest, opts ...grpc.CallOption) (*GetDownloadLocsResponse, error)
	// Get the download locations for a list of chunk hashes. Streaming to
	// support large and incrementally available payloads. Results are generated
	// as requests come in.
	StreamDownloadLocations(ctx context.Context, opts ...grpc.CallOption) (ChunkStoreService_StreamDownloadLocationsClient, error)
	// Get upload locations for a list of table file hashes.
	// NOTE: We upload full table files but download individual chunks.
	GetUploadLocations(ctx context.Context, in *GetUploadLocsRequest, opts ...grpc.CallOption) (*GetUploadLocsResponse, error)
	Rebase(ctx context.Context, in *RebaseRequest, opts ...grpc.CallOption) (*RebaseResponse, error)
	Root(ctx context.Context, in *RootRequest, opts ...grpc.CallOption) (*RootResponse, error)
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	ListTableFiles(ctx context.Context, in *ListTableFilesRequest, opts ...grpc.CallOption) (*ListTableFilesResponse, error)
	RefreshTableFileUrl(ctx context.Context, in *RefreshTableFileUrlRequest, opts ...grpc.CallOption) (*RefreshTableFileUrlResponse, error)
	AddTableFiles(ctx context.Context, in *AddTableFilesRequest, opts ...grpc.CallOption) (*AddTableFilesResponse, error)
}

ChunkStoreServiceClient is the client API for ChunkStoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewChunkStoreServiceClient 

func NewChunkStoreServiceClient(cc grpc.ClientConnInterface) ChunkStoreServiceClient

type ChunkStoreServiceServer 

type ChunkStoreServiceServer interface {
	GetRepoMetadata(context.Context, *GetRepoMetadataRequest) (*GetRepoMetadataResponse, error)
	HasChunks(context.Context, *HasChunksRequest) (*HasChunksResponse, error)
	// Get the download locations for a list of chunk hashes.
	// Deprecated. Use StreamDownloadLocations.
	GetDownloadLocations(context.Context, *GetDownloadLocsRequest) (*GetDownloadLocsResponse, error)
	// Get the download locations for a list of chunk hashes. Streaming to
	// support large and incrementally available payloads. Results are generated
	// as requests come in.
	StreamDownloadLocations(ChunkStoreService_StreamDownloadLocationsServer) error
	// Get upload locations for a list of table file hashes.
	// NOTE: We upload full table files but download individual chunks.
	GetUploadLocations(context.Context, *GetUploadLocsRequest) (*GetUploadLocsResponse, error)
	Rebase(context.Context, *RebaseRequest) (*RebaseResponse, error)
	Root(context.Context, *RootRequest) (*RootResponse, error)
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	ListTableFiles(context.Context, *ListTableFilesRequest) (*ListTableFilesResponse, error)
	RefreshTableFileUrl(context.Context, *RefreshTableFileUrlRequest) (*RefreshTableFileUrlResponse, error)
	AddTableFiles(context.Context, *AddTableFilesRequest) (*AddTableFilesResponse, error)
	// contains filtered or unexported methods
}

ChunkStoreServiceServer is the server API for ChunkStoreService service. All implementations must embed UnimplementedChunkStoreServiceServer for forward compatibility

type ChunkStoreService_StreamDownloadLocationsClient 

type ChunkStoreService_StreamDownloadLocationsClient interface {
	Send(*GetDownloadLocsRequest) error
	Recv() (*GetDownloadLocsResponse, error)
	grpc.ClientStream
}

type ChunkStoreService_StreamDownloadLocationsServer 

type ChunkStoreService_StreamDownloadLocationsServer interface {
	Send(*GetDownloadLocsResponse) error
	Recv() (*GetDownloadLocsRequest, error)
	grpc.ServerStream
}

type ChunkTableInfo 

type ChunkTableInfo struct {
	Hash       []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	ChunkCount uint32 `protobuf:"varint,2,opt,name=chunk_count,json=chunkCount,proto3" json:"chunk_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkTableInfo) Descriptor deprecated 

func (*ChunkTableInfo) Descriptor() ([]byte, []int)

Deprecated: Use ChunkTableInfo.ProtoReflect.Descriptor instead.

func (*ChunkTableInfo) GetChunkCount 

func (x *ChunkTableInfo) GetChunkCount() uint32

func (*ChunkTableInfo) GetHash 

func (x *ChunkTableInfo) GetHash() []byte

func (*ChunkTableInfo) ProtoMessage 

func (*ChunkTableInfo) ProtoMessage()

func (*ChunkTableInfo) ProtoReflect 

func (x *ChunkTableInfo) ProtoReflect() protoreflect.Message

func (*ChunkTableInfo) Reset 

func (x *ChunkTableInfo) Reset()

func (*ChunkTableInfo) String 

func (x *ChunkTableInfo) String() string

type ClientRepoFormat 

type ClientRepoFormat struct {
	NbfVersion string `protobuf:"bytes,1,opt,name=nbf_version,json=nbfVersion,proto3" json:"nbf_version,omitempty"`
	NbsVersion string `protobuf:"bytes,2,opt,name=nbs_version,json=nbsVersion,proto3" json:"nbs_version,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientRepoFormat) Descriptor deprecated 

func (*ClientRepoFormat) Descriptor() ([]byte, []int)

Deprecated: Use ClientRepoFormat.ProtoReflect.Descriptor instead.

func (*ClientRepoFormat) GetNbfVersion 

func (x *ClientRepoFormat) GetNbfVersion() string

func (*ClientRepoFormat) GetNbsVersion 

func (x *ClientRepoFormat) GetNbsVersion() string

func (*ClientRepoFormat) ProtoMessage 

func (*ClientRepoFormat) ProtoMessage()

func (*ClientRepoFormat) ProtoReflect 

func (x *ClientRepoFormat) ProtoReflect() protoreflect.Message

func (*ClientRepoFormat) Reset 

func (x *ClientRepoFormat) Reset()

func (*ClientRepoFormat) String 

func (x *ClientRepoFormat) String() string

type CommitRequest 

type CommitRequest struct {
	RepoId           *RepoId           `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Current          []byte            `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	Last             []byte            `protobuf:"bytes,3,opt,name=last,proto3" json:"last,omitempty"`
	ChunkTableInfo   []*ChunkTableInfo `protobuf:"bytes,4,rep,name=chunk_table_info,json=chunkTableInfo,proto3" json:"chunk_table_info,omitempty"`
	ClientRepoFormat *ClientRepoFormat `protobuf:"bytes,14,opt,name=client_repo_format,json=clientRepoFormat,proto3" json:"client_repo_format,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitRequest) Descriptor deprecated 

func (*CommitRequest) Descriptor() ([]byte, []int)

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetChunkTableInfo 

func (x *CommitRequest) GetChunkTableInfo() []*ChunkTableInfo

func (*CommitRequest) GetClientRepoFormat 

func (x *CommitRequest) GetClientRepoFormat() *ClientRepoFormat

func (*CommitRequest) GetCurrent 

func (x *CommitRequest) GetCurrent() []byte

func (*CommitRequest) GetLast 

func (x *CommitRequest) GetLast() []byte

func (*CommitRequest) GetRepoId 

func (x *CommitRequest) GetRepoId() *RepoId

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect 

func (x *CommitRequest) ProtoReflect() protoreflect.Message

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitResponse 

type CommitResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitResponse) Descriptor deprecated 

func (*CommitResponse) Descriptor() ([]byte, []int)

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) GetSuccess 

func (x *CommitResponse) GetSuccess() bool

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect 

func (x *CommitResponse) ProtoReflect() protoreflect.Message

func (*CommitResponse) Reset 

func (x *CommitResponse) Reset()

func (*CommitResponse) String 

func (x *CommitResponse) String() string

type CredentialsServiceClient 

type CredentialsServiceClient interface {
	WhoAmI(ctx context.Context, in *WhoAmIRequest, opts ...grpc.CallOption) (*WhoAmIResponse, error)
}

CredentialsServiceClient is the client API for CredentialsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCredentialsServiceClient 

func NewCredentialsServiceClient(cc grpc.ClientConnInterface) CredentialsServiceClient

type CredentialsServiceServer 

type CredentialsServiceServer interface {
	WhoAmI(context.Context, *WhoAmIRequest) (*WhoAmIResponse, error)
	// contains filtered or unexported methods
}

CredentialsServiceServer is the server API for CredentialsService service. All implementations must embed UnimplementedCredentialsServiceServer for forward compatibility

type DownloadLoc 

type DownloadLoc struct {

	// Types that are assignable to Location:
	//	*DownloadLoc_HttpGet
	//	*DownloadLoc_HttpGetRange
	Location       isDownloadLoc_Location      `protobuf_oneof:"location"`
	RefreshAfter   *timestamppb.Timestamp      `protobuf:"bytes,3,opt,name=refresh_after,json=refreshAfter,proto3" json:"refresh_after,omitempty"`
	RefreshRequest *RefreshTableFileUrlRequest `protobuf:"bytes,4,opt,name=refresh_request,json=refreshRequest,proto3" json:"refresh_request,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadLoc) Descriptor deprecated 

func (*DownloadLoc) Descriptor() ([]byte, []int)

Deprecated: Use DownloadLoc.ProtoReflect.Descriptor instead.

func (*DownloadLoc) GetHttpGet 

func (x *DownloadLoc) GetHttpGet() *HttpGetChunk

func (*DownloadLoc) GetHttpGetRange 

func (x *DownloadLoc) GetHttpGetRange() *HttpGetRange

func (*DownloadLoc) GetLocation 

func (m *DownloadLoc) GetLocation() isDownloadLoc_Location

func (*DownloadLoc) GetRefreshAfter 

func (x *DownloadLoc) GetRefreshAfter() *timestamppb.Timestamp

func (*DownloadLoc) GetRefreshRequest 

func (x *DownloadLoc) GetRefreshRequest() *RefreshTableFileUrlRequest

func (*DownloadLoc) ProtoMessage 

func (*DownloadLoc) ProtoMessage()

func (*DownloadLoc) ProtoReflect 

func (x *DownloadLoc) ProtoReflect() protoreflect.Message

func (*DownloadLoc) Reset 

func (x *DownloadLoc) Reset()

func (*DownloadLoc) String 

func (x *DownloadLoc) String() string

type DownloadLoc_HttpGet 

type DownloadLoc_HttpGet struct {
	HttpGet *HttpGetChunk `protobuf:"bytes,1,opt,name=http_get,json=httpGet,proto3,oneof"`
}

type DownloadLoc_HttpGetRange 

type DownloadLoc_HttpGetRange struct {
	HttpGetRange *HttpGetRange `protobuf:"bytes,2,opt,name=http_get_range,json=httpGetRange,proto3,oneof"`
}

type GetDownloadLocsRequest 

type GetDownloadLocsRequest struct {
	RepoId      *RepoId  `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	ChunkHashes [][]byte `protobuf:"bytes,2,rep,name=chunk_hashes,json=chunkHashes,proto3" json:"chunk_hashes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDownloadLocsRequest) Descriptor deprecated 

func (*GetDownloadLocsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDownloadLocsRequest.ProtoReflect.Descriptor instead.

func (*GetDownloadLocsRequest) GetChunkHashes 

func (x *GetDownloadLocsRequest) GetChunkHashes() [][]byte

func (*GetDownloadLocsRequest) GetRepoId 

func (x *GetDownloadLocsRequest) GetRepoId() *RepoId

func (*GetDownloadLocsRequest) ProtoMessage 

func (*GetDownloadLocsRequest) ProtoMessage()

func (*GetDownloadLocsRequest) ProtoReflect 

func (x *GetDownloadLocsRequest) ProtoReflect() protoreflect.Message

func (*GetDownloadLocsRequest) Reset 

func (x *GetDownloadLocsRequest) Reset()

func (*GetDownloadLocsRequest) String 

func (x *GetDownloadLocsRequest) String() string

type GetDownloadLocsResponse 

type GetDownloadLocsResponse struct {
	Locs []*DownloadLoc `protobuf:"bytes,1,rep,name=locs,proto3" json:"locs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDownloadLocsResponse) Descriptor deprecated 

func (*GetDownloadLocsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDownloadLocsResponse.ProtoReflect.Descriptor instead.

func (*GetDownloadLocsResponse) GetLocs 

func (x *GetDownloadLocsResponse) GetLocs() []*DownloadLoc

func (*GetDownloadLocsResponse) ProtoMessage 

func (*GetDownloadLocsResponse) ProtoMessage()

func (*GetDownloadLocsResponse) ProtoReflect 

func (x *GetDownloadLocsResponse) ProtoReflect() protoreflect.Message

func (*GetDownloadLocsResponse) Reset 

func (x *GetDownloadLocsResponse) Reset()

func (*GetDownloadLocsResponse) String 

func (x *GetDownloadLocsResponse) String() string

type GetRepoMetadataRequest 

type GetRepoMetadataRequest struct {
	RepoId           *RepoId           `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	ClientRepoFormat *ClientRepoFormat `protobuf:"bytes,14,opt,name=client_repo_format,json=clientRepoFormat,proto3" json:"client_repo_format,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRepoMetadataRequest) Descriptor deprecated 

func (*GetRepoMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRepoMetadataRequest.ProtoReflect.Descriptor instead.

func (*GetRepoMetadataRequest) GetClientRepoFormat 

func (x *GetRepoMetadataRequest) GetClientRepoFormat() *ClientRepoFormat

func (*GetRepoMetadataRequest) GetRepoId 

func (x *GetRepoMetadataRequest) GetRepoId() *RepoId

func (*GetRepoMetadataRequest) ProtoMessage 

func (*GetRepoMetadataRequest) ProtoMessage()

func (*GetRepoMetadataRequest) ProtoReflect 

func (x *GetRepoMetadataRequest) ProtoReflect() protoreflect.Message

func (*GetRepoMetadataRequest) Reset 

func (x *GetRepoMetadataRequest) Reset()

func (*GetRepoMetadataRequest) String 

func (x *GetRepoMetadataRequest) String() string

type GetRepoMetadataResponse 

type GetRepoMetadataResponse struct {

	// Version string of the noms binary format for this repository.
	// See types.NomsBinFormat.
	NbfVersion string `protobuf:"bytes,1,opt,name=nbf_version,json=nbfVersion,proto3" json:"nbf_version,omitempty"`
	// Version string of the nbs format of this repository.
	// See nbs.StorageVersion.
	NbsVersion string `protobuf:"bytes,2,opt,name=nbs_version,json=nbsVersion,proto3" json:"nbs_version,omitempty"`
	// Approximate number of bytes required for storage of all
	// currently-referenced repository table files.
	StorageSize uint64 `protobuf:"varint,3,opt,name=storage_size,json=storageSize,proto3" json:"storage_size,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRepoMetadataResponse) Descriptor deprecated 

func (*GetRepoMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRepoMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetRepoMetadataResponse) GetNbfVersion 

func (x *GetRepoMetadataResponse) GetNbfVersion() string

func (*GetRepoMetadataResponse) GetNbsVersion 

func (x *GetRepoMetadataResponse) GetNbsVersion() string

func (*GetRepoMetadataResponse) GetStorageSize 

func (x *GetRepoMetadataResponse) GetStorageSize() uint64

func (*GetRepoMetadataResponse) ProtoMessage 

func (*GetRepoMetadataResponse) ProtoMessage()

func (*GetRepoMetadataResponse) ProtoReflect 

func (x *GetRepoMetadataResponse) ProtoReflect() protoreflect.Message

func (*GetRepoMetadataResponse) Reset 

func (x *GetRepoMetadataResponse) Reset()

func (*GetRepoMetadataResponse) String 

func (x *GetRepoMetadataResponse) String() string

type GetUploadLocsRequest 

type GetUploadLocsRequest struct {
	RepoId *RepoId `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Deprecated: Do not use.
	TableFileHashes  [][]byte            `protobuf:"bytes,2,rep,name=table_file_hashes,json=tableFileHashes,proto3" json:"table_file_hashes,omitempty"`
	TableFileDetails []*TableFileDetails `protobuf:"bytes,3,rep,name=table_file_details,json=tableFileDetails,proto3" json:"table_file_details,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUploadLocsRequest) Descriptor deprecated 

func (*GetUploadLocsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetUploadLocsRequest.ProtoReflect.Descriptor instead.

func (*GetUploadLocsRequest) GetRepoId 

func (x *GetUploadLocsRequest) GetRepoId() *RepoId

func (*GetUploadLocsRequest) GetTableFileDetails 

func (x *GetUploadLocsRequest) GetTableFileDetails() []*TableFileDetails

func (*GetUploadLocsRequest) GetTableFileHashes deprecated 

func (x *GetUploadLocsRequest) GetTableFileHashes() [][]byte

Deprecated: Do not use.

func (*GetUploadLocsRequest) ProtoMessage 

func (*GetUploadLocsRequest) ProtoMessage()

func (*GetUploadLocsRequest) ProtoReflect 

func (x *GetUploadLocsRequest) ProtoReflect() protoreflect.Message

func (*GetUploadLocsRequest) Reset 

func (x *GetUploadLocsRequest) Reset()

func (*GetUploadLocsRequest) String 

func (x *GetUploadLocsRequest) String() string

type GetUploadLocsResponse 

type GetUploadLocsResponse struct {
	Locs []*UploadLoc `protobuf:"bytes,1,rep,name=locs,proto3" json:"locs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUploadLocsResponse) Descriptor deprecated 

func (*GetUploadLocsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetUploadLocsResponse.ProtoReflect.Descriptor instead.

func (*GetUploadLocsResponse) GetLocs 

func (x *GetUploadLocsResponse) GetLocs() []*UploadLoc

func (*GetUploadLocsResponse) ProtoMessage 

func (*GetUploadLocsResponse) ProtoMessage()

func (*GetUploadLocsResponse) ProtoReflect 

func (x *GetUploadLocsResponse) ProtoReflect() protoreflect.Message

func (*GetUploadLocsResponse) Reset 

func (x *GetUploadLocsResponse) Reset()

func (*GetUploadLocsResponse) String 

func (x *GetUploadLocsResponse) String() string

type HasChunksRequest 

type HasChunksRequest struct {
	RepoId *RepoId  `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	Hashes [][]byte `protobuf:"bytes,2,rep,name=hashes,proto3" json:"hashes,omitempty"`
	// contains filtered or unexported fields
}

func (*HasChunksRequest) Descriptor deprecated 

func (*HasChunksRequest) Descriptor() ([]byte, []int)

Deprecated: Use HasChunksRequest.ProtoReflect.Descriptor instead.

func (*HasChunksRequest) GetHashes 

func (x *HasChunksRequest) GetHashes() [][]byte

func (*HasChunksRequest) GetRepoId 

func (x *HasChunksRequest) GetRepoId() *RepoId

func (*HasChunksRequest) ProtoMessage 

func (*HasChunksRequest) ProtoMessage()

func (*HasChunksRequest) ProtoReflect 

func (x *HasChunksRequest) ProtoReflect() protoreflect.Message

func (*HasChunksRequest) Reset 

func (x *HasChunksRequest) Reset()

func (*HasChunksRequest) String 

func (x *HasChunksRequest) String() string

type HasChunksResponse 

type HasChunksResponse struct {
	Absent []int32 `protobuf:"varint,1,rep,packed,name=absent,proto3" json:"absent,omitempty"`
	// contains filtered or unexported fields
}

func (*HasChunksResponse) Descriptor deprecated 

func (*HasChunksResponse) Descriptor() ([]byte, []int)

Deprecated: Use HasChunksResponse.ProtoReflect.Descriptor instead.

func (*HasChunksResponse) GetAbsent 

func (x *HasChunksResponse) GetAbsent() []int32

func (*HasChunksResponse) ProtoMessage 

func (*HasChunksResponse) ProtoMessage()

func (*HasChunksResponse) ProtoReflect 

func (x *HasChunksResponse) ProtoReflect() protoreflect.Message

func (*HasChunksResponse) Reset 

func (x *HasChunksResponse) Reset()

func (*HasChunksResponse) String 

func (x *HasChunksResponse) String() string

type HttpGetChunk 

type HttpGetChunk struct {
	Url    string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Hashes [][]byte `protobuf:"bytes,2,rep,name=hashes,proto3" json:"hashes,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpGetChunk) Descriptor deprecated 

func (*HttpGetChunk) Descriptor() ([]byte, []int)

Deprecated: Use HttpGetChunk.ProtoReflect.Descriptor instead.

func (*HttpGetChunk) GetHashes 

func (x *HttpGetChunk) GetHashes() [][]byte

func (*HttpGetChunk) GetUrl 

func (x *HttpGetChunk) GetUrl() string

func (*HttpGetChunk) ProtoMessage 

func (*HttpGetChunk) ProtoMessage()

func (*HttpGetChunk) ProtoReflect 

func (x *HttpGetChunk) ProtoReflect() protoreflect.Message

func (*HttpGetChunk) Reset 

func (x *HttpGetChunk) Reset()

func (*HttpGetChunk) String 

func (x *HttpGetChunk) String() string

type HttpGetRange 

type HttpGetRange struct {
	Url    string        `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Ranges []*RangeChunk `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpGetRange) Descriptor deprecated 

func (*HttpGetRange) Descriptor() ([]byte, []int)

Deprecated: Use HttpGetRange.ProtoReflect.Descriptor instead.

func (*HttpGetRange) GetRanges 

func (x *HttpGetRange) GetRanges() []*RangeChunk

func (*HttpGetRange) GetUrl 

func (x *HttpGetRange) GetUrl() string

func (*HttpGetRange) ProtoMessage 

func (*HttpGetRange) ProtoMessage()

func (*HttpGetRange) ProtoReflect 

func (x *HttpGetRange) ProtoReflect() protoreflect.Message

func (*HttpGetRange) Reset 

func (x *HttpGetRange) Reset()

func (*HttpGetRange) String 

func (x *HttpGetRange) String() string

type HttpPostTableFile 

type HttpPostTableFile struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpPostTableFile) Descriptor deprecated 

func (*HttpPostTableFile) Descriptor() ([]byte, []int)

Deprecated: Use HttpPostTableFile.ProtoReflect.Descriptor instead.

func (*HttpPostTableFile) GetUrl 

func (x *HttpPostTableFile) GetUrl() string

func (*HttpPostTableFile) ProtoMessage 

func (*HttpPostTableFile) ProtoMessage()

func (*HttpPostTableFile) ProtoReflect 

func (x *HttpPostTableFile) ProtoReflect() protoreflect.Message

func (*HttpPostTableFile) Reset 

func (x *HttpPostTableFile) Reset()

func (*HttpPostTableFile) String 

func (x *HttpPostTableFile) String() string

type ListTableFilesRequest 

type ListTableFilesRequest struct {
	RepoId *RepoId `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// Deprecated: Do not use.
	AppendixOnly bool `protobuf:"varint,2,opt,name=appendix_only,json=appendixOnly,proto3" json:"appendix_only,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTableFilesRequest) Descriptor deprecated 

func (*ListTableFilesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTableFilesRequest.ProtoReflect.Descriptor instead.

func (*ListTableFilesRequest) GetAppendixOnly deprecated 

func (x *ListTableFilesRequest) GetAppendixOnly() bool

Deprecated: Do not use.

func (*ListTableFilesRequest) GetRepoId 

func (x *ListTableFilesRequest) GetRepoId() *RepoId

func (*ListTableFilesRequest) ProtoMessage 

func (*ListTableFilesRequest) ProtoMessage()

func (*ListTableFilesRequest) ProtoReflect 

func (x *ListTableFilesRequest) ProtoReflect() protoreflect.Message

func (*ListTableFilesRequest) Reset 

func (x *ListTableFilesRequest) Reset()

func (*ListTableFilesRequest) String 

func (x *ListTableFilesRequest) String() string

type ListTableFilesResponse 

type ListTableFilesResponse struct {
	RootHash              []byte           `protobuf:"bytes,1,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
	TableFileInfo         []*TableFileInfo `protobuf:"bytes,2,rep,name=table_file_info,json=tableFileInfo,proto3" json:"table_file_info,omitempty"`
	AppendixTableFileInfo []*TableFileInfo `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListTableFilesResponse) Descriptor deprecated 

func (*ListTableFilesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTableFilesResponse.ProtoReflect.Descriptor instead.

func (*ListTableFilesResponse) GetAppendixTableFileInfo 

func (x *ListTableFilesResponse) GetAppendixTableFileInfo() []*TableFileInfo

func (*ListTableFilesResponse) GetRootHash 

func (x *ListTableFilesResponse) GetRootHash() []byte

func (*ListTableFilesResponse) GetTableFileInfo 

func (x *ListTableFilesResponse) GetTableFileInfo() []*TableFileInfo

func (*ListTableFilesResponse) ProtoMessage 

func (*ListTableFilesResponse) ProtoMessage()

func (*ListTableFilesResponse) ProtoReflect 

func (x *ListTableFilesResponse) ProtoReflect() protoreflect.Message

func (*ListTableFilesResponse) Reset 

func (x *ListTableFilesResponse) Reset()

func (*ListTableFilesResponse) String 

func (x *ListTableFilesResponse) String() string

type ManifestAppendixOption 

type ManifestAppendixOption int32
const (
	ManifestAppendixOption_MANIFEST_APPENDIX_OPTION_UNSPECIFIED ManifestAppendixOption = 0
	ManifestAppendixOption_MANIFEST_APPENDIX_OPTION_SET         ManifestAppendixOption = 1
	ManifestAppendixOption_MANIFEST_APPENDIX_OPTION_APPEND      ManifestAppendixOption = 2
)

func (ManifestAppendixOption) Descriptor 

func (ManifestAppendixOption) Descriptor() protoreflect.EnumDescriptor

func (ManifestAppendixOption) Enum 

func (x ManifestAppendixOption) Enum() *ManifestAppendixOption

func (ManifestAppendixOption) EnumDescriptor deprecated 

func (ManifestAppendixOption) EnumDescriptor() ([]byte, []int)

Deprecated: Use ManifestAppendixOption.Descriptor instead.

func (ManifestAppendixOption) Number 

func (x ManifestAppendixOption) Number() protoreflect.EnumNumber

func (ManifestAppendixOption) String 

func (x ManifestAppendixOption) String() string

func (ManifestAppendixOption) Type 

func (ManifestAppendixOption) Type() protoreflect.EnumType

type RangeChunk 

type RangeChunk struct {
	Hash   []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Length uint32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeChunk) Descriptor deprecated 

func (*RangeChunk) Descriptor() ([]byte, []int)

Deprecated: Use RangeChunk.ProtoReflect.Descriptor instead.

func (*RangeChunk) GetHash 

func (x *RangeChunk) GetHash() []byte

func (*RangeChunk) GetLength 

func (x *RangeChunk) GetLength() uint32

func (*RangeChunk) GetOffset 

func (x *RangeChunk) GetOffset() uint64

func (*RangeChunk) ProtoMessage 

func (*RangeChunk) ProtoMessage()

func (*RangeChunk) ProtoReflect 

func (x *RangeChunk) ProtoReflect() protoreflect.Message

func (*RangeChunk) Reset 

func (x *RangeChunk) Reset()

func (*RangeChunk) String 

func (x *RangeChunk) String() string

type RebaseRequest 

type RebaseRequest struct {
	RepoId *RepoId `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RebaseRequest) Descriptor deprecated 

func (*RebaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use RebaseRequest.ProtoReflect.Descriptor instead.

func (*RebaseRequest) GetRepoId 

func (x *RebaseRequest) GetRepoId() *RepoId

func (*RebaseRequest) ProtoMessage 

func (*RebaseRequest) ProtoMessage()

func (*RebaseRequest) ProtoReflect 

func (x *RebaseRequest) ProtoReflect() protoreflect.Message

func (*RebaseRequest) Reset 

func (x *RebaseRequest) Reset()

func (*RebaseRequest) String 

func (x *RebaseRequest) String() string

type RebaseResponse 

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

func (*RebaseResponse) Descriptor deprecated 

func (*RebaseResponse) Descriptor() ([]byte, []int)

Deprecated: Use RebaseResponse.ProtoReflect.Descriptor instead.

func (*RebaseResponse) ProtoMessage 

func (*RebaseResponse) ProtoMessage()

func (*RebaseResponse) ProtoReflect 

func (x *RebaseResponse) ProtoReflect() protoreflect.Message

func (*RebaseResponse) Reset 

func (x *RebaseResponse) Reset()

func (*RebaseResponse) String 

func (x *RebaseResponse) String() string

type RefreshTableFileUrlRequest 

type RefreshTableFileUrlRequest struct {
	RepoId *RepoId `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	FileId string  `protobuf:"bytes,2,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTableFileUrlRequest) Descriptor deprecated 

func (*RefreshTableFileUrlRequest) Descriptor() ([]byte, []int)

Deprecated: Use RefreshTableFileUrlRequest.ProtoReflect.Descriptor instead.

func (*RefreshTableFileUrlRequest) GetFileId 

func (x *RefreshTableFileUrlRequest) GetFileId() string

func (*RefreshTableFileUrlRequest) GetRepoId 

func (x *RefreshTableFileUrlRequest) GetRepoId() *RepoId

func (*RefreshTableFileUrlRequest) ProtoMessage 

func (*RefreshTableFileUrlRequest) ProtoMessage()

func (*RefreshTableFileUrlRequest) ProtoReflect 

func (x *RefreshTableFileUrlRequest) ProtoReflect() protoreflect.Message

func (*RefreshTableFileUrlRequest) Reset 

func (x *RefreshTableFileUrlRequest) Reset()

func (*RefreshTableFileUrlRequest) String 

func (x *RefreshTableFileUrlRequest) String() string

type RefreshTableFileUrlResponse 

type RefreshTableFileUrlResponse struct {
	Url          string                 `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	RefreshAfter *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=refresh_after,json=refreshAfter,proto3" json:"refresh_after,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTableFileUrlResponse) Descriptor deprecated 

func (*RefreshTableFileUrlResponse) Descriptor() ([]byte, []int)

Deprecated: Use RefreshTableFileUrlResponse.ProtoReflect.Descriptor instead.

func (*RefreshTableFileUrlResponse) GetRefreshAfter 

func (x *RefreshTableFileUrlResponse) GetRefreshAfter() *timestamppb.Timestamp

func (*RefreshTableFileUrlResponse) GetUrl 

func (x *RefreshTableFileUrlResponse) GetUrl() string

func (*RefreshTableFileUrlResponse) ProtoMessage 

func (*RefreshTableFileUrlResponse) ProtoMessage()

func (*RefreshTableFileUrlResponse) ProtoReflect 

func (x *RefreshTableFileUrlResponse) ProtoReflect() protoreflect.Message

func (*RefreshTableFileUrlResponse) Reset 

func (x *RefreshTableFileUrlResponse) Reset()

func (*RefreshTableFileUrlResponse) String 

func (x *RefreshTableFileUrlResponse) String() string

type RepoId 

type RepoId struct {
	Org      string `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	RepoName string `protobuf:"bytes,2,opt,name=repo_name,json=repoName,proto3" json:"repo_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RepoId) Descriptor deprecated 

func (*RepoId) Descriptor() ([]byte, []int)

Deprecated: Use RepoId.ProtoReflect.Descriptor instead.

func (*RepoId) GetOrg 

func (x *RepoId) GetOrg() string

func (*RepoId) GetRepoName 

func (x *RepoId) GetRepoName() string

func (*RepoId) ProtoMessage 

func (*RepoId) ProtoMessage()

func (*RepoId) ProtoReflect 

func (x *RepoId) ProtoReflect() protoreflect.Message

func (*RepoId) Reset 

func (x *RepoId) Reset()

func (*RepoId) String 

func (x *RepoId) String() string

type RootRequest 

type RootRequest struct {
	RepoId *RepoId `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RootRequest) Descriptor deprecated 

func (*RootRequest) Descriptor() ([]byte, []int)

Deprecated: Use RootRequest.ProtoReflect.Descriptor instead.

func (*RootRequest) GetRepoId 

func (x *RootRequest) GetRepoId() *RepoId

func (*RootRequest) ProtoMessage 

func (*RootRequest) ProtoMessage()

func (*RootRequest) ProtoReflect 

func (x *RootRequest) ProtoReflect() protoreflect.Message

func (*RootRequest) Reset 

func (x *RootRequest) Reset()

func (*RootRequest) String 

func (x *RootRequest) String() string

type RootResponse 

type RootResponse struct {
	RootHash []byte `protobuf:"bytes,1,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*RootResponse) Descriptor deprecated 

func (*RootResponse) Descriptor() ([]byte, []int)

Deprecated: Use RootResponse.ProtoReflect.Descriptor instead.

func (*RootResponse) GetRootHash 

func (x *RootResponse) GetRootHash() []byte

func (*RootResponse) ProtoMessage 

func (*RootResponse) ProtoMessage()

func (*RootResponse) ProtoReflect 

func (x *RootResponse) ProtoReflect() protoreflect.Message

func (*RootResponse) Reset 

func (x *RootResponse) Reset()

func (*RootResponse) String 

func (x *RootResponse) String() string

type TableFileDetails 

type TableFileDetails struct {
	Id            []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ContentLength uint64 `protobuf:"varint,2,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
	ContentHash   []byte `protobuf:"bytes,3,opt,name=content_hash,json=contentHash,proto3" json:"content_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*TableFileDetails) Descriptor deprecated 

func (*TableFileDetails) Descriptor() ([]byte, []int)

Deprecated: Use TableFileDetails.ProtoReflect.Descriptor instead.

func (*TableFileDetails) GetContentHash 

func (x *TableFileDetails) GetContentHash() []byte

func (*TableFileDetails) GetContentLength 

func (x *TableFileDetails) GetContentLength() uint64

func (*TableFileDetails) GetId 

func (x *TableFileDetails) GetId() []byte

func (*TableFileDetails) ProtoMessage 

func (*TableFileDetails) ProtoMessage()

func (*TableFileDetails) ProtoReflect 

func (x *TableFileDetails) ProtoReflect() protoreflect.Message

func (*TableFileDetails) Reset 

func (x *TableFileDetails) Reset()

func (*TableFileDetails) String 

func (x *TableFileDetails) String() string

type TableFileInfo 

type TableFileInfo struct {
	FileId         string                      `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	NumChunks      uint32                      `protobuf:"varint,2,opt,name=num_chunks,json=numChunks,proto3" json:"num_chunks,omitempty"`
	Url            string                      `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	RefreshAfter   *timestamppb.Timestamp      `protobuf:"bytes,4,opt,name=refresh_after,json=refreshAfter,proto3" json:"refresh_after,omitempty"`
	RefreshRequest *RefreshTableFileUrlRequest `protobuf:"bytes,5,opt,name=refresh_request,json=refreshRequest,proto3" json:"refresh_request,omitempty"`
	// contains filtered or unexported fields
}

func (*TableFileInfo) Descriptor deprecated 

func (*TableFileInfo) Descriptor() ([]byte, []int)

Deprecated: Use TableFileInfo.ProtoReflect.Descriptor instead.

func (*TableFileInfo) GetFileId 

func (x *TableFileInfo) GetFileId() string

func (*TableFileInfo) GetNumChunks 

func (x *TableFileInfo) GetNumChunks() uint32

func (*TableFileInfo) GetRefreshAfter 

func (x *TableFileInfo) GetRefreshAfter() *timestamppb.Timestamp

func (*TableFileInfo) GetRefreshRequest 

func (x *TableFileInfo) GetRefreshRequest() *RefreshTableFileUrlRequest

func (*TableFileInfo) GetUrl 

func (x *TableFileInfo) GetUrl() string

func (*TableFileInfo) ProtoMessage 

func (*TableFileInfo) ProtoMessage()

func (*TableFileInfo) ProtoReflect 

func (x *TableFileInfo) ProtoReflect() protoreflect.Message

func (*TableFileInfo) Reset 

func (x *TableFileInfo) Reset()

func (*TableFileInfo) String 

func (x *TableFileInfo) String() string

type UnimplementedChunkStoreServiceServer 

type UnimplementedChunkStoreServiceServer struct {
}

UnimplementedChunkStoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedChunkStoreServiceServer) AddTableFiles 

func (UnimplementedChunkStoreServiceServer) AddTableFiles(context.Context, *AddTableFilesRequest) (*AddTableFilesResponse, error)

func (UnimplementedChunkStoreServiceServer) Commit 

func (UnimplementedChunkStoreServiceServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error)

func (UnimplementedChunkStoreServiceServer) GetDownloadLocations 

func (UnimplementedChunkStoreServiceServer) GetDownloadLocations(context.Context, *GetDownloadLocsRequest) (*GetDownloadLocsResponse, error)

func (UnimplementedChunkStoreServiceServer) GetRepoMetadata 

func (UnimplementedChunkStoreServiceServer) GetRepoMetadata(context.Context, *GetRepoMetadataRequest) (*GetRepoMetadataResponse, error)

func (UnimplementedChunkStoreServiceServer) GetUploadLocations 

func (UnimplementedChunkStoreServiceServer) GetUploadLocations(context.Context, *GetUploadLocsRequest) (*GetUploadLocsResponse, error)

func (UnimplementedChunkStoreServiceServer) HasChunks 

func (UnimplementedChunkStoreServiceServer) HasChunks(context.Context, *HasChunksRequest) (*HasChunksResponse, error)

func (UnimplementedChunkStoreServiceServer) ListTableFiles 

func (UnimplementedChunkStoreServiceServer) ListTableFiles(context.Context, *ListTableFilesRequest) (*ListTableFilesResponse, error)

func (UnimplementedChunkStoreServiceServer) Rebase 

func (UnimplementedChunkStoreServiceServer) Rebase(context.Context, *RebaseRequest) (*RebaseResponse, error)

func (UnimplementedChunkStoreServiceServer) RefreshTableFileUrl 

func (UnimplementedChunkStoreServiceServer) RefreshTableFileUrl(context.Context, *RefreshTableFileUrlRequest) (*RefreshTableFileUrlResponse, error)

func (UnimplementedChunkStoreServiceServer) Root 

func (UnimplementedChunkStoreServiceServer) Root(context.Context, *RootRequest) (*RootResponse, error)

func (UnimplementedChunkStoreServiceServer) StreamDownloadLocations 

func (UnimplementedChunkStoreServiceServer) StreamDownloadLocations(ChunkStoreService_StreamDownloadLocationsServer) error

type UnimplementedCredentialsServiceServer 

type UnimplementedCredentialsServiceServer struct {
}

UnimplementedCredentialsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCredentialsServiceServer) WhoAmI 

func (UnimplementedCredentialsServiceServer) WhoAmI(context.Context, *WhoAmIRequest) (*WhoAmIResponse, error)

type UnsafeChunkStoreServiceServer 

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

UnsafeChunkStoreServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChunkStoreServiceServer will result in compilation errors.

type UnsafeCredentialsServiceServer 

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

UnsafeCredentialsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CredentialsServiceServer will result in compilation errors.

type UploadLoc 

type UploadLoc struct {
	TableFileHash []byte `protobuf:"bytes,1,opt,name=table_file_hash,json=tableFileHash,proto3" json:"table_file_hash,omitempty"`
	// Types that are assignable to Location:
	//	*UploadLoc_HttpPost
	Location isUploadLoc_Location `protobuf_oneof:"location"`
	// contains filtered or unexported fields
}

func (*UploadLoc) Descriptor deprecated 

func (*UploadLoc) Descriptor() ([]byte, []int)

Deprecated: Use UploadLoc.ProtoReflect.Descriptor instead.

func (*UploadLoc) GetHttpPost 

func (x *UploadLoc) GetHttpPost() *HttpPostTableFile

func (*UploadLoc) GetLocation 

func (m *UploadLoc) GetLocation() isUploadLoc_Location

func (*UploadLoc) GetTableFileHash 

func (x *UploadLoc) GetTableFileHash() []byte

func (*UploadLoc) ProtoMessage 

func (*UploadLoc) ProtoMessage()

func (*UploadLoc) ProtoReflect 

func (x *UploadLoc) ProtoReflect() protoreflect.Message

func (*UploadLoc) Reset 

func (x *UploadLoc) Reset()

func (*UploadLoc) String 

func (x *UploadLoc) String() string

type UploadLoc_HttpPost 

type UploadLoc_HttpPost struct {
	HttpPost *HttpPostTableFile `protobuf:"bytes,2,opt,name=http_post,json=httpPost,proto3,oneof"`
}

type WhoAmIRequest 

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

func (*WhoAmIRequest) Descriptor deprecated 

func (*WhoAmIRequest) Descriptor() ([]byte, []int)

Deprecated: Use WhoAmIRequest.ProtoReflect.Descriptor instead.

func (*WhoAmIRequest) ProtoMessage 

func (*WhoAmIRequest) ProtoMessage()

func (*WhoAmIRequest) ProtoReflect 

func (x *WhoAmIRequest) ProtoReflect() protoreflect.Message

func (*WhoAmIRequest) Reset 

func (x *WhoAmIRequest) Reset()

func (*WhoAmIRequest) String 

func (x *WhoAmIRequest) String() string

type WhoAmIResponse 

type WhoAmIResponse struct {

	// Ex: "bheni"
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// Ex: "Brian Hendriks"
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Ex: "brian@liquidata.co"
	EmailAddress string `protobuf:"bytes,3,opt,name=email_address,json=emailAddress,proto3" json:"email_address,omitempty"`
	// contains filtered or unexported fields
}

func (*WhoAmIResponse) Descriptor deprecated 

func (*WhoAmIResponse) Descriptor() ([]byte, []int)

Deprecated: Use WhoAmIResponse.ProtoReflect.Descriptor instead.

func (*WhoAmIResponse) GetDisplayName 

func (x *WhoAmIResponse) GetDisplayName() string

func (*WhoAmIResponse) GetEmailAddress 

func (x *WhoAmIResponse) GetEmailAddress() string

func (*WhoAmIResponse) GetUsername 

func (x *WhoAmIResponse) GetUsername() string

func (*WhoAmIResponse) ProtoMessage 

func (*WhoAmIResponse) ProtoMessage()

func (*WhoAmIResponse) ProtoReflect 

func (x *WhoAmIResponse) ProtoReflect() protoreflect.Message

func (*WhoAmIResponse) Reset 

func (x *WhoAmIResponse) Reset()

func (*WhoAmIResponse) String 

func (x *WhoAmIResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.