Documentation
¶
Overview ¶
Package bboltproto contains the definition of the **specific GRPC protpcol** that is used between an SST Client and the BBolt part of an **SST Remote Repository**; both using the SST Core API.
Index ¶
- Constants
- Variables
- func DatasetReadUUID() *fieldmaskpb.FieldMask
- func RegisterCommitServiceServer(s grpc.ServiceRegistrar, srv CommitServiceServer)
- func RegisterDatasetServiceServer(s grpc.ServiceRegistrar, srv DatasetServiceServer)
- func RegisterRefServiceServer(s grpc.ServiceRegistrar, srv RefServiceServer)
- func RegisterRepoManagerServiceServer(s grpc.ServiceRegistrar, srv RepoManagerServiceServer)
- type BareRefName
- type BranchRef
- type Commit
- func (*Commit) Descriptor() ([]byte, []int)deprecated
- func (x *Commit) GetAuthorTimestamp() *timestamppb.Timestamp
- func (x *Commit) GetAuthorUri() string
- func (x *Commit) GetCommitId() []byte
- func (x *Commit) GetDatasets() []*CommittedDatasetRevision
- func (x *Commit) GetMessage() string
- func (x *Commit) GetMessageOrReason() isCommit_MessageOrReason
- func (x *Commit) GetNamedGraphs() []*CommittedNamedGraphRevision
- func (x *Commit) GetReason() string
- func (*Commit) ProtoMessage()
- func (x *Commit) ProtoReflect() protoreflect.Message
- func (x *Commit) Reset()
- func (x *Commit) String() string
- type CommitDetail
- func (*CommitDetail) Descriptor() ([]byte, []int)deprecated
- func (x *CommitDetail) GetAuthor() string
- func (x *CommitDetail) GetCommitId() []byte
- func (x *CommitDetail) GetDatasetRevisions() map[string][]byte
- func (x *CommitDetail) GetMessage() string
- func (x *CommitDetail) GetNamedGraphRevisions() map[string][]byte
- func (x *CommitDetail) GetParentCommits() map[string]*ParentHashes
- func (x *CommitDetail) GetTimestamp() int64
- func (*CommitDetail) ProtoMessage()
- func (x *CommitDetail) ProtoReflect() protoreflect.Message
- func (x *CommitDetail) Reset()
- func (x *CommitDetail) String() string
- type CommitServiceClient
- type CommitServiceServer
- type CommitService_GetCommitClient
- type CommitService_GetCommitServer
- type CommitService_ListCommitsClient
- type CommitService_ListCommitsServer
- type Commit_Message
- type Commit_MessageOrReason
- type Commit_Reason
- type CommittedDatasetRevision
- func (*CommittedDatasetRevision) Descriptor() ([]byte, []int)deprecated
- func (x *CommittedDatasetRevision) GetDatasetHash() []byte
- func (x *CommittedDatasetRevision) GetDatasetUuid() []byte
- func (x *CommittedDatasetRevision) GetParentCommitIds() [][]byte
- func (*CommittedDatasetRevision) ProtoMessage()
- func (x *CommittedDatasetRevision) ProtoReflect() protoreflect.Message
- func (x *CommittedDatasetRevision) Reset()
- func (x *CommittedDatasetRevision) String() string
- type CommittedNamedGraphRevision
- func (*CommittedNamedGraphRevision) Descriptor() ([]byte, []int)deprecated
- func (x *CommittedNamedGraphRevision) GetNamedGraphHash() []byte
- func (x *CommittedNamedGraphRevision) GetNamedGraphUuid() []byte
- func (*CommittedNamedGraphRevision) ProtoMessage()
- func (x *CommittedNamedGraphRevision) ProtoReflect() protoreflect.Message
- func (x *CommittedNamedGraphRevision) Reset()
- func (x *CommittedNamedGraphRevision) String() string
- type CompareCommitsRequest
- func (*CompareCommitsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompareCommitsRequest) GetDatasetCommitPair() []*CompareCommitsRequest_DatasetCommitPair
- func (x *CompareCommitsRequest) GetRepoName() string
- func (*CompareCommitsRequest) ProtoMessage()
- func (x *CompareCommitsRequest) ProtoReflect() protoreflect.Message
- func (x *CompareCommitsRequest) Reset()
- func (x *CompareCommitsRequest) String() string
- type CompareCommitsRequest_DatasetCommitPair
- func (*CompareCommitsRequest_DatasetCommitPair) Descriptor() ([]byte, []int)deprecated
- func (x *CompareCommitsRequest_DatasetCommitPair) GetCommit1() []byte
- func (x *CompareCommitsRequest_DatasetCommitPair) GetCommit2() []byte
- func (x *CompareCommitsRequest_DatasetCommitPair) GetDatasetId() [][]byte
- func (*CompareCommitsRequest_DatasetCommitPair) ProtoMessage()
- func (x *CompareCommitsRequest_DatasetCommitPair) ProtoReflect() protoreflect.Message
- func (x *CompareCommitsRequest_DatasetCommitPair) Reset()
- func (x *CompareCommitsRequest_DatasetCommitPair) String() string
- type CompareCommitsResponse
- func (*CompareCommitsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CompareCommitsResponse) GetRelationshipAndCount() []byte
- func (*CompareCommitsResponse) ProtoMessage()
- func (x *CompareCommitsResponse) ProtoReflect() protoreflect.Message
- func (x *CompareCommitsResponse) Reset()
- func (x *CompareCommitsResponse) String() string
- type CreateCommitRequest
- func (*CreateCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCommitRequest) GetBaseCommit() []byte
- func (x *CreateCommitRequest) GetCheckoutDatasetSignatures() []*DatasetSignature
- func (x *CreateCommitRequest) GetCheckoutNamedGraphSignatures() []*NamedGraphSignature
- func (x *CreateCommitRequest) GetFlags() []CreateCommitRequest_Flag
- func (x *CreateCommitRequest) GetMessage() string
- func (x *CreateCommitRequest) GetModifiedNGs() [][]byte
- func (x *CreateCommitRequest) GetNamedGraphs() [][]byte
- func (x *CreateCommitRequest) GetParentCommitOverrides() []*ParentCommit
- func (x *CreateCommitRequest) GetRefName() *RefName
- func (x *CreateCommitRequest) GetRepoName() string
- func (*CreateCommitRequest) ProtoMessage()
- func (x *CreateCommitRequest) ProtoReflect() protoreflect.Message
- func (x *CreateCommitRequest) Reset()
- func (x *CreateCommitRequest) String() string
- type CreateCommitRequest_Flag
- func (CreateCommitRequest_Flag) Descriptor() protoreflect.EnumDescriptor
- func (x CreateCommitRequest_Flag) Enum() *CreateCommitRequest_Flag
- func (CreateCommitRequest_Flag) EnumDescriptor() ([]byte, []int)deprecated
- func (x CreateCommitRequest_Flag) Number() protoreflect.EnumNumber
- func (x CreateCommitRequest_Flag) String() string
- func (CreateCommitRequest_Flag) Type() protoreflect.EnumType
- type CreateCommitResponse
- func (*CreateCommitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCommitResponse) GetCheckoutDatasetSignatures() []*DatasetSignature
- func (x *CreateCommitResponse) GetCheckoutNamedGraphSignatures() []*NamedGraphSignature
- func (x *CreateCommitResponse) GetCommitId() []byte
- func (x *CreateCommitResponse) GetModifiedDatasets() [][]byte
- func (*CreateCommitResponse) ProtoMessage()
- func (x *CreateCommitResponse) ProtoReflect() protoreflect.Message
- func (x *CreateCommitResponse) Reset()
- func (x *CreateCommitResponse) String() string
- type CreateDatasetRequest
- func (*CreateDatasetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDatasetRequest) FieldMask_Filter() *CreateDatasetRequest_FieldMask
- func (x *CreateDatasetRequest) FieldMask_Prune() *CreateDatasetRequest_FieldMask
- func (x *CreateDatasetRequest) GetDatasetUuid() []byte
- func (x *CreateDatasetRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *CreateDatasetRequest) MaskOut_Iri() *CreateDatasetRequest
- func (x *CreateDatasetRequest) MaskOut_Uuid() *CreateDatasetRequest
- func (*CreateDatasetRequest) ProtoMessage()
- func (x *CreateDatasetRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDatasetRequest) Reset()
- func (x *CreateDatasetRequest) String() string
- type CreateDatasetRequest_FieldMask
- type CreateRepoReply
- type CreateRepoRequest
- type Dataset
- type DatasetInquiry
- func (*DatasetInquiry) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetInquiry) GetHasCommitIdNoParents() []byte
- func (x *DatasetInquiry) GetHasCommitIdWithParents() []byte
- func (x *DatasetInquiry) GetInq() isDatasetInquiry_Inq
- func (x *DatasetInquiry) GetRepoName() string
- func (x *DatasetInquiry) GetWantDatasetNoCommitParents() *RefName
- func (x *DatasetInquiry) GetWantDatasetRevision() []byte
- func (x *DatasetInquiry) GetWantDatasetWithCommitParents() *RefName
- func (*DatasetInquiry) ProtoMessage()
- func (x *DatasetInquiry) ProtoReflect() protoreflect.Message
- func (x *DatasetInquiry) Reset()
- func (x *DatasetInquiry) String() string
- type DatasetInquiry_HasCommitIdNoParents
- type DatasetInquiry_HasCommitIdWithParents
- type DatasetInquiry_WantDatasetNoCommitParents
- type DatasetInquiry_WantDatasetRevision
- type DatasetInquiry_WantDatasetWithCommitParents
- type DatasetObject
- func (*DatasetObject) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetObject) GetCommit() *Commit
- func (x *DatasetObject) GetDatasetRevision() *DatasetRevision
- func (x *DatasetObject) GetDatasetRevisionCommitHash() *DatasetRevisionToCommitHash
- func (x *DatasetObject) GetNamedGraphRevision() *NamedGraphRevision
- func (x *DatasetObject) GetObj() isDatasetObject_Obj
- func (x *DatasetObject) GetPendingCommitId() []byte
- func (x *DatasetObject) GetWantedDatasetNoCommitParents() *Ref
- func (x *DatasetObject) GetWantedDatasetRevision() []byte
- func (x *DatasetObject) GetWantedDatasetWithCommitParents() *Ref
- func (*DatasetObject) ProtoMessage()
- func (x *DatasetObject) ProtoReflect() protoreflect.Message
- func (x *DatasetObject) Reset()
- func (x *DatasetObject) String() string
- type DatasetObject_Commit
- type DatasetObject_DatasetRevision
- type DatasetObject_DatasetRevisionCommitHash
- type DatasetObject_NamedGraphRevision
- type DatasetObject_PendingCommitId
- type DatasetObject_WantedDatasetNoCommitParents
- type DatasetObject_WantedDatasetRevision
- type DatasetObject_WantedDatasetWithCommitParents
- type DatasetRevision
- func (*DatasetRevision) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetRevision) GetDefaultNamedGraphHash() []byte
- func (x *DatasetRevision) GetHash() []byte
- func (x *DatasetRevision) GetImportedDatasets() []*DatasetRevision_Import
- func (*DatasetRevision) ProtoMessage()
- func (x *DatasetRevision) ProtoReflect() protoreflect.Message
- func (x *DatasetRevision) Reset()
- func (x *DatasetRevision) String() string
- type DatasetRevisionToCommitHash
- func (*DatasetRevisionToCommitHash) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetRevisionToCommitHash) GetCommitHash() []byte
- func (x *DatasetRevisionToCommitHash) GetDatasetRevision() []byte
- func (*DatasetRevisionToCommitHash) ProtoMessage()
- func (x *DatasetRevisionToCommitHash) ProtoReflect() protoreflect.Message
- func (x *DatasetRevisionToCommitHash) Reset()
- func (x *DatasetRevisionToCommitHash) String() string
- type DatasetRevision_Import
- func (*DatasetRevision_Import) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetRevision_Import) GetDatasetHash() []byte
- func (x *DatasetRevision_Import) GetDatasetUuid() []byte
- func (*DatasetRevision_Import) ProtoMessage()
- func (x *DatasetRevision_Import) ProtoReflect() protoreflect.Message
- func (x *DatasetRevision_Import) Reset()
- func (x *DatasetRevision_Import) String() string
- type DatasetServiceClient
- type DatasetServiceServer
- type DatasetService_DocumentClient
- type DatasetService_DocumentServer
- type DatasetService_DocumentSetClient
- type DatasetService_DocumentSetServer
- type DatasetService_DownloadNamedGraphRevisionClient
- type DatasetService_DownloadNamedGraphRevisionServer
- type DatasetService_FetchDatasetsClient
- type DatasetService_FetchDatasetsServer
- type DatasetService_GetDatasetClient
- type DatasetService_GetDatasetServer
- type DatasetService_PushDatasetsClient
- type DatasetService_PushDatasetsServer
- type DatasetService_SyncFromClient
- type DatasetService_SyncFromServer
- type DatasetService_SyncToClient
- type DatasetService_SyncToServer
- type DatasetSignature
- func (*DatasetSignature) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetSignature) GetDSHash() []byte
- func (x *DatasetSignature) GetDSUuid() []byte
- func (*DatasetSignature) ProtoMessage()
- func (x *DatasetSignature) ProtoReflect() protoreflect.Message
- func (x *DatasetSignature) Reset()
- func (x *DatasetSignature) String() string
- type DatasetSuggestion
- func (*DatasetSuggestion) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetSuggestion) GetObj() *DatasetObject
- func (x *DatasetSuggestion) GetSgg() isDatasetSuggestion_Sgg
- func (x *DatasetSuggestion) GetSuggestDatasetNoCommitParents() *RefName
- func (x *DatasetSuggestion) GetSuggestDatasetWithCommitParents() *RefName
- func (*DatasetSuggestion) ProtoMessage()
- func (x *DatasetSuggestion) ProtoReflect() protoreflect.Message
- func (x *DatasetSuggestion) Reset()
- func (x *DatasetSuggestion) String() string
- type DatasetSuggestion_Obj
- type DatasetSuggestion_SuggestDatasetNoCommitParents
- type DatasetSuggestion_SuggestDatasetWithCommitParents
- type DeleteRepoReply
- type DeleteRepoRequest
- type DocumentDeleteRequest
- func (*DocumentDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentDeleteRequest) GetHash() []byte
- func (x *DocumentDeleteRequest) GetRepoName() string
- func (*DocumentDeleteRequest) ProtoMessage()
- func (x *DocumentDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DocumentDeleteRequest) Reset()
- func (x *DocumentDeleteRequest) String() string
- type DocumentDeleteResponse
- type DocumentInfo
- func (*DocumentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentInfo) GetAuthor() string
- func (x *DocumentInfo) GetHash() []byte
- func (x *DocumentInfo) GetMimeType() string
- func (x *DocumentInfo) GetSizeBytes() int64
- func (x *DocumentInfo) GetTimestamp() *timestamppb.Timestamp
- func (*DocumentInfo) ProtoMessage()
- func (x *DocumentInfo) ProtoReflect() protoreflect.Message
- func (x *DocumentInfo) Reset()
- func (x *DocumentInfo) String() string
- type DocumentRequest
- func (*DocumentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentRequest) GetHash() []byte
- func (x *DocumentRequest) GetRepoName() string
- func (*DocumentRequest) ProtoMessage()
- func (x *DocumentRequest) ProtoReflect() protoreflect.Message
- func (x *DocumentRequest) Reset()
- func (x *DocumentRequest) String() string
- type DocumentResponse
- func (*DocumentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentResponse) GetChunk() []byte
- func (x *DocumentResponse) GetEvent() isDocumentResponse_Event
- func (x *DocumentResponse) GetInfo() *DocumentInfo
- func (*DocumentResponse) ProtoMessage()
- func (x *DocumentResponse) ProtoReflect() protoreflect.Message
- func (x *DocumentResponse) Reset()
- func (x *DocumentResponse) String() string
- type DocumentResponse_Chunk
- type DocumentResponse_Info
- type DocumentSetRequest
- func (*DocumentSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentSetRequest) GetContent() []byte
- func (x *DocumentSetRequest) GetEvent() isDocumentSetRequest_Event
- func (x *DocumentSetRequest) GetInfo() *DocumentInfo
- func (x *DocumentSetRequest) GetRepoName() string
- func (*DocumentSetRequest) ProtoMessage()
- func (x *DocumentSetRequest) ProtoReflect() protoreflect.Message
- func (x *DocumentSetRequest) Reset()
- func (x *DocumentSetRequest) String() string
- type DocumentSetRequest_Content
- type DocumentSetRequest_Info
- type DocumentSetResponse
- func (*DocumentSetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentSetResponse) GetHash() []byte
- func (*DocumentSetResponse) ProtoMessage()
- func (x *DocumentSetResponse) ProtoReflect() protoreflect.Message
- func (x *DocumentSetResponse) Reset()
- func (x *DocumentSetResponse) String() string
- type DocumentsListRequest
- func (*DocumentsListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentsListRequest) GetRepoName() string
- func (*DocumentsListRequest) ProtoMessage()
- func (x *DocumentsListRequest) ProtoReflect() protoreflect.Message
- func (x *DocumentsListRequest) Reset()
- func (x *DocumentsListRequest) String() string
- type DocumentsListResponse
- func (*DocumentsListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentsListResponse) GetDocuments() []*DocumentInfo
- func (*DocumentsListResponse) ProtoMessage()
- func (x *DocumentsListResponse) ProtoReflect() protoreflect.Message
- func (x *DocumentsListResponse) Reset()
- func (x *DocumentsListResponse) String() string
- type DownloadNamedGraphRevisionRequest
- func (*DownloadNamedGraphRevisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadNamedGraphRevisionRequest) GetHash() []byte
- func (x *DownloadNamedGraphRevisionRequest) GetRepoName() string
- func (*DownloadNamedGraphRevisionRequest) ProtoMessage()
- func (x *DownloadNamedGraphRevisionRequest) ProtoReflect() protoreflect.Message
- func (x *DownloadNamedGraphRevisionRequest) Reset()
- func (x *DownloadNamedGraphRevisionRequest) String() string
- type DownloadNamedGraphRevisionResponse
- func (*DownloadNamedGraphRevisionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DownloadNamedGraphRevisionResponse) GetChunk() []byte
- func (*DownloadNamedGraphRevisionResponse) ProtoMessage()
- func (x *DownloadNamedGraphRevisionResponse) ProtoReflect() protoreflect.Message
- func (x *DownloadNamedGraphRevisionResponse) Reset()
- func (x *DownloadNamedGraphRevisionResponse) String() string
- type FindCommonParentRevisionRequest
- func (*FindCommonParentRevisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindCommonParentRevisionRequest) GetDatasetCommitRv1() []byte
- func (x *FindCommonParentRevisionRequest) GetDatasetCommitRv2() []byte
- func (x *FindCommonParentRevisionRequest) GetDatasetId() []byte
- func (x *FindCommonParentRevisionRequest) GetRepoName() string
- func (*FindCommonParentRevisionRequest) ProtoMessage()
- func (x *FindCommonParentRevisionRequest) ProtoReflect() protoreflect.Message
- func (x *FindCommonParentRevisionRequest) Reset()
- func (x *FindCommonParentRevisionRequest) String() string
- type FindCommonParentRevisionResponse
- func (*FindCommonParentRevisionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FindCommonParentRevisionResponse) GetCommonParentCommitRv() []byte
- func (*FindCommonParentRevisionResponse) ProtoMessage()
- func (x *FindCommonParentRevisionResponse) ProtoReflect() protoreflect.Message
- func (x *FindCommonParentRevisionResponse) Reset()
- func (x *FindCommonParentRevisionResponse) String() string
- type GetBranchesRequest
- func (*GetBranchesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetBranchesRequest) GetRepoName() string
- func (x *GetBranchesRequest) GetUuid() []byte
- func (*GetBranchesRequest) ProtoMessage()
- func (x *GetBranchesRequest) ProtoReflect() protoreflect.Message
- func (x *GetBranchesRequest) Reset()
- func (x *GetBranchesRequest) String() string
- type GetBranchesResponse
- func (*GetBranchesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetBranchesResponse) GetBranchRefs() []*BranchRef
- func (*GetBranchesResponse) ProtoMessage()
- func (x *GetBranchesResponse) ProtoReflect() protoreflect.Message
- func (x *GetBranchesResponse) Reset()
- func (x *GetBranchesResponse) String() string
- type GetCommitDetailsBatchRequest
- func (*GetCommitDetailsBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCommitDetailsBatchRequest) GetCommitIds() [][]byte
- func (x *GetCommitDetailsBatchRequest) GetRepoName() string
- func (*GetCommitDetailsBatchRequest) ProtoMessage()
- func (x *GetCommitDetailsBatchRequest) ProtoReflect() protoreflect.Message
- func (x *GetCommitDetailsBatchRequest) Reset()
- func (x *GetCommitDetailsBatchRequest) String() string
- type GetCommitDetailsBatchResponse
- func (*GetCommitDetailsBatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCommitDetailsBatchResponse) GetDetails() []*CommitDetail
- func (*GetCommitDetailsBatchResponse) ProtoMessage()
- func (x *GetCommitDetailsBatchResponse) ProtoReflect() protoreflect.Message
- func (x *GetCommitDetailsBatchResponse) Reset()
- func (x *GetCommitDetailsBatchResponse) String() string
- type GetCommitRequest
- func (*GetCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetCommitRequest) FieldMask_Filter() *GetCommitRequest_FieldMask
- func (x *GetCommitRequest) FieldMask_Prune() *GetCommitRequest_FieldMask
- func (x *GetCommitRequest) GetCommitId() []byte
- func (x *GetCommitRequest) GetDatasetUuid() []byte
- func (x *GetCommitRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *GetCommitRequest) GetRepoName() string
- func (x *GetCommitRequest) MaskOut_AuthorTimestamp() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_AuthorTimestamp_Nanos() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_AuthorTimestamp_Seconds() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_AuthorUri() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_CommitId() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_Datasets() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_Message() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_NamedGraphs() *GetCommitRequest
- func (x *GetCommitRequest) MaskOut_Reason() *GetCommitRequest
- func (*GetCommitRequest) ProtoMessage()
- func (x *GetCommitRequest) ProtoReflect() protoreflect.Message
- func (x *GetCommitRequest) Reset()
- func (x *GetCommitRequest) String() string
- type GetCommitRequest_FieldMask
- func (x *GetCommitRequest_FieldMask) Mask(m *Commit) *Commit
- func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp_Nanos() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp_Seconds() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorUri() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_CommitId() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_Datasets() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_Message() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_NamedGraphs() bool
- func (x *GetCommitRequest_FieldMask) MaskedOut_Reason() bool
- type GetDatasetRequest
- func (*GetDatasetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDatasetRequest) FieldMask_Filter() *GetDatasetRequest_FieldMask
- func (x *GetDatasetRequest) FieldMask_Prune() *GetDatasetRequest_FieldMask
- func (x *GetDatasetRequest) GetDatasetId() isGetDatasetRequest_DatasetId
- func (x *GetDatasetRequest) GetDatasetIri() string
- func (x *GetDatasetRequest) GetDatasetUuid() []byte
- func (x *GetDatasetRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *GetDatasetRequest) GetRepoName() string
- func (x *GetDatasetRequest) MaskOut_Iri() *GetDatasetRequest
- func (x *GetDatasetRequest) MaskOut_Uuid() *GetDatasetRequest
- func (*GetDatasetRequest) ProtoMessage()
- func (x *GetDatasetRequest) ProtoReflect() protoreflect.Message
- func (x *GetDatasetRequest) Reset()
- func (x *GetDatasetRequest) String() string
- type GetDatasetRequest_DatasetIri
- type GetDatasetRequest_DatasetUuid
- type GetDatasetRequest_FieldMask
- type GetLeafCommitsRequest
- func (*GetLeafCommitsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetLeafCommitsRequest) GetRepoName() string
- func (x *GetLeafCommitsRequest) GetUuid() []byte
- func (*GetLeafCommitsRequest) ProtoMessage()
- func (x *GetLeafCommitsRequest) ProtoReflect() protoreflect.Message
- func (x *GetLeafCommitsRequest) Reset()
- func (x *GetLeafCommitsRequest) String() string
- type GetLeafCommitsResponse
- func (*GetLeafCommitsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLeafCommitsResponse) GetCommitHashes() [][]byte
- func (*GetLeafCommitsResponse) ProtoMessage()
- func (x *GetLeafCommitsResponse) ProtoReflect() protoreflect.Message
- func (x *GetLeafCommitsResponse) Reset()
- func (x *GetLeafCommitsResponse) String() string
- type GetRefRequest
- func (*GetRefRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRefRequest) FieldMask_Filter() *GetRefRequest_FieldMask
- func (x *GetRefRequest) FieldMask_Prune() *GetRefRequest_FieldMask
- func (x *GetRefRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *GetRefRequest) GetRefName() *RefName
- func (x *GetRefRequest) GetRepoName() string
- func (x *GetRefRequest) MaskOut_CommitId() *GetRefRequest
- func (x *GetRefRequest) MaskOut_Ref() *GetRefRequest
- func (x *GetRefRequest) MaskOut_Ref_Branch() *GetRefRequest
- func (x *GetRefRequest) MaskOut_Ref_DatasetIri() *GetRefRequest
- func (x *GetRefRequest) MaskOut_Ref_DatasetUuid() *GetRefRequest
- func (x *GetRefRequest) MaskOut_Ref_Leaf() *GetRefRequest
- func (*GetRefRequest) ProtoMessage()
- func (x *GetRefRequest) ProtoReflect() protoreflect.Message
- func (x *GetRefRequest) Reset()
- func (x *GetRefRequest) String() string
- type GetRefRequest_FieldMask
- func (x *GetRefRequest_FieldMask) Mask(m *Ref) *Ref
- func (x *GetRefRequest_FieldMask) MaskedOut_CommitId() bool
- func (x *GetRefRequest_FieldMask) MaskedOut_Ref() bool
- func (x *GetRefRequest_FieldMask) MaskedOut_Ref_Branch() bool
- func (x *GetRefRequest_FieldMask) MaskedOut_Ref_DatasetIri() bool
- func (x *GetRefRequest_FieldMask) MaskedOut_Ref_DatasetUuid() bool
- func (x *GetRefRequest_FieldMask) MaskedOut_Ref_Leaf() bool
- type GetRepoBleveInfoRequest
- type GetRepoBleveInfoResponse
- func (*GetRepoBleveInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRepoBleveInfoResponse) GetName() string
- func (x *GetRepoBleveInfoResponse) GetVersion() string
- func (*GetRepoBleveInfoResponse) ProtoMessage()
- func (x *GetRepoBleveInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetRepoBleveInfoResponse) Reset()
- func (x *GetRepoBleveInfoResponse) String() string
- type GetRepositoryInfoRequest
- func (*GetRepositoryInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRepositoryInfoRequest) GetBranchName() string
- func (x *GetRepositoryInfoRequest) GetRepoName() string
- func (*GetRepositoryInfoRequest) ProtoMessage()
- func (x *GetRepositoryInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetRepositoryInfoRequest) Reset()
- func (x *GetRepositoryInfoRequest) String() string
- type GetRepositoryInfoResponse
- func (*GetRepositoryInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRepositoryInfoResponse) GetAccessRight() string
- func (x *GetRepositoryInfoResponse) GetBboltSize() int32
- func (x *GetRepositoryInfoResponse) GetBleveSize() int32
- func (x *GetRepositoryInfoResponse) GetDocumentDbSize() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfCommits() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfDatasetRevisions() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfDatasets() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfDatasetsInBranch() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfDocuments() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfNamedGraphRevisions() int32
- func (x *GetRepositoryInfoResponse) GetNumberOfRepositoryLogs() int32
- func (x *GetRepositoryInfoResponse) GetVersionHash() string
- func (*GetRepositoryInfoResponse) ProtoMessage()
- func (x *GetRepositoryInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetRepositoryInfoResponse) Reset()
- func (x *GetRepositoryInfoResponse) String() string
- type GetRepositoryLogRequest
- func (*GetRepositoryLogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRepositoryLogRequest) GetEnd() int64
- func (x *GetRepositoryLogRequest) GetRepoName() string
- func (x *GetRepositoryLogRequest) GetStart() int64
- func (*GetRepositoryLogRequest) ProtoMessage()
- func (x *GetRepositoryLogRequest) ProtoReflect() protoreflect.Message
- func (x *GetRepositoryLogRequest) Reset()
- func (x *GetRepositoryLogRequest) String() string
- type GetRepositoryLogResponse
- func (*GetRepositoryLogResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRepositoryLogResponse) GetEntries() []*RepositoryLogEntry
- func (*GetRepositoryLogResponse) ProtoMessage()
- func (x *GetRepositoryLogResponse) ProtoReflect() protoreflect.Message
- func (x *GetRepositoryLogResponse) Reset()
- func (x *GetRepositoryLogResponse) String() string
- type ListCommitsRequest
- func (*ListCommitsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListCommitsRequest) FieldMask_Filter() *ListCommitsRequest_FieldMask
- func (x *ListCommitsRequest) FieldMask_Prune() *ListCommitsRequest_FieldMask
- func (x *ListCommitsRequest) GetPageSize() int32
- func (x *ListCommitsRequest) GetPageToken() string
- func (x *ListCommitsRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *ListCommitsRequest) GetRefName() *RefName
- func (x *ListCommitsRequest) MaskOut_AuthorTimestamp() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_AuthorTimestamp_Nanos() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_AuthorTimestamp_Seconds() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_AuthorUri() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_CommitId() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_Datasets() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_Message() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_NamedGraphs() *ListCommitsRequest
- func (x *ListCommitsRequest) MaskOut_Reason() *ListCommitsRequest
- func (*ListCommitsRequest) ProtoMessage()
- func (x *ListCommitsRequest) ProtoReflect() protoreflect.Message
- func (x *ListCommitsRequest) Reset()
- func (x *ListCommitsRequest) String() string
- type ListCommitsRequest_FieldMask
- func (x *ListCommitsRequest_FieldMask) Mask(m *Commit) *Commit
- func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp_Nanos() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp_Seconds() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorUri() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_CommitId() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_Datasets() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_Message() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_NamedGraphs() bool
- func (x *ListCommitsRequest_FieldMask) MaskedOut_Reason() bool
- type ListCommitsResponse
- func (*ListCommitsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListCommitsResponse) GetCommits() []*Commit
- func (x *ListCommitsResponse) GetNextPageToken() string
- func (*ListCommitsResponse) ProtoMessage()
- func (x *ListCommitsResponse) ProtoReflect() protoreflect.Message
- func (x *ListCommitsResponse) Reset()
- func (x *ListCommitsResponse) String() string
- type ListCommitsResponse_NextPageToken
- func (*ListCommitsResponse_NextPageToken) Descriptor() ([]byte, []int)deprecated
- func (x *ListCommitsResponse_NextPageToken) GetNextCommitId() []byte
- func (*ListCommitsResponse_NextPageToken) ProtoMessage()
- func (x *ListCommitsResponse_NextPageToken) ProtoReflect() protoreflect.Message
- func (x *ListCommitsResponse_NextPageToken) Reset()
- func (x *ListCommitsResponse_NextPageToken) String() string
- type ListDatasetsRequest
- func (*ListDatasetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDatasetsRequest) FieldMask_Filter() *ListDatasetsRequest_FieldMask
- func (x *ListDatasetsRequest) FieldMask_Prune() *ListDatasetsRequest_FieldMask
- func (x *ListDatasetsRequest) GetPageSize() int32
- func (x *ListDatasetsRequest) GetPageToken() string
- func (x *ListDatasetsRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *ListDatasetsRequest) GetRepoName() string
- func (x *ListDatasetsRequest) MaskOut_Iri() *ListDatasetsRequest
- func (x *ListDatasetsRequest) MaskOut_Uuid() *ListDatasetsRequest
- func (*ListDatasetsRequest) ProtoMessage()
- func (x *ListDatasetsRequest) ProtoReflect() protoreflect.Message
- func (x *ListDatasetsRequest) Reset()
- func (x *ListDatasetsRequest) String() string
- type ListDatasetsRequest_FieldMask
- type ListDatasetsResponse
- func (*ListDatasetsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDatasetsResponse) GetDatasets() []*Dataset
- func (x *ListDatasetsResponse) GetNextPageToken() string
- func (*ListDatasetsResponse) ProtoMessage()
- func (x *ListDatasetsResponse) ProtoReflect() protoreflect.Message
- func (x *ListDatasetsResponse) Reset()
- func (x *ListDatasetsResponse) String() string
- type ListDatasetsResponse_NextPageToken
- func (*ListDatasetsResponse_NextPageToken) Descriptor() ([]byte, []int)deprecated
- func (x *ListDatasetsResponse_NextPageToken) GetNextId() []byte
- func (*ListDatasetsResponse_NextPageToken) ProtoMessage()
- func (x *ListDatasetsResponse_NextPageToken) ProtoReflect() protoreflect.Message
- func (x *ListDatasetsResponse_NextPageToken) Reset()
- func (x *ListDatasetsResponse_NextPageToken) String() string
- type ListRefsRequest
- func (*ListRefsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRefsRequest) FieldMask_Filter() *ListRefsRequest_FieldMask
- func (x *ListRefsRequest) FieldMask_Prune() *ListRefsRequest_FieldMask
- func (x *ListRefsRequest) GetDatasetId() isListRefsRequest_DatasetId
- func (x *ListRefsRequest) GetDatasetIri() string
- func (x *ListRefsRequest) GetDatasetUuid() []byte
- func (x *ListRefsRequest) GetPageSize() int32
- func (x *ListRefsRequest) GetPageToken() string
- func (x *ListRefsRequest) GetReadMask() *fieldmaskpb.FieldMask
- func (x *ListRefsRequest) MaskOut_CommitId() *ListRefsRequest
- func (x *ListRefsRequest) MaskOut_Ref() *ListRefsRequest
- func (x *ListRefsRequest) MaskOut_Ref_Branch() *ListRefsRequest
- func (x *ListRefsRequest) MaskOut_Ref_DatasetIri() *ListRefsRequest
- func (x *ListRefsRequest) MaskOut_Ref_DatasetUuid() *ListRefsRequest
- func (x *ListRefsRequest) MaskOut_Ref_Leaf() *ListRefsRequest
- func (*ListRefsRequest) ProtoMessage()
- func (x *ListRefsRequest) ProtoReflect() protoreflect.Message
- func (x *ListRefsRequest) Reset()
- func (x *ListRefsRequest) String() string
- type ListRefsRequest_DatasetIri
- type ListRefsRequest_DatasetUuid
- type ListRefsRequest_FieldMask
- func (x *ListRefsRequest_FieldMask) Mask(m *Ref) *Ref
- func (x *ListRefsRequest_FieldMask) MaskedOut_CommitId() bool
- func (x *ListRefsRequest_FieldMask) MaskedOut_Ref() bool
- func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_Branch() bool
- func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_DatasetIri() bool
- func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_DatasetUuid() bool
- func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_Leaf() bool
- type ListRefsResponse
- func (*ListRefsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListRefsResponse) GetNextPageToken() string
- func (x *ListRefsResponse) GetRefs() []*Ref
- func (*ListRefsResponse) ProtoMessage()
- func (x *ListRefsResponse) ProtoReflect() protoreflect.Message
- func (x *ListRefsResponse) Reset()
- func (x *ListRefsResponse) String() string
- type ListRefsResponse_NextPageToken
- func (*ListRefsResponse_NextPageToken) Descriptor() ([]byte, []int)deprecated
- func (x *ListRefsResponse_NextPageToken) GetNextBranch() string
- func (x *ListRefsResponse_NextPageToken) GetNextDatasetUuid() []byte
- func (x *ListRefsResponse_NextPageToken) GetNextLeaf() []byte
- func (x *ListRefsResponse_NextPageToken) GetNextRefName() isListRefsResponse_NextPageToken_NextRefName
- func (*ListRefsResponse_NextPageToken) ProtoMessage()
- func (x *ListRefsResponse_NextPageToken) ProtoReflect() protoreflect.Message
- func (x *ListRefsResponse_NextPageToken) Reset()
- func (x *ListRefsResponse_NextPageToken) String() string
- type ListRefsResponse_NextPageToken_NextBranch
- type ListRefsResponse_NextPageToken_NextLeaf
- type ListRefsResponse_NextPageToken_NextRefName
- type ListReposReply
- type ListReposRequest
- type NamedGraphRevision
- func (*NamedGraphRevision) Descriptor() ([]byte, []int)deprecated
- func (x *NamedGraphRevision) GetContent() []byte
- func (x *NamedGraphRevision) GetHash() []byte
- func (*NamedGraphRevision) ProtoMessage()
- func (x *NamedGraphRevision) ProtoReflect() protoreflect.Message
- func (x *NamedGraphRevision) Reset()
- func (x *NamedGraphRevision) String() string
- type NamedGraphSignature
- func (*NamedGraphSignature) Descriptor() ([]byte, []int)deprecated
- func (x *NamedGraphSignature) GetNgHash() []byte
- func (x *NamedGraphSignature) GetNgUuid() []byte
- func (*NamedGraphSignature) ProtoMessage()
- func (x *NamedGraphSignature) ProtoReflect() protoreflect.Message
- func (x *NamedGraphSignature) Reset()
- func (x *NamedGraphSignature) String() string
- type ParentCommit
- func (*ParentCommit) Descriptor() ([]byte, []int)deprecated
- func (x *ParentCommit) GetCommitId() []byte
- func (x *ParentCommit) GetDatasetUuid() []byte
- func (*ParentCommit) ProtoMessage()
- func (x *ParentCommit) ProtoReflect() protoreflect.Message
- func (x *ParentCommit) Reset()
- func (x *ParentCommit) String() string
- type ParentHashes
- type Ref
- type RefName
- func (*RefName) Descriptor() ([]byte, []int)deprecated
- func (x *RefName) GetBranch() string
- func (x *RefName) GetDatasetId() isRefName_DatasetId
- func (x *RefName) GetDatasetIri() string
- func (x *RefName) GetDatasetUuid() []byte
- func (x *RefName) GetLeaf() []byte
- func (x *RefName) GetRefName() isRefName_RefName
- func (*RefName) ProtoMessage()
- func (x *RefName) ProtoReflect() protoreflect.Message
- func (x *RefName) Reset()
- func (x *RefName) String() string
- type RefName_Branch
- type RefName_DatasetIri
- type RefName_DatasetUuid
- type RefName_Leaf
- type RefServiceClient
- type RefServiceServer
- type RefService_GetRefClient
- type RefService_GetRefServer
- type RemoveBranchRequest
- func (*RemoveBranchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveBranchRequest) GetBranch() string
- func (x *RemoveBranchRequest) GetRepoName() string
- func (x *RemoveBranchRequest) GetUuid() []byte
- func (*RemoveBranchRequest) ProtoMessage()
- func (x *RemoveBranchRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveBranchRequest) Reset()
- func (x *RemoveBranchRequest) String() string
- type RemoveBranchResponse
- type RepoManagerServiceClient
- type RepoManagerServiceServer
- type RepositoryLogEntry
- func (*RepositoryLogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *RepositoryLogEntry) GetFields() map[string]string
- func (x *RepositoryLogEntry) GetLogKey() uint64
- func (*RepositoryLogEntry) ProtoMessage()
- func (x *RepositoryLogEntry) ProtoReflect() protoreflect.Message
- func (x *RepositoryLogEntry) Reset()
- func (x *RepositoryLogEntry) String() string
- type SetBranchRequest
- func (*SetBranchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetBranchRequest) GetBranch() string
- func (x *SetBranchRequest) GetCommitHash() []byte
- func (x *SetBranchRequest) GetRepoName() string
- func (x *SetBranchRequest) GetUuid() []byte
- func (*SetBranchRequest) ProtoMessage()
- func (x *SetBranchRequest) ProtoReflect() protoreflect.Message
- func (x *SetBranchRequest) Reset()
- func (x *SetBranchRequest) String() string
- type SetBranchResponse
- type SyncFromBucketData
- func (*SyncFromBucketData) Descriptor() ([]byte, []int)deprecated
- func (x *SyncFromBucketData) GetBucketName() string
- func (x *SyncFromBucketData) GetIsBucket() bool
- func (x *SyncFromBucketData) GetKey() []byte
- func (x *SyncFromBucketData) GetSubKey() []byte
- func (x *SyncFromBucketData) GetSubValue() []byte
- func (x *SyncFromBucketData) GetValue() []byte
- func (*SyncFromBucketData) ProtoMessage()
- func (x *SyncFromBucketData) ProtoReflect() protoreflect.Message
- func (x *SyncFromBucketData) Reset()
- func (x *SyncFromBucketData) String() string
- type SyncFromMetadata
- func (*SyncFromMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *SyncFromMetadata) GetBranchName() string
- func (x *SyncFromMetadata) GetDatasetIds() [][]byte
- func (x *SyncFromMetadata) GetRepoName() string
- func (*SyncFromMetadata) ProtoMessage()
- func (x *SyncFromMetadata) ProtoReflect() protoreflect.Message
- func (x *SyncFromMetadata) Reset()
- func (x *SyncFromMetadata) String() string
- type SyncFromRequest
- func (*SyncFromRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncFromRequest) GetBucketData() *SyncFromBucketData
- func (x *SyncFromRequest) GetData() isSyncFromRequest_Data
- func (x *SyncFromRequest) GetMetadata() *SyncFromMetadata
- func (*SyncFromRequest) ProtoMessage()
- func (x *SyncFromRequest) ProtoReflect() protoreflect.Message
- func (x *SyncFromRequest) Reset()
- func (x *SyncFromRequest) String() string
- type SyncFromRequest_BucketData
- type SyncFromRequest_Metadata
- type SyncFromResponse
- func (*SyncFromResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncFromResponse) GetCommitsSynced() int32
- func (x *SyncFromResponse) GetDatasetRevisionsSynced() int32
- func (x *SyncFromResponse) GetDatasetsSynced() int32
- func (x *SyncFromResponse) GetDocumentInfoSynced() int32
- func (x *SyncFromResponse) GetNamedGraphRevisionsSynced() int32
- func (*SyncFromResponse) ProtoMessage()
- func (x *SyncFromResponse) ProtoReflect() protoreflect.Message
- func (x *SyncFromResponse) Reset()
- func (x *SyncFromResponse) String() string
- type SyncToBucketData
- func (*SyncToBucketData) Descriptor() ([]byte, []int)deprecated
- func (x *SyncToBucketData) GetBucketName() string
- func (x *SyncToBucketData) GetIsBucket() bool
- func (x *SyncToBucketData) GetKey() []byte
- func (x *SyncToBucketData) GetSubKey() []byte
- func (x *SyncToBucketData) GetSubValue() []byte
- func (x *SyncToBucketData) GetValue() []byte
- func (*SyncToBucketData) ProtoMessage()
- func (x *SyncToBucketData) ProtoReflect() protoreflect.Message
- func (x *SyncToBucketData) Reset()
- func (x *SyncToBucketData) String() string
- type SyncToComplete
- func (*SyncToComplete) Descriptor() ([]byte, []int)deprecated
- func (x *SyncToComplete) GetCommitsSynced() int32
- func (x *SyncToComplete) GetDatasetRevisionsSynced() int32
- func (x *SyncToComplete) GetDatasetsSynced() int32
- func (x *SyncToComplete) GetDocumentInfoSynced() int32
- func (x *SyncToComplete) GetNamedGraphRevisionsSynced() int32
- func (*SyncToComplete) ProtoMessage()
- func (x *SyncToComplete) ProtoReflect() protoreflect.Message
- func (x *SyncToComplete) Reset()
- func (x *SyncToComplete) String() string
- type SyncToMetadata
- func (*SyncToMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *SyncToMetadata) GetBranchName() string
- func (x *SyncToMetadata) GetDatasetIds() [][]byte
- func (*SyncToMetadata) ProtoMessage()
- func (x *SyncToMetadata) ProtoReflect() protoreflect.Message
- func (x *SyncToMetadata) Reset()
- func (x *SyncToMetadata) String() string
- type SyncToRequest
- type SyncToResponse
- func (*SyncToResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncToResponse) GetBucketData() *SyncToBucketData
- func (x *SyncToResponse) GetComplete() *SyncToComplete
- func (x *SyncToResponse) GetData() isSyncToResponse_Data
- func (*SyncToResponse) ProtoMessage()
- func (x *SyncToResponse) ProtoReflect() protoreflect.Message
- func (x *SyncToResponse) Reset()
- func (x *SyncToResponse) String() string
- type SyncToResponse_BucketData
- type SyncToResponse_Complete
- type UnimplementedCommitServiceServer
- func (UnimplementedCommitServiceServer) CompareCommits(context.Context, *CompareCommitsRequest) (*CompareCommitsResponse, error)
- func (UnimplementedCommitServiceServer) CreateCommit(context.Context, *CreateCommitRequest) (*CreateCommitResponse, error)
- func (UnimplementedCommitServiceServer) GetCommit(grpc.ClientStreamingServer[GetCommitRequest, Commit]) error
- func (UnimplementedCommitServiceServer) GetCommitDetailsBatch(context.Context, *GetCommitDetailsBatchRequest) (*GetCommitDetailsBatchResponse, error)
- func (UnimplementedCommitServiceServer) ListCommits(grpc.ClientStreamingServer[ListCommitsRequest, ListCommitsResponse]) error
- type UnimplementedDatasetServiceServer
- func (UnimplementedDatasetServiceServer) CreateDataset(context.Context, *CreateDatasetRequest) (*Dataset, error)
- func (UnimplementedDatasetServiceServer) Document(*DocumentRequest, grpc.ServerStreamingServer[DocumentResponse]) error
- func (UnimplementedDatasetServiceServer) DocumentDelete(context.Context, *DocumentDeleteRequest) (*DocumentDeleteResponse, error)
- func (UnimplementedDatasetServiceServer) DocumentSet(grpc.ClientStreamingServer[DocumentSetRequest, DocumentSetResponse]) error
- func (UnimplementedDatasetServiceServer) Documents(context.Context, *DocumentsListRequest) (*DocumentsListResponse, error)
- func (UnimplementedDatasetServiceServer) DownloadNamedGraphRevision(*DownloadNamedGraphRevisionRequest, ...) error
- func (UnimplementedDatasetServiceServer) FetchDatasets(grpc.BidiStreamingServer[DatasetInquiry, DatasetObject]) error
- func (UnimplementedDatasetServiceServer) FindCommonParentRevision(context.Context, *FindCommonParentRevisionRequest) (*FindCommonParentRevisionResponse, error)
- func (UnimplementedDatasetServiceServer) GetBleveInfo(context.Context, *GetRepoBleveInfoRequest) (*GetRepoBleveInfoResponse, error)
- func (UnimplementedDatasetServiceServer) GetBranches(context.Context, *GetBranchesRequest) (*GetBranchesResponse, error)
- func (UnimplementedDatasetServiceServer) GetDataset(grpc.ClientStreamingServer[GetDatasetRequest, Dataset]) error
- func (UnimplementedDatasetServiceServer) GetLeafCommits(context.Context, *GetLeafCommitsRequest) (*GetLeafCommitsResponse, error)
- func (UnimplementedDatasetServiceServer) GetRepositoryInfo(context.Context, *GetRepositoryInfoRequest) (*GetRepositoryInfoResponse, error)
- func (UnimplementedDatasetServiceServer) GetRepositoryLog(context.Context, *GetRepositoryLogRequest) (*GetRepositoryLogResponse, error)
- func (UnimplementedDatasetServiceServer) ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
- func (UnimplementedDatasetServiceServer) PushDatasets(grpc.BidiStreamingServer[DatasetSuggestion, DatasetInquiry]) error
- func (UnimplementedDatasetServiceServer) RemoveBranch(context.Context, *RemoveBranchRequest) (*RemoveBranchResponse, error)
- func (UnimplementedDatasetServiceServer) SetBranch(context.Context, *SetBranchRequest) (*SetBranchResponse, error)
- func (UnimplementedDatasetServiceServer) SyncFrom(grpc.ClientStreamingServer[SyncFromRequest, SyncFromResponse]) error
- func (UnimplementedDatasetServiceServer) SyncTo(*SyncToRequest, grpc.ServerStreamingServer[SyncToResponse]) error
- type UnimplementedRefServiceServer
- type UnimplementedRepoManagerServiceServer
- func (UnimplementedRepoManagerServiceServer) CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoReply, error)
- func (UnimplementedRepoManagerServiceServer) DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoReply, error)
- func (UnimplementedRepoManagerServiceServer) ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error)
- type UnsafeCommitServiceServer
- type UnsafeDatasetServiceServer
- type UnsafeRefServiceServer
- type UnsafeRepoManagerServiceServer
Constants ¶
const ( RepoManagerService_ListRepos_FullMethodName = "/sst.repository.RepoManagerService/ListRepos" RepoManagerService_CreateRepo_FullMethodName = "/sst.repository.RepoManagerService/CreateRepo" RepoManagerService_DeleteRepo_FullMethodName = "/sst.repository.RepoManagerService/DeleteRepo" )
const ( DatasetService_RemoveBranch_FullMethodName = "/sst.repository.DatasetService/RemoveBranch" DatasetService_SetBranch_FullMethodName = "/sst.repository.DatasetService/SetBranch" DatasetService_GetBranches_FullMethodName = "/sst.repository.DatasetService/GetBranches" DatasetService_GetLeafCommits_FullMethodName = "/sst.repository.DatasetService/GetLeafCommits" DatasetService_GetBleveInfo_FullMethodName = "/sst.repository.DatasetService/GetBleveInfo" DatasetService_ListDatasets_FullMethodName = "/sst.repository.DatasetService/ListDatasets" DatasetService_GetDataset_FullMethodName = "/sst.repository.DatasetService/GetDataset" DatasetService_CreateDataset_FullMethodName = "/sst.repository.DatasetService/CreateDataset" DatasetService_FetchDatasets_FullMethodName = "/sst.repository.DatasetService/FetchDatasets" DatasetService_PushDatasets_FullMethodName = "/sst.repository.DatasetService/PushDatasets" DatasetService_GetRepositoryInfo_FullMethodName = "/sst.repository.DatasetService/GetRepositoryInfo" DatasetService_GetRepositoryLog_FullMethodName = "/sst.repository.DatasetService/GetRepositoryLog" DatasetService_DocumentSet_FullMethodName = "/sst.repository.DatasetService/DocumentSet" DatasetService_Document_FullMethodName = "/sst.repository.DatasetService/Document" DatasetService_Documents_FullMethodName = "/sst.repository.DatasetService/Documents" DatasetService_DocumentDelete_FullMethodName = "/sst.repository.DatasetService/DocumentDelete" DatasetService_DownloadNamedGraphRevision_FullMethodName = "/sst.repository.DatasetService/DownloadNamedGraphRevision" DatasetService_FindCommonParentRevision_FullMethodName = "/sst.repository.DatasetService/FindCommonParentRevision" DatasetService_SyncFrom_FullMethodName = "/sst.repository.DatasetService/SyncFrom" DatasetService_SyncTo_FullMethodName = "/sst.repository.DatasetService/SyncTo" )
const ( RefService_ListRefs_FullMethodName = "/sst.repository.RefService/ListRefs" RefService_GetRef_FullMethodName = "/sst.repository.RefService/GetRef" )
const ( CommitService_ListCommits_FullMethodName = "/sst.repository.CommitService/ListCommits" CommitService_GetCommit_FullMethodName = "/sst.repository.CommitService/GetCommit" CommitService_CreateCommit_FullMethodName = "/sst.repository.CommitService/CreateCommit" CommitService_CompareCommits_FullMethodName = "/sst.repository.CommitService/CompareCommits" CommitService_GetCommitDetailsBatch_FullMethodName = "/sst.repository.CommitService/GetCommitDetailsBatch" )
Variables ¶
var ( CreateCommitRequest_Flag_name = map[int32]string{ 0: "default", 1: "skipRootDataset", 2: "forbidDatasetBranchDivergence", 3: "createFirstLevelDatasetsOnly", } CreateCommitRequest_Flag_value = map[string]int32{ "default": 0, "skipRootDataset": 1, "forbidDatasetBranchDivergence": 2, "createFirstLevelDatasetsOnly": 3, } )
Enum value maps for CreateCommitRequest_Flag.
var CommitService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sst.repository.CommitService", HandlerType: (*CommitServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateCommit", Handler: _CommitService_CreateCommit_Handler, }, { MethodName: "CompareCommits", Handler: _CommitService_CompareCommits_Handler, }, { MethodName: "GetCommitDetailsBatch", Handler: _CommitService_GetCommitDetailsBatch_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ListCommits", Handler: _CommitService_ListCommits_Handler, ClientStreams: true, }, { StreamName: "GetCommit", Handler: _CommitService_GetCommit_Handler, ClientStreams: true, }, }, Metadata: "repository.proto", }
CommitService_ServiceDesc is the grpc.ServiceDesc for CommitService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DatasetService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sst.repository.DatasetService", HandlerType: (*DatasetServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RemoveBranch", Handler: _DatasetService_RemoveBranch_Handler, }, { MethodName: "SetBranch", Handler: _DatasetService_SetBranch_Handler, }, { MethodName: "GetBranches", Handler: _DatasetService_GetBranches_Handler, }, { MethodName: "GetLeafCommits", Handler: _DatasetService_GetLeafCommits_Handler, }, { MethodName: "GetBleveInfo", Handler: _DatasetService_GetBleveInfo_Handler, }, { MethodName: "ListDatasets", Handler: _DatasetService_ListDatasets_Handler, }, { MethodName: "CreateDataset", Handler: _DatasetService_CreateDataset_Handler, }, { MethodName: "GetRepositoryInfo", Handler: _DatasetService_GetRepositoryInfo_Handler, }, { MethodName: "GetRepositoryLog", Handler: _DatasetService_GetRepositoryLog_Handler, }, { MethodName: "Documents", Handler: _DatasetService_Documents_Handler, }, { MethodName: "DocumentDelete", Handler: _DatasetService_DocumentDelete_Handler, }, { MethodName: "FindCommonParentRevision", Handler: _DatasetService_FindCommonParentRevision_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetDataset", Handler: _DatasetService_GetDataset_Handler, ClientStreams: true, }, { StreamName: "FetchDatasets", Handler: _DatasetService_FetchDatasets_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "PushDatasets", Handler: _DatasetService_PushDatasets_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "DocumentSet", Handler: _DatasetService_DocumentSet_Handler, ClientStreams: true, }, { StreamName: "Document", Handler: _DatasetService_Document_Handler, ServerStreams: true, }, { StreamName: "DownloadNamedGraphRevision", Handler: _DatasetService_DownloadNamedGraphRevision_Handler, ServerStreams: true, }, { StreamName: "SyncFrom", Handler: _DatasetService_SyncFrom_Handler, ClientStreams: true, }, { StreamName: "SyncTo", Handler: _DatasetService_SyncTo_Handler, ServerStreams: true, }, }, Metadata: "repository.proto", }
DatasetService_ServiceDesc is the grpc.ServiceDesc for DatasetService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_repository_proto protoreflect.FileDescriptor
var RefService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sst.repository.RefService", HandlerType: (*RefServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListRefs", Handler: _RefService_ListRefs_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetRef", Handler: _RefService_GetRef_Handler, ClientStreams: true, }, }, Metadata: "repository.proto", }
RefService_ServiceDesc is the grpc.ServiceDesc for RefService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var RepoManagerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sst.repository.RepoManagerService", HandlerType: (*RepoManagerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListRepos", Handler: _RepoManagerService_ListRepos_Handler, }, { MethodName: "CreateRepo", Handler: _RepoManagerService_CreateRepo_Handler, }, { MethodName: "DeleteRepo", Handler: _RepoManagerService_DeleteRepo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "repository.proto", }
RepoManagerService_ServiceDesc is the grpc.ServiceDesc for RepoManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func DatasetReadUUID ¶
func DatasetReadUUID() *fieldmaskpb.FieldMask
func RegisterCommitServiceServer ¶
func RegisterCommitServiceServer(s grpc.ServiceRegistrar, srv CommitServiceServer)
func RegisterDatasetServiceServer ¶
func RegisterDatasetServiceServer(s grpc.ServiceRegistrar, srv DatasetServiceServer)
func RegisterRefServiceServer ¶
func RegisterRefServiceServer(s grpc.ServiceRegistrar, srv RefServiceServer)
func RegisterRepoManagerServiceServer ¶
func RegisterRepoManagerServiceServer(s grpc.ServiceRegistrar, srv RepoManagerServiceServer)
Types ¶
type BareRefName ¶
type BareRefName = isRefName_RefName
type BranchRef ¶
type BranchRef struct {
Branch string `protobuf:"bytes,1,opt,name=branch,proto3" json:"branch,omitempty"`
CommitHash []byte `protobuf:"bytes,2,opt,name=commitHash,proto3" json:"commitHash,omitempty"`
// contains filtered or unexported fields
}
func (*BranchRef) Descriptor
deprecated
func (*BranchRef) GetCommitHash ¶
func (*BranchRef) ProtoMessage ¶
func (*BranchRef) ProtoMessage()
func (*BranchRef) ProtoReflect ¶
func (x *BranchRef) ProtoReflect() protoreflect.Message
type Commit ¶
type Commit struct {
CommitId []byte `protobuf:"bytes,1,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
Datasets []*CommittedDatasetRevision `protobuf:"bytes,2,rep,name=datasets,proto3" json:"datasets,omitempty"`
NamedGraphs []*CommittedNamedGraphRevision `protobuf:"bytes,3,rep,name=namedGraphs,proto3" json:"namedGraphs,omitempty"`
AuthorUri string `protobuf:"bytes,4,opt,name=author_uri,json=authorUri,proto3" json:"author_uri,omitempty"`
AuthorTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=author_timestamp,json=authorTimestamp,proto3" json:"author_timestamp,omitempty"`
// string committer_uri = 6;
// google.protobuf.Timestamp committer_timestamp = 7;
//
// Types that are valid to be assigned to MessageOrReason:
//
// *Commit_Message
// *Commit_Reason
MessageOrReason isCommit_MessageOrReason `protobuf_oneof:"message_or_reason"`
// contains filtered or unexported fields
}
func (*Commit) Descriptor
deprecated
func (*Commit) GetAuthorTimestamp ¶
func (x *Commit) GetAuthorTimestamp() *timestamppb.Timestamp
func (*Commit) GetAuthorUri ¶
func (*Commit) GetCommitId ¶
func (*Commit) GetDatasets ¶
func (x *Commit) GetDatasets() []*CommittedDatasetRevision
func (*Commit) GetMessage ¶
func (*Commit) GetMessageOrReason ¶
func (x *Commit) GetMessageOrReason() isCommit_MessageOrReason
func (*Commit) GetNamedGraphs ¶
func (x *Commit) GetNamedGraphs() []*CommittedNamedGraphRevision
func (*Commit) ProtoMessage ¶
func (*Commit) ProtoMessage()
func (*Commit) ProtoReflect ¶
func (x *Commit) ProtoReflect() protoreflect.Message
type CommitDetail ¶
type CommitDetail struct {
CommitId []byte `protobuf:"bytes,1,opt,name=CommitId,proto3" json:"CommitId,omitempty"` // Commit hash
Author string `protobuf:"bytes,2,opt,name=Author,proto3" json:"Author,omitempty"` // Commit author
Message string `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"` // Commit message
Timestamp int64 `protobuf:"varint,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"` // Commit time (Unix timestamp)
ParentCommits map[string]*ParentHashes `` // map<DatasetID string, list of parent commit hash>
/* 153-byte string literal not displayed */
DatasetRevisions map[string][]byte `` // UUID string → DS Hash
/* 159-byte string literal not displayed */
NamedGraphRevisions map[string][]byte `` // UUID string → NG Hash
/* 165-byte string literal not displayed */
// contains filtered or unexported fields
}
A single commit detail
func (*CommitDetail) Descriptor
deprecated
func (*CommitDetail) Descriptor() ([]byte, []int)
Deprecated: Use CommitDetail.ProtoReflect.Descriptor instead.
func (*CommitDetail) GetAuthor ¶
func (x *CommitDetail) GetAuthor() string
func (*CommitDetail) GetCommitId ¶
func (x *CommitDetail) GetCommitId() []byte
func (*CommitDetail) GetDatasetRevisions ¶
func (x *CommitDetail) GetDatasetRevisions() map[string][]byte
func (*CommitDetail) GetMessage ¶
func (x *CommitDetail) GetMessage() string
func (*CommitDetail) GetNamedGraphRevisions ¶
func (x *CommitDetail) GetNamedGraphRevisions() map[string][]byte
func (*CommitDetail) GetParentCommits ¶
func (x *CommitDetail) GetParentCommits() map[string]*ParentHashes
func (*CommitDetail) GetTimestamp ¶
func (x *CommitDetail) GetTimestamp() int64
func (*CommitDetail) ProtoMessage ¶
func (*CommitDetail) ProtoMessage()
func (*CommitDetail) ProtoReflect ¶
func (x *CommitDetail) ProtoReflect() protoreflect.Message
func (*CommitDetail) Reset ¶
func (x *CommitDetail) Reset()
func (*CommitDetail) String ¶
func (x *CommitDetail) String() string
type CommitServiceClient ¶
type CommitServiceClient interface {
ListCommits(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ListCommitsRequest, ListCommitsResponse], error)
GetCommit(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[GetCommitRequest, Commit], error)
CreateCommit(ctx context.Context, in *CreateCommitRequest, opts ...grpc.CallOption) (*CreateCommitResponse, error)
CompareCommits(ctx context.Context, in *CompareCommitsRequest, opts ...grpc.CallOption) (*CompareCommitsResponse, error)
GetCommitDetailsBatch(ctx context.Context, in *GetCommitDetailsBatchRequest, opts ...grpc.CallOption) (*GetCommitDetailsBatchResponse, error)
}
CommitServiceClient is the client API for CommitService 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 NewCommitServiceClient ¶
func NewCommitServiceClient(cc grpc.ClientConnInterface) CommitServiceClient
type CommitServiceServer ¶
type CommitServiceServer interface {
ListCommits(grpc.ClientStreamingServer[ListCommitsRequest, ListCommitsResponse]) error
GetCommit(grpc.ClientStreamingServer[GetCommitRequest, Commit]) error
CreateCommit(context.Context, *CreateCommitRequest) (*CreateCommitResponse, error)
CompareCommits(context.Context, *CompareCommitsRequest) (*CompareCommitsResponse, error)
GetCommitDetailsBatch(context.Context, *GetCommitDetailsBatchRequest) (*GetCommitDetailsBatchResponse, error)
// contains filtered or unexported methods
}
CommitServiceServer is the server API for CommitService service. All implementations must embed UnimplementedCommitServiceServer for forward compatibility.
type CommitService_GetCommitClient ¶
type CommitService_GetCommitClient = grpc.ClientStreamingClient[GetCommitRequest, Commit]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CommitService_GetCommitServer ¶
type CommitService_GetCommitServer = grpc.ClientStreamingServer[GetCommitRequest, Commit]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CommitService_ListCommitsClient ¶
type CommitService_ListCommitsClient = grpc.ClientStreamingClient[ListCommitsRequest, ListCommitsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CommitService_ListCommitsServer ¶
type CommitService_ListCommitsServer = grpc.ClientStreamingServer[ListCommitsRequest, ListCommitsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Commit_Message ¶
type Commit_Message struct {
Message string `protobuf:"bytes,8,opt,name=message,proto3,oneof"`
}
type Commit_MessageOrReason ¶
type Commit_MessageOrReason = isCommit_MessageOrReason //nolint:revive
type Commit_Reason ¶
type Commit_Reason struct {
Reason string `protobuf:"bytes,9,opt,name=reason,proto3,oneof"`
}
type CommittedDatasetRevision ¶
type CommittedDatasetRevision struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3" json:"dataset_uuid,omitempty"`
DatasetHash []byte `protobuf:"bytes,2,opt,name=dataset_hash,json=datasetHash,proto3" json:"dataset_hash,omitempty"`
ParentCommitIds [][]byte `protobuf:"bytes,3,rep,name=parent_commit_ids,json=parentCommitIds,proto3" json:"parent_commit_ids,omitempty"`
// contains filtered or unexported fields
}
func (*CommittedDatasetRevision) Descriptor
deprecated
func (*CommittedDatasetRevision) Descriptor() ([]byte, []int)
Deprecated: Use CommittedDatasetRevision.ProtoReflect.Descriptor instead.
func (*CommittedDatasetRevision) GetDatasetHash ¶
func (x *CommittedDatasetRevision) GetDatasetHash() []byte
func (*CommittedDatasetRevision) GetDatasetUuid ¶
func (x *CommittedDatasetRevision) GetDatasetUuid() []byte
func (*CommittedDatasetRevision) GetParentCommitIds ¶
func (x *CommittedDatasetRevision) GetParentCommitIds() [][]byte
func (*CommittedDatasetRevision) ProtoMessage ¶
func (*CommittedDatasetRevision) ProtoMessage()
func (*CommittedDatasetRevision) ProtoReflect ¶
func (x *CommittedDatasetRevision) ProtoReflect() protoreflect.Message
func (*CommittedDatasetRevision) Reset ¶
func (x *CommittedDatasetRevision) Reset()
func (*CommittedDatasetRevision) String ¶
func (x *CommittedDatasetRevision) String() string
type CommittedNamedGraphRevision ¶
type CommittedNamedGraphRevision struct {
NamedGraphUuid []byte `protobuf:"bytes,1,opt,name=namedGraph_uuid,json=namedGraphUuid,proto3" json:"namedGraph_uuid,omitempty"`
NamedGraphHash []byte `protobuf:"bytes,2,opt,name=namedGraph_hash,json=namedGraphHash,proto3" json:"namedGraph_hash,omitempty"`
// contains filtered or unexported fields
}
func (*CommittedNamedGraphRevision) Descriptor
deprecated
func (*CommittedNamedGraphRevision) Descriptor() ([]byte, []int)
Deprecated: Use CommittedNamedGraphRevision.ProtoReflect.Descriptor instead.
func (*CommittedNamedGraphRevision) GetNamedGraphHash ¶
func (x *CommittedNamedGraphRevision) GetNamedGraphHash() []byte
func (*CommittedNamedGraphRevision) GetNamedGraphUuid ¶
func (x *CommittedNamedGraphRevision) GetNamedGraphUuid() []byte
func (*CommittedNamedGraphRevision) ProtoMessage ¶
func (*CommittedNamedGraphRevision) ProtoMessage()
func (*CommittedNamedGraphRevision) ProtoReflect ¶
func (x *CommittedNamedGraphRevision) ProtoReflect() protoreflect.Message
func (*CommittedNamedGraphRevision) Reset ¶
func (x *CommittedNamedGraphRevision) Reset()
func (*CommittedNamedGraphRevision) String ¶
func (x *CommittedNamedGraphRevision) String() string
type CompareCommitsRequest ¶
type CompareCommitsRequest struct {
DatasetCommitPair []*CompareCommitsRequest_DatasetCommitPair `protobuf:"bytes,1,rep,name=dataset_commit_pair,json=datasetCommitPair,proto3" json:"dataset_commit_pair,omitempty"`
RepoName string `protobuf:"bytes,4,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*CompareCommitsRequest) Descriptor
deprecated
func (*CompareCommitsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompareCommitsRequest.ProtoReflect.Descriptor instead.
func (*CompareCommitsRequest) GetDatasetCommitPair ¶
func (x *CompareCommitsRequest) GetDatasetCommitPair() []*CompareCommitsRequest_DatasetCommitPair
func (*CompareCommitsRequest) GetRepoName ¶
func (x *CompareCommitsRequest) GetRepoName() string
func (*CompareCommitsRequest) ProtoMessage ¶
func (*CompareCommitsRequest) ProtoMessage()
func (*CompareCommitsRequest) ProtoReflect ¶
func (x *CompareCommitsRequest) ProtoReflect() protoreflect.Message
func (*CompareCommitsRequest) Reset ¶
func (x *CompareCommitsRequest) Reset()
func (*CompareCommitsRequest) String ¶
func (x *CompareCommitsRequest) String() string
type CompareCommitsRequest_DatasetCommitPair ¶
type CompareCommitsRequest_DatasetCommitPair struct {
DatasetId [][]byte `protobuf:"bytes,1,rep,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
Commit1 []byte `protobuf:"bytes,2,opt,name=commit1,proto3" json:"commit1,omitempty"`
Commit2 []byte `protobuf:"bytes,3,opt,name=commit2,proto3" json:"commit2,omitempty"`
// contains filtered or unexported fields
}
func (*CompareCommitsRequest_DatasetCommitPair) Descriptor
deprecated
func (*CompareCommitsRequest_DatasetCommitPair) Descriptor() ([]byte, []int)
Deprecated: Use CompareCommitsRequest_DatasetCommitPair.ProtoReflect.Descriptor instead.
func (*CompareCommitsRequest_DatasetCommitPair) GetCommit1 ¶
func (x *CompareCommitsRequest_DatasetCommitPair) GetCommit1() []byte
func (*CompareCommitsRequest_DatasetCommitPair) GetCommit2 ¶
func (x *CompareCommitsRequest_DatasetCommitPair) GetCommit2() []byte
func (*CompareCommitsRequest_DatasetCommitPair) GetDatasetId ¶
func (x *CompareCommitsRequest_DatasetCommitPair) GetDatasetId() [][]byte
func (*CompareCommitsRequest_DatasetCommitPair) ProtoMessage ¶
func (*CompareCommitsRequest_DatasetCommitPair) ProtoMessage()
func (*CompareCommitsRequest_DatasetCommitPair) ProtoReflect ¶
func (x *CompareCommitsRequest_DatasetCommitPair) ProtoReflect() protoreflect.Message
func (*CompareCommitsRequest_DatasetCommitPair) Reset ¶
func (x *CompareCommitsRequest_DatasetCommitPair) Reset()
func (*CompareCommitsRequest_DatasetCommitPair) String ¶
func (x *CompareCommitsRequest_DatasetCommitPair) String() string
type CompareCommitsResponse ¶
type CompareCommitsResponse struct {
// relationship_and_count consists of relationship+count sequence as byte values
// relationship corresponds to storagerepo.CommitRelationship and is one of:
//
// 0 - commits are unrelated;
// 1 - commit2 is older than commit1;
// 2 - commit2 is same as commit1;
// 3 - commit2 is newer than commit1;
//
// count denotes the number of datasets from the request the relationship applies to.
RelationshipAndCount []byte `protobuf:"bytes,1,opt,name=relationship_and_count,json=relationshipAndCount,proto3" json:"relationship_and_count,omitempty"`
// contains filtered or unexported fields
}
func (*CompareCommitsResponse) Descriptor
deprecated
func (*CompareCommitsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CompareCommitsResponse.ProtoReflect.Descriptor instead.
func (*CompareCommitsResponse) GetRelationshipAndCount ¶
func (x *CompareCommitsResponse) GetRelationshipAndCount() []byte
func (*CompareCommitsResponse) ProtoMessage ¶
func (*CompareCommitsResponse) ProtoMessage()
func (*CompareCommitsResponse) ProtoReflect ¶
func (x *CompareCommitsResponse) ProtoReflect() protoreflect.Message
func (*CompareCommitsResponse) Reset ¶
func (x *CompareCommitsResponse) Reset()
func (*CompareCommitsResponse) String ¶
func (x *CompareCommitsResponse) String() string
type CreateCommitRequest ¶
type CreateCommitRequest struct {
RefName *RefName `protobuf:"bytes,1,opt,name=ref_name,json=refName,proto3" json:"ref_name,omitempty"`
BaseCommit []byte `protobuf:"bytes,2,opt,name=base_commit,json=baseCommit,proto3" json:"base_commit,omitempty"`
NamedGraphs [][]byte `protobuf:"bytes,3,rep,name=named_graphs,json=namedGraphs,proto3" json:"named_graphs,omitempty"`
ParentCommitOverrides []*ParentCommit `` /* 126-byte string literal not displayed */
Flags []CreateCommitRequest_Flag `protobuf:"varint,5,rep,packed,name=flags,proto3,enum=sst.repository.CreateCommitRequest_Flag" json:"flags,omitempty"`
Message string `protobuf:"bytes,8,opt,name=message,proto3" json:"message,omitempty"`
ModifiedNGs [][]byte `protobuf:"bytes,9,rep,name=modifiedNGs,proto3" json:"modifiedNGs,omitempty"`
CheckoutNamedGraphSignatures []*NamedGraphSignature `protobuf:"bytes,10,rep,name=CheckoutNamedGraphSignatures,proto3" json:"CheckoutNamedGraphSignatures,omitempty"`
CheckoutDatasetSignatures []*DatasetSignature `protobuf:"bytes,11,rep,name=CheckoutDatasetSignatures,proto3" json:"CheckoutDatasetSignatures,omitempty"`
RepoName string `protobuf:"bytes,12,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*CreateCommitRequest) Descriptor
deprecated
func (*CreateCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateCommitRequest.ProtoReflect.Descriptor instead.
func (*CreateCommitRequest) GetBaseCommit ¶
func (x *CreateCommitRequest) GetBaseCommit() []byte
func (*CreateCommitRequest) GetCheckoutDatasetSignatures ¶
func (x *CreateCommitRequest) GetCheckoutDatasetSignatures() []*DatasetSignature
func (*CreateCommitRequest) GetCheckoutNamedGraphSignatures ¶
func (x *CreateCommitRequest) GetCheckoutNamedGraphSignatures() []*NamedGraphSignature
func (*CreateCommitRequest) GetFlags ¶
func (x *CreateCommitRequest) GetFlags() []CreateCommitRequest_Flag
func (*CreateCommitRequest) GetMessage ¶
func (x *CreateCommitRequest) GetMessage() string
func (*CreateCommitRequest) GetModifiedNGs ¶
func (x *CreateCommitRequest) GetModifiedNGs() [][]byte
func (*CreateCommitRequest) GetNamedGraphs ¶
func (x *CreateCommitRequest) GetNamedGraphs() [][]byte
func (*CreateCommitRequest) GetParentCommitOverrides ¶
func (x *CreateCommitRequest) GetParentCommitOverrides() []*ParentCommit
func (*CreateCommitRequest) GetRefName ¶
func (x *CreateCommitRequest) GetRefName() *RefName
func (*CreateCommitRequest) GetRepoName ¶
func (x *CreateCommitRequest) GetRepoName() string
func (*CreateCommitRequest) ProtoMessage ¶
func (*CreateCommitRequest) ProtoMessage()
func (*CreateCommitRequest) ProtoReflect ¶
func (x *CreateCommitRequest) ProtoReflect() protoreflect.Message
func (*CreateCommitRequest) Reset ¶
func (x *CreateCommitRequest) Reset()
func (*CreateCommitRequest) String ¶
func (x *CreateCommitRequest) String() string
type CreateCommitRequest_Flag ¶
type CreateCommitRequest_Flag int32
const ( CreateCommitRequest_default CreateCommitRequest_Flag = 0 CreateCommitRequest_skipRootDataset CreateCommitRequest_Flag = 1 CreateCommitRequest_forbidDatasetBranchDivergence CreateCommitRequest_Flag = 2 CreateCommitRequest_createFirstLevelDatasetsOnly CreateCommitRequest_Flag = 3 )
func (CreateCommitRequest_Flag) Descriptor ¶
func (CreateCommitRequest_Flag) Descriptor() protoreflect.EnumDescriptor
func (CreateCommitRequest_Flag) Enum ¶
func (x CreateCommitRequest_Flag) Enum() *CreateCommitRequest_Flag
func (CreateCommitRequest_Flag) EnumDescriptor
deprecated
func (CreateCommitRequest_Flag) EnumDescriptor() ([]byte, []int)
Deprecated: Use CreateCommitRequest_Flag.Descriptor instead.
func (CreateCommitRequest_Flag) Number ¶
func (x CreateCommitRequest_Flag) Number() protoreflect.EnumNumber
func (CreateCommitRequest_Flag) String ¶
func (x CreateCommitRequest_Flag) String() string
func (CreateCommitRequest_Flag) Type ¶
func (CreateCommitRequest_Flag) Type() protoreflect.EnumType
type CreateCommitResponse ¶
type CreateCommitResponse struct {
CommitId []byte `protobuf:"bytes,1,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
CheckoutNamedGraphSignatures []*NamedGraphSignature `protobuf:"bytes,2,rep,name=CheckoutNamedGraphSignatures,proto3" json:"CheckoutNamedGraphSignatures,omitempty"`
CheckoutDatasetSignatures []*DatasetSignature `protobuf:"bytes,3,rep,name=CheckoutDatasetSignatures,proto3" json:"CheckoutDatasetSignatures,omitempty"`
ModifiedDatasets [][]byte `protobuf:"bytes,4,rep,name=modifiedDatasets,proto3" json:"modifiedDatasets,omitempty"`
// contains filtered or unexported fields
}
func (*CreateCommitResponse) Descriptor
deprecated
func (*CreateCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateCommitResponse.ProtoReflect.Descriptor instead.
func (*CreateCommitResponse) GetCheckoutDatasetSignatures ¶
func (x *CreateCommitResponse) GetCheckoutDatasetSignatures() []*DatasetSignature
func (*CreateCommitResponse) GetCheckoutNamedGraphSignatures ¶
func (x *CreateCommitResponse) GetCheckoutNamedGraphSignatures() []*NamedGraphSignature
func (*CreateCommitResponse) GetCommitId ¶
func (x *CreateCommitResponse) GetCommitId() []byte
func (*CreateCommitResponse) GetModifiedDatasets ¶
func (x *CreateCommitResponse) GetModifiedDatasets() [][]byte
func (*CreateCommitResponse) ProtoMessage ¶
func (*CreateCommitResponse) ProtoMessage()
func (*CreateCommitResponse) ProtoReflect ¶
func (x *CreateCommitResponse) ProtoReflect() protoreflect.Message
func (*CreateCommitResponse) Reset ¶
func (x *CreateCommitResponse) Reset()
func (*CreateCommitResponse) String ¶
func (x *CreateCommitResponse) String() string
type CreateDatasetRequest ¶
type CreateDatasetRequest struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3" json:"dataset_uuid,omitempty"`
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// contains filtered or unexported fields
}
func (*CreateDatasetRequest) Descriptor
deprecated
func (*CreateDatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDatasetRequest.ProtoReflect.Descriptor instead.
func (*CreateDatasetRequest) FieldMask_Filter ¶
func (x *CreateDatasetRequest) FieldMask_Filter() *CreateDatasetRequest_FieldMask
FieldMask_Filter generates *CreateDatasetRequest_FieldMask with filter mode, so that only the fields in the CreateDatasetRequest.ReadMask will be appended into the CreateDatasetRequest.
func (*CreateDatasetRequest) FieldMask_Prune ¶
func (x *CreateDatasetRequest) FieldMask_Prune() *CreateDatasetRequest_FieldMask
FieldMask_Prune generates *CreateDatasetRequest_FieldMask with prune mode, so that only the fields NOT in the CreateDatasetRequest.ReadMask will be appended into the CreateDatasetRequest.
func (*CreateDatasetRequest) GetDatasetUuid ¶
func (x *CreateDatasetRequest) GetDatasetUuid() []byte
func (*CreateDatasetRequest) GetReadMask ¶
func (x *CreateDatasetRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*CreateDatasetRequest) MaskOut_Iri ¶
func (x *CreateDatasetRequest) MaskOut_Iri() *CreateDatasetRequest
MaskOut_Iri append Dataset.Iri into CreateDatasetRequest.ReadMask.
func (*CreateDatasetRequest) MaskOut_Uuid ¶
func (x *CreateDatasetRequest) MaskOut_Uuid() *CreateDatasetRequest
MaskOut_Uuid append Dataset.Uuid into CreateDatasetRequest.ReadMask.
func (*CreateDatasetRequest) ProtoMessage ¶
func (*CreateDatasetRequest) ProtoMessage()
func (*CreateDatasetRequest) ProtoReflect ¶
func (x *CreateDatasetRequest) ProtoReflect() protoreflect.Message
func (*CreateDatasetRequest) Reset ¶
func (x *CreateDatasetRequest) Reset()
func (*CreateDatasetRequest) String ¶
func (x *CreateDatasetRequest) String() string
type CreateDatasetRequest_FieldMask ¶
type CreateDatasetRequest_FieldMask struct {
// contains filtered or unexported fields
}
CreateDatasetRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*CreateDatasetRequest_FieldMask) Mask ¶
func (x *CreateDatasetRequest_FieldMask) Mask(m *Dataset) *Dataset
Mask only affects the fields in the CreateDatasetRequest.
func (*CreateDatasetRequest_FieldMask) MaskedOut_Iri ¶
func (x *CreateDatasetRequest_FieldMask) MaskedOut_Iri() bool
MaskedOut_Iri indicates the field CreateDatasetRequest.Iri exists in the CreateDatasetRequest.ReadMask or not.
func (*CreateDatasetRequest_FieldMask) MaskedOut_Uuid ¶
func (x *CreateDatasetRequest_FieldMask) MaskedOut_Uuid() bool
MaskedOut_Uuid indicates the field CreateDatasetRequest.Uuid exists in the CreateDatasetRequest.ReadMask or not.
type CreateRepoReply ¶
type CreateRepoReply struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*CreateRepoReply) Descriptor
deprecated
func (*CreateRepoReply) Descriptor() ([]byte, []int)
Deprecated: Use CreateRepoReply.ProtoReflect.Descriptor instead.
func (*CreateRepoReply) GetName ¶
func (x *CreateRepoReply) GetName() string
func (*CreateRepoReply) ProtoMessage ¶
func (*CreateRepoReply) ProtoMessage()
func (*CreateRepoReply) ProtoReflect ¶
func (x *CreateRepoReply) ProtoReflect() protoreflect.Message
func (*CreateRepoReply) Reset ¶
func (x *CreateRepoReply) Reset()
func (*CreateRepoReply) String ¶
func (x *CreateRepoReply) String() string
type CreateRepoRequest ¶
type CreateRepoRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*CreateRepoRequest) Descriptor
deprecated
func (*CreateRepoRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRepoRequest.ProtoReflect.Descriptor instead.
func (*CreateRepoRequest) GetName ¶
func (x *CreateRepoRequest) GetName() string
func (*CreateRepoRequest) ProtoMessage ¶
func (*CreateRepoRequest) ProtoMessage()
func (*CreateRepoRequest) ProtoReflect ¶
func (x *CreateRepoRequest) ProtoReflect() protoreflect.Message
func (*CreateRepoRequest) Reset ¶
func (x *CreateRepoRequest) Reset()
func (*CreateRepoRequest) String ¶
func (x *CreateRepoRequest) String() string
type Dataset ¶
type Dataset struct {
Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Iri *string `protobuf:"bytes,2,opt,name=iri,proto3,oneof" json:"iri,omitempty"` // eg. urn:uuid:...
// contains filtered or unexported fields
}
func (*Dataset) Descriptor
deprecated
func (*Dataset) ProtoMessage ¶
func (*Dataset) ProtoMessage()
func (*Dataset) ProtoReflect ¶
func (x *Dataset) ProtoReflect() protoreflect.Message
type DatasetInquiry ¶
type DatasetInquiry struct {
// When streaming has fields have to precede related want fields
//
// Types that are valid to be assigned to Inq:
//
// *DatasetInquiry_HasCommitIdWithParents
// *DatasetInquiry_HasCommitIdNoParents
// *DatasetInquiry_WantDatasetWithCommitParents
// *DatasetInquiry_WantDatasetNoCommitParents
// *DatasetInquiry_WantDatasetRevision
Inq isDatasetInquiry_Inq `protobuf_oneof:"inq"`
RepoName string `protobuf:"bytes,13,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
`DatasetInquiry` provides either the items client already has available on the client side or the items it wants to have available. Request pertains to single identified Dataset where the revision is identified through a commit or a branch. Use case of single identified NamedGraphRevision should be considered.
func (*DatasetInquiry) Descriptor
deprecated
func (*DatasetInquiry) Descriptor() ([]byte, []int)
Deprecated: Use DatasetInquiry.ProtoReflect.Descriptor instead.
func (*DatasetInquiry) GetHasCommitIdNoParents ¶
func (x *DatasetInquiry) GetHasCommitIdNoParents() []byte
func (*DatasetInquiry) GetHasCommitIdWithParents ¶
func (x *DatasetInquiry) GetHasCommitIdWithParents() []byte
func (*DatasetInquiry) GetInq ¶
func (x *DatasetInquiry) GetInq() isDatasetInquiry_Inq
func (*DatasetInquiry) GetRepoName ¶
func (x *DatasetInquiry) GetRepoName() string
func (*DatasetInquiry) GetWantDatasetNoCommitParents ¶
func (x *DatasetInquiry) GetWantDatasetNoCommitParents() *RefName
func (*DatasetInquiry) GetWantDatasetRevision ¶
func (x *DatasetInquiry) GetWantDatasetRevision() []byte
func (*DatasetInquiry) GetWantDatasetWithCommitParents ¶
func (x *DatasetInquiry) GetWantDatasetWithCommitParents() *RefName
func (*DatasetInquiry) ProtoMessage ¶
func (*DatasetInquiry) ProtoMessage()
func (*DatasetInquiry) ProtoReflect ¶
func (x *DatasetInquiry) ProtoReflect() protoreflect.Message
func (*DatasetInquiry) Reset ¶
func (x *DatasetInquiry) Reset()
func (*DatasetInquiry) String ¶
func (x *DatasetInquiry) String() string
type DatasetInquiry_HasCommitIdNoParents ¶
type DatasetInquiry_HasCommitIdNoParents struct {
HasCommitIdNoParents []byte `protobuf:"bytes,2,opt,name=has_commit_id_no_parents,json=hasCommitIdNoParents,proto3,oneof"`
}
type DatasetInquiry_HasCommitIdWithParents ¶
type DatasetInquiry_HasCommitIdWithParents struct {
HasCommitIdWithParents []byte `protobuf:"bytes,1,opt,name=has_commit_id_with_parents,json=hasCommitIdWithParents,proto3,oneof"`
}
type DatasetInquiry_WantDatasetNoCommitParents ¶
type DatasetInquiry_WantDatasetNoCommitParents struct {
WantDatasetNoCommitParents *RefName `protobuf:"bytes,9,opt,name=want_dataset_no_commit_parents,json=wantDatasetNoCommitParents,proto3,oneof"`
}
type DatasetInquiry_WantDatasetRevision ¶
type DatasetInquiry_WantDatasetRevision struct {
WantDatasetRevision []byte `protobuf:"bytes,14,opt,name=want_dataset_revision,json=wantDatasetRevision,proto3,oneof"`
}
type DatasetInquiry_WantDatasetWithCommitParents ¶
type DatasetInquiry_WantDatasetWithCommitParents struct {
WantDatasetWithCommitParents *RefName `protobuf:"bytes,8,opt,name=want_dataset_with_commit_parents,json=wantDatasetWithCommitParents,proto3,oneof"`
}
type DatasetObject ¶
type DatasetObject struct {
// Types that are valid to be assigned to Obj:
//
// *DatasetObject_PendingCommitId
// *DatasetObject_NamedGraphRevision
// *DatasetObject_DatasetRevision
// *DatasetObject_Commit
// *DatasetObject_DatasetRevisionCommitHash
// *DatasetObject_WantedDatasetWithCommitParents
// *DatasetObject_WantedDatasetNoCommitParents
// *DatasetObject_WantedDatasetRevision
Obj isDatasetObject_Obj `protobuf_oneof:"obj"`
// contains filtered or unexported fields
}
DatasetObject represents streamed responses from Dataset fetch call.
func (*DatasetObject) Descriptor
deprecated
func (*DatasetObject) Descriptor() ([]byte, []int)
Deprecated: Use DatasetObject.ProtoReflect.Descriptor instead.
func (*DatasetObject) GetCommit ¶
func (x *DatasetObject) GetCommit() *Commit
func (*DatasetObject) GetDatasetRevision ¶
func (x *DatasetObject) GetDatasetRevision() *DatasetRevision
func (*DatasetObject) GetDatasetRevisionCommitHash ¶
func (x *DatasetObject) GetDatasetRevisionCommitHash() *DatasetRevisionToCommitHash
func (*DatasetObject) GetNamedGraphRevision ¶
func (x *DatasetObject) GetNamedGraphRevision() *NamedGraphRevision
func (*DatasetObject) GetObj ¶
func (x *DatasetObject) GetObj() isDatasetObject_Obj
func (*DatasetObject) GetPendingCommitId ¶
func (x *DatasetObject) GetPendingCommitId() []byte
func (*DatasetObject) GetWantedDatasetNoCommitParents ¶
func (x *DatasetObject) GetWantedDatasetNoCommitParents() *Ref
func (*DatasetObject) GetWantedDatasetRevision ¶
func (x *DatasetObject) GetWantedDatasetRevision() []byte
func (*DatasetObject) GetWantedDatasetWithCommitParents ¶
func (x *DatasetObject) GetWantedDatasetWithCommitParents() *Ref
func (*DatasetObject) ProtoMessage ¶
func (*DatasetObject) ProtoMessage()
func (*DatasetObject) ProtoReflect ¶
func (x *DatasetObject) ProtoReflect() protoreflect.Message
func (*DatasetObject) Reset ¶
func (x *DatasetObject) Reset()
func (*DatasetObject) String ¶
func (x *DatasetObject) String() string
type DatasetObject_Commit ¶
type DatasetObject_Commit struct {
Commit *Commit `protobuf:"bytes,4,opt,name=commit,proto3,oneof"`
}
type DatasetObject_DatasetRevision ¶
type DatasetObject_DatasetRevision struct {
DatasetRevision *DatasetRevision `protobuf:"bytes,3,opt,name=dataset_revision,json=datasetRevision,proto3,oneof"`
}
type DatasetObject_DatasetRevisionCommitHash ¶
type DatasetObject_DatasetRevisionCommitHash struct {
DatasetRevisionCommitHash *DatasetRevisionToCommitHash `protobuf:"bytes,5,opt,name=dataset_revision_commit_hash,json=datasetRevisionCommitHash,proto3,oneof"`
}
type DatasetObject_NamedGraphRevision ¶
type DatasetObject_NamedGraphRevision struct {
NamedGraphRevision *NamedGraphRevision `protobuf:"bytes,2,opt,name=named_graph_revision,json=namedGraphRevision,proto3,oneof"`
}
type DatasetObject_PendingCommitId ¶
type DatasetObject_PendingCommitId struct {
PendingCommitId []byte `protobuf:"bytes,1,opt,name=pending_commit_id,json=pendingCommitId,proto3,oneof"`
}
type DatasetObject_WantedDatasetNoCommitParents ¶
type DatasetObject_WantedDatasetNoCommitParents struct {
WantedDatasetNoCommitParents *Ref `protobuf:"bytes,9,opt,name=wanted_dataset_no_commit_parents,json=wantedDatasetNoCommitParents,proto3,oneof"`
}
type DatasetObject_WantedDatasetRevision ¶
type DatasetObject_WantedDatasetRevision struct {
WantedDatasetRevision []byte `protobuf:"bytes,14,opt,name=wanted_dataset_revision,json=wantedDatasetRevision,proto3,oneof"`
}
type DatasetObject_WantedDatasetWithCommitParents ¶
type DatasetObject_WantedDatasetWithCommitParents struct {
WantedDatasetWithCommitParents *Ref `protobuf:"bytes,8,opt,name=wanted_dataset_with_commit_parents,json=wantedDatasetWithCommitParents,proto3,oneof"`
}
type DatasetRevision ¶
type DatasetRevision struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
DefaultNamedGraphHash []byte `` /* 128-byte string literal not displayed */
ImportedDatasets []*DatasetRevision_Import `protobuf:"bytes,3,rep,name=imported_datasets,json=importedDatasets,proto3" json:"imported_datasets,omitempty"`
// contains filtered or unexported fields
}
func (*DatasetRevision) Descriptor
deprecated
func (*DatasetRevision) Descriptor() ([]byte, []int)
Deprecated: Use DatasetRevision.ProtoReflect.Descriptor instead.
func (*DatasetRevision) GetDefaultNamedGraphHash ¶
func (x *DatasetRevision) GetDefaultNamedGraphHash() []byte
func (*DatasetRevision) GetHash ¶
func (x *DatasetRevision) GetHash() []byte
func (*DatasetRevision) GetImportedDatasets ¶
func (x *DatasetRevision) GetImportedDatasets() []*DatasetRevision_Import
func (*DatasetRevision) ProtoMessage ¶
func (*DatasetRevision) ProtoMessage()
func (*DatasetRevision) ProtoReflect ¶
func (x *DatasetRevision) ProtoReflect() protoreflect.Message
func (*DatasetRevision) Reset ¶
func (x *DatasetRevision) Reset()
func (*DatasetRevision) String ¶
func (x *DatasetRevision) String() string
type DatasetRevisionToCommitHash ¶
type DatasetRevisionToCommitHash struct {
DatasetRevision []byte `protobuf:"bytes,1,opt,name=dataset_revision,json=datasetRevision,proto3" json:"dataset_revision,omitempty"`
CommitHash []byte `protobuf:"bytes,2,opt,name=commit_hash,json=commitHash,proto3" json:"commit_hash,omitempty"`
// contains filtered or unexported fields
}
func (*DatasetRevisionToCommitHash) Descriptor
deprecated
func (*DatasetRevisionToCommitHash) Descriptor() ([]byte, []int)
Deprecated: Use DatasetRevisionToCommitHash.ProtoReflect.Descriptor instead.
func (*DatasetRevisionToCommitHash) GetCommitHash ¶
func (x *DatasetRevisionToCommitHash) GetCommitHash() []byte
func (*DatasetRevisionToCommitHash) GetDatasetRevision ¶
func (x *DatasetRevisionToCommitHash) GetDatasetRevision() []byte
func (*DatasetRevisionToCommitHash) ProtoMessage ¶
func (*DatasetRevisionToCommitHash) ProtoMessage()
func (*DatasetRevisionToCommitHash) ProtoReflect ¶
func (x *DatasetRevisionToCommitHash) ProtoReflect() protoreflect.Message
func (*DatasetRevisionToCommitHash) Reset ¶
func (x *DatasetRevisionToCommitHash) Reset()
func (*DatasetRevisionToCommitHash) String ¶
func (x *DatasetRevisionToCommitHash) String() string
type DatasetRevision_Import ¶
type DatasetRevision_Import struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3" json:"dataset_uuid,omitempty"`
DatasetHash []byte `protobuf:"bytes,2,opt,name=dataset_hash,json=datasetHash,proto3" json:"dataset_hash,omitempty"`
// contains filtered or unexported fields
}
func (*DatasetRevision_Import) Descriptor
deprecated
func (*DatasetRevision_Import) Descriptor() ([]byte, []int)
Deprecated: Use DatasetRevision_Import.ProtoReflect.Descriptor instead.
func (*DatasetRevision_Import) GetDatasetHash ¶
func (x *DatasetRevision_Import) GetDatasetHash() []byte
func (*DatasetRevision_Import) GetDatasetUuid ¶
func (x *DatasetRevision_Import) GetDatasetUuid() []byte
func (*DatasetRevision_Import) ProtoMessage ¶
func (*DatasetRevision_Import) ProtoMessage()
func (*DatasetRevision_Import) ProtoReflect ¶
func (x *DatasetRevision_Import) ProtoReflect() protoreflect.Message
func (*DatasetRevision_Import) Reset ¶
func (x *DatasetRevision_Import) Reset()
func (*DatasetRevision_Import) String ¶
func (x *DatasetRevision_Import) String() string
type DatasetServiceClient ¶
type DatasetServiceClient interface {
RemoveBranch(ctx context.Context, in *RemoveBranchRequest, opts ...grpc.CallOption) (*RemoveBranchResponse, error)
SetBranch(ctx context.Context, in *SetBranchRequest, opts ...grpc.CallOption) (*SetBranchResponse, error)
GetBranches(ctx context.Context, in *GetBranchesRequest, opts ...grpc.CallOption) (*GetBranchesResponse, error)
GetLeafCommits(ctx context.Context, in *GetLeafCommitsRequest, opts ...grpc.CallOption) (*GetLeafCommitsResponse, error)
GetBleveInfo(ctx context.Context, in *GetRepoBleveInfoRequest, opts ...grpc.CallOption) (*GetRepoBleveInfoResponse, error)
ListDatasets(ctx context.Context, in *ListDatasetsRequest, opts ...grpc.CallOption) (*ListDatasetsResponse, error)
GetDataset(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[GetDatasetRequest, Dataset], error)
CreateDataset(ctx context.Context, in *CreateDatasetRequest, opts ...grpc.CallOption) (*Dataset, error)
FetchDatasets(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[DatasetInquiry, DatasetObject], error)
PushDatasets(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[DatasetSuggestion, DatasetInquiry], error)
GetRepositoryInfo(ctx context.Context, in *GetRepositoryInfoRequest, opts ...grpc.CallOption) (*GetRepositoryInfoResponse, error)
GetRepositoryLog(ctx context.Context, in *GetRepositoryLogRequest, opts ...grpc.CallOption) (*GetRepositoryLogResponse, error)
DocumentSet(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[DocumentSetRequest, DocumentSetResponse], error)
Document(ctx context.Context, in *DocumentRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DocumentResponse], error)
Documents(ctx context.Context, in *DocumentsListRequest, opts ...grpc.CallOption) (*DocumentsListResponse, error)
DocumentDelete(ctx context.Context, in *DocumentDeleteRequest, opts ...grpc.CallOption) (*DocumentDeleteResponse, error)
DownloadNamedGraphRevision(ctx context.Context, in *DownloadNamedGraphRevisionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DownloadNamedGraphRevisionResponse], error)
FindCommonParentRevision(ctx context.Context, in *FindCommonParentRevisionRequest, opts ...grpc.CallOption) (*FindCommonParentRevisionResponse, error)
SyncFrom(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SyncFromRequest, SyncFromResponse], error)
// SyncTo streams bucket data from server to client (for remote to local sync)
SyncTo(ctx context.Context, in *SyncToRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SyncToResponse], error)
}
DatasetServiceClient is the client API for DatasetService 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 NewDatasetServiceClient ¶
func NewDatasetServiceClient(cc grpc.ClientConnInterface) DatasetServiceClient
type DatasetServiceServer ¶
type DatasetServiceServer interface {
RemoveBranch(context.Context, *RemoveBranchRequest) (*RemoveBranchResponse, error)
SetBranch(context.Context, *SetBranchRequest) (*SetBranchResponse, error)
GetBranches(context.Context, *GetBranchesRequest) (*GetBranchesResponse, error)
GetLeafCommits(context.Context, *GetLeafCommitsRequest) (*GetLeafCommitsResponse, error)
GetBleveInfo(context.Context, *GetRepoBleveInfoRequest) (*GetRepoBleveInfoResponse, error)
ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
GetDataset(grpc.ClientStreamingServer[GetDatasetRequest, Dataset]) error
CreateDataset(context.Context, *CreateDatasetRequest) (*Dataset, error)
FetchDatasets(grpc.BidiStreamingServer[DatasetInquiry, DatasetObject]) error
PushDatasets(grpc.BidiStreamingServer[DatasetSuggestion, DatasetInquiry]) error
GetRepositoryInfo(context.Context, *GetRepositoryInfoRequest) (*GetRepositoryInfoResponse, error)
GetRepositoryLog(context.Context, *GetRepositoryLogRequest) (*GetRepositoryLogResponse, error)
DocumentSet(grpc.ClientStreamingServer[DocumentSetRequest, DocumentSetResponse]) error
Document(*DocumentRequest, grpc.ServerStreamingServer[DocumentResponse]) error
Documents(context.Context, *DocumentsListRequest) (*DocumentsListResponse, error)
DocumentDelete(context.Context, *DocumentDeleteRequest) (*DocumentDeleteResponse, error)
DownloadNamedGraphRevision(*DownloadNamedGraphRevisionRequest, grpc.ServerStreamingServer[DownloadNamedGraphRevisionResponse]) error
FindCommonParentRevision(context.Context, *FindCommonParentRevisionRequest) (*FindCommonParentRevisionResponse, error)
SyncFrom(grpc.ClientStreamingServer[SyncFromRequest, SyncFromResponse]) error
// SyncTo streams bucket data from server to client (for remote to local sync)
SyncTo(*SyncToRequest, grpc.ServerStreamingServer[SyncToResponse]) error
// contains filtered or unexported methods
}
DatasetServiceServer is the server API for DatasetService service. All implementations must embed UnimplementedDatasetServiceServer for forward compatibility.
type DatasetService_DocumentClient ¶
type DatasetService_DocumentClient = grpc.ServerStreamingClient[DocumentResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_DocumentServer ¶
type DatasetService_DocumentServer = grpc.ServerStreamingServer[DocumentResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_DocumentSetClient ¶
type DatasetService_DocumentSetClient = grpc.ClientStreamingClient[DocumentSetRequest, DocumentSetResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_DocumentSetServer ¶
type DatasetService_DocumentSetServer = grpc.ClientStreamingServer[DocumentSetRequest, DocumentSetResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_DownloadNamedGraphRevisionClient ¶
type DatasetService_DownloadNamedGraphRevisionClient = grpc.ServerStreamingClient[DownloadNamedGraphRevisionResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_DownloadNamedGraphRevisionServer ¶
type DatasetService_DownloadNamedGraphRevisionServer = grpc.ServerStreamingServer[DownloadNamedGraphRevisionResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_FetchDatasetsClient ¶
type DatasetService_FetchDatasetsClient = grpc.BidiStreamingClient[DatasetInquiry, DatasetObject]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_FetchDatasetsServer ¶
type DatasetService_FetchDatasetsServer = grpc.BidiStreamingServer[DatasetInquiry, DatasetObject]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_GetDatasetClient ¶
type DatasetService_GetDatasetClient = grpc.ClientStreamingClient[GetDatasetRequest, Dataset]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_GetDatasetServer ¶
type DatasetService_GetDatasetServer = grpc.ClientStreamingServer[GetDatasetRequest, Dataset]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_PushDatasetsClient ¶
type DatasetService_PushDatasetsClient = grpc.BidiStreamingClient[DatasetSuggestion, DatasetInquiry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_PushDatasetsServer ¶
type DatasetService_PushDatasetsServer = grpc.BidiStreamingServer[DatasetSuggestion, DatasetInquiry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_SyncFromClient ¶
type DatasetService_SyncFromClient = grpc.ClientStreamingClient[SyncFromRequest, SyncFromResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_SyncFromServer ¶
type DatasetService_SyncFromServer = grpc.ClientStreamingServer[SyncFromRequest, SyncFromResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_SyncToClient ¶
type DatasetService_SyncToClient = grpc.ServerStreamingClient[SyncToResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetService_SyncToServer ¶
type DatasetService_SyncToServer = grpc.ServerStreamingServer[SyncToResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatasetSignature ¶
type DatasetSignature struct {
DSUuid []byte `protobuf:"bytes,1,opt,name=DS_uuid,json=DSUuid,proto3" json:"DS_uuid,omitempty"`
DSHash []byte `protobuf:"bytes,2,opt,name=DS_hash,json=DSHash,proto3" json:"DS_hash,omitempty"`
// contains filtered or unexported fields
}
func (*DatasetSignature) Descriptor
deprecated
func (*DatasetSignature) Descriptor() ([]byte, []int)
Deprecated: Use DatasetSignature.ProtoReflect.Descriptor instead.
func (*DatasetSignature) GetDSHash ¶
func (x *DatasetSignature) GetDSHash() []byte
func (*DatasetSignature) GetDSUuid ¶
func (x *DatasetSignature) GetDSUuid() []byte
func (*DatasetSignature) ProtoMessage ¶
func (*DatasetSignature) ProtoMessage()
func (*DatasetSignature) ProtoReflect ¶
func (x *DatasetSignature) ProtoReflect() protoreflect.Message
func (*DatasetSignature) Reset ¶
func (x *DatasetSignature) Reset()
func (*DatasetSignature) String ¶
func (x *DatasetSignature) String() string
type DatasetSuggestion ¶
type DatasetSuggestion struct {
// Types that are valid to be assigned to Sgg:
//
// *DatasetSuggestion_SuggestDatasetWithCommitParents
// *DatasetSuggestion_SuggestDatasetNoCommitParents
// *DatasetSuggestion_Obj
Sgg isDatasetSuggestion_Sgg `protobuf_oneof:"sgg"`
// contains filtered or unexported fields
}
func (*DatasetSuggestion) Descriptor
deprecated
func (*DatasetSuggestion) Descriptor() ([]byte, []int)
Deprecated: Use DatasetSuggestion.ProtoReflect.Descriptor instead.
func (*DatasetSuggestion) GetObj ¶
func (x *DatasetSuggestion) GetObj() *DatasetObject
func (*DatasetSuggestion) GetSgg ¶
func (x *DatasetSuggestion) GetSgg() isDatasetSuggestion_Sgg
func (*DatasetSuggestion) GetSuggestDatasetNoCommitParents ¶
func (x *DatasetSuggestion) GetSuggestDatasetNoCommitParents() *RefName
func (*DatasetSuggestion) GetSuggestDatasetWithCommitParents ¶
func (x *DatasetSuggestion) GetSuggestDatasetWithCommitParents() *RefName
func (*DatasetSuggestion) ProtoMessage ¶
func (*DatasetSuggestion) ProtoMessage()
func (*DatasetSuggestion) ProtoReflect ¶
func (x *DatasetSuggestion) ProtoReflect() protoreflect.Message
func (*DatasetSuggestion) Reset ¶
func (x *DatasetSuggestion) Reset()
func (*DatasetSuggestion) String ¶
func (x *DatasetSuggestion) String() string
type DatasetSuggestion_Obj ¶
type DatasetSuggestion_Obj struct {
// TODO: Add support for following want requests
// bytes suggest_commit_id_with_parents = 3;
// bytes suggest_commit_id_no_parents = 4;
// bytes suggest_dataset_hash = 5;
Obj *DatasetObject `protobuf:"bytes,8,opt,name=obj,proto3,oneof"`
}
type DatasetSuggestion_SuggestDatasetNoCommitParents ¶
type DatasetSuggestion_SuggestDatasetNoCommitParents struct {
SuggestDatasetNoCommitParents *RefName `protobuf:"bytes,2,opt,name=suggest_dataset_no_commit_parents,json=suggestDatasetNoCommitParents,proto3,oneof"`
}
type DatasetSuggestion_SuggestDatasetWithCommitParents ¶
type DatasetSuggestion_SuggestDatasetWithCommitParents struct {
SuggestDatasetWithCommitParents *RefName `protobuf:"bytes,1,opt,name=suggest_dataset_with_commit_parents,json=suggestDatasetWithCommitParents,proto3,oneof"`
}
type DeleteRepoReply ¶
type DeleteRepoReply struct {
// contains filtered or unexported fields
}
func (*DeleteRepoReply) Descriptor
deprecated
func (*DeleteRepoReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRepoReply.ProtoReflect.Descriptor instead.
func (*DeleteRepoReply) ProtoMessage ¶
func (*DeleteRepoReply) ProtoMessage()
func (*DeleteRepoReply) ProtoReflect ¶
func (x *DeleteRepoReply) ProtoReflect() protoreflect.Message
func (*DeleteRepoReply) Reset ¶
func (x *DeleteRepoReply) Reset()
func (*DeleteRepoReply) String ¶
func (x *DeleteRepoReply) String() string
type DeleteRepoRequest ¶
type DeleteRepoRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteRepoRequest) Descriptor
deprecated
func (*DeleteRepoRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRepoRequest.ProtoReflect.Descriptor instead.
func (*DeleteRepoRequest) GetName ¶
func (x *DeleteRepoRequest) GetName() string
func (*DeleteRepoRequest) ProtoMessage ¶
func (*DeleteRepoRequest) ProtoMessage()
func (*DeleteRepoRequest) ProtoReflect ¶
func (x *DeleteRepoRequest) ProtoReflect() protoreflect.Message
func (*DeleteRepoRequest) Reset ¶
func (x *DeleteRepoRequest) Reset()
func (*DeleteRepoRequest) String ¶
func (x *DeleteRepoRequest) String() string
type DocumentDeleteRequest ¶
type DocumentDeleteRequest struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentDeleteRequest) Descriptor
deprecated
func (*DocumentDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DocumentDeleteRequest.ProtoReflect.Descriptor instead.
func (*DocumentDeleteRequest) GetHash ¶
func (x *DocumentDeleteRequest) GetHash() []byte
func (*DocumentDeleteRequest) GetRepoName ¶
func (x *DocumentDeleteRequest) GetRepoName() string
func (*DocumentDeleteRequest) ProtoMessage ¶
func (*DocumentDeleteRequest) ProtoMessage()
func (*DocumentDeleteRequest) ProtoReflect ¶
func (x *DocumentDeleteRequest) ProtoReflect() protoreflect.Message
func (*DocumentDeleteRequest) Reset ¶
func (x *DocumentDeleteRequest) Reset()
func (*DocumentDeleteRequest) String ¶
func (x *DocumentDeleteRequest) String() string
type DocumentDeleteResponse ¶
type DocumentDeleteResponse struct {
// contains filtered or unexported fields
}
func (*DocumentDeleteResponse) Descriptor
deprecated
func (*DocumentDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DocumentDeleteResponse.ProtoReflect.Descriptor instead.
func (*DocumentDeleteResponse) ProtoMessage ¶
func (*DocumentDeleteResponse) ProtoMessage()
func (*DocumentDeleteResponse) ProtoReflect ¶
func (x *DocumentDeleteResponse) ProtoReflect() protoreflect.Message
func (*DocumentDeleteResponse) Reset ¶
func (x *DocumentDeleteResponse) Reset()
func (*DocumentDeleteResponse) String ¶
func (x *DocumentDeleteResponse) String() string
type DocumentInfo ¶
type DocumentInfo struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
MimeType string `protobuf:"bytes,2,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
Author string `protobuf:"bytes,3,opt,name=author,proto3" json:"author,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
SizeBytes int64 `protobuf:"varint,5,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentInfo) Descriptor
deprecated
func (*DocumentInfo) Descriptor() ([]byte, []int)
Deprecated: Use DocumentInfo.ProtoReflect.Descriptor instead.
func (*DocumentInfo) GetAuthor ¶
func (x *DocumentInfo) GetAuthor() string
func (*DocumentInfo) GetHash ¶
func (x *DocumentInfo) GetHash() []byte
func (*DocumentInfo) GetMimeType ¶
func (x *DocumentInfo) GetMimeType() string
func (*DocumentInfo) GetSizeBytes ¶
func (x *DocumentInfo) GetSizeBytes() int64
func (*DocumentInfo) GetTimestamp ¶
func (x *DocumentInfo) GetTimestamp() *timestamppb.Timestamp
func (*DocumentInfo) ProtoMessage ¶
func (*DocumentInfo) ProtoMessage()
func (*DocumentInfo) ProtoReflect ¶
func (x *DocumentInfo) ProtoReflect() protoreflect.Message
func (*DocumentInfo) Reset ¶
func (x *DocumentInfo) Reset()
func (*DocumentInfo) String ¶
func (x *DocumentInfo) String() string
type DocumentRequest ¶
type DocumentRequest struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentRequest) Descriptor
deprecated
func (*DocumentRequest) Descriptor() ([]byte, []int)
Deprecated: Use DocumentRequest.ProtoReflect.Descriptor instead.
func (*DocumentRequest) GetHash ¶
func (x *DocumentRequest) GetHash() []byte
func (*DocumentRequest) GetRepoName ¶
func (x *DocumentRequest) GetRepoName() string
func (*DocumentRequest) ProtoMessage ¶
func (*DocumentRequest) ProtoMessage()
func (*DocumentRequest) ProtoReflect ¶
func (x *DocumentRequest) ProtoReflect() protoreflect.Message
func (*DocumentRequest) Reset ¶
func (x *DocumentRequest) Reset()
func (*DocumentRequest) String ¶
func (x *DocumentRequest) String() string
type DocumentResponse ¶
type DocumentResponse struct {
// Types that are valid to be assigned to Event:
//
// *DocumentResponse_Info
// *DocumentResponse_Chunk
Event isDocumentResponse_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*DocumentResponse) Descriptor
deprecated
func (*DocumentResponse) Descriptor() ([]byte, []int)
Deprecated: Use DocumentResponse.ProtoReflect.Descriptor instead.
func (*DocumentResponse) GetChunk ¶
func (x *DocumentResponse) GetChunk() []byte
func (*DocumentResponse) GetEvent ¶
func (x *DocumentResponse) GetEvent() isDocumentResponse_Event
func (*DocumentResponse) GetInfo ¶
func (x *DocumentResponse) GetInfo() *DocumentInfo
func (*DocumentResponse) ProtoMessage ¶
func (*DocumentResponse) ProtoMessage()
func (*DocumentResponse) ProtoReflect ¶
func (x *DocumentResponse) ProtoReflect() protoreflect.Message
func (*DocumentResponse) Reset ¶
func (x *DocumentResponse) Reset()
func (*DocumentResponse) String ¶
func (x *DocumentResponse) String() string
type DocumentResponse_Chunk ¶
type DocumentResponse_Chunk struct {
Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}
type DocumentResponse_Info ¶
type DocumentResponse_Info struct {
Info *DocumentInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof"`
}
type DocumentSetRequest ¶
type DocumentSetRequest struct {
// Types that are valid to be assigned to Event:
//
// *DocumentSetRequest_Info
// *DocumentSetRequest_Content
Event isDocumentSetRequest_Event `protobuf_oneof:"event"`
RepoName string `protobuf:"bytes,3,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentSetRequest) Descriptor
deprecated
func (*DocumentSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use DocumentSetRequest.ProtoReflect.Descriptor instead.
func (*DocumentSetRequest) GetContent ¶
func (x *DocumentSetRequest) GetContent() []byte
func (*DocumentSetRequest) GetEvent ¶
func (x *DocumentSetRequest) GetEvent() isDocumentSetRequest_Event
func (*DocumentSetRequest) GetInfo ¶
func (x *DocumentSetRequest) GetInfo() *DocumentInfo
func (*DocumentSetRequest) GetRepoName ¶
func (x *DocumentSetRequest) GetRepoName() string
func (*DocumentSetRequest) ProtoMessage ¶
func (*DocumentSetRequest) ProtoMessage()
func (*DocumentSetRequest) ProtoReflect ¶
func (x *DocumentSetRequest) ProtoReflect() protoreflect.Message
func (*DocumentSetRequest) Reset ¶
func (x *DocumentSetRequest) Reset()
func (*DocumentSetRequest) String ¶
func (x *DocumentSetRequest) String() string
type DocumentSetRequest_Content ¶
type DocumentSetRequest_Content struct {
Content []byte `protobuf:"bytes,2,opt,name=content,proto3,oneof"`
}
type DocumentSetRequest_Info ¶
type DocumentSetRequest_Info struct {
Info *DocumentInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof"`
}
type DocumentSetResponse ¶
type DocumentSetResponse struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentSetResponse) Descriptor
deprecated
func (*DocumentSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use DocumentSetResponse.ProtoReflect.Descriptor instead.
func (*DocumentSetResponse) GetHash ¶
func (x *DocumentSetResponse) GetHash() []byte
func (*DocumentSetResponse) ProtoMessage ¶
func (*DocumentSetResponse) ProtoMessage()
func (*DocumentSetResponse) ProtoReflect ¶
func (x *DocumentSetResponse) ProtoReflect() protoreflect.Message
func (*DocumentSetResponse) Reset ¶
func (x *DocumentSetResponse) Reset()
func (*DocumentSetResponse) String ¶
func (x *DocumentSetResponse) String() string
type DocumentsListRequest ¶
type DocumentsListRequest struct {
RepoName string `protobuf:"bytes,1,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentsListRequest) Descriptor
deprecated
func (*DocumentsListRequest) Descriptor() ([]byte, []int)
Deprecated: Use DocumentsListRequest.ProtoReflect.Descriptor instead.
func (*DocumentsListRequest) GetRepoName ¶
func (x *DocumentsListRequest) GetRepoName() string
func (*DocumentsListRequest) ProtoMessage ¶
func (*DocumentsListRequest) ProtoMessage()
func (*DocumentsListRequest) ProtoReflect ¶
func (x *DocumentsListRequest) ProtoReflect() protoreflect.Message
func (*DocumentsListRequest) Reset ¶
func (x *DocumentsListRequest) Reset()
func (*DocumentsListRequest) String ¶
func (x *DocumentsListRequest) String() string
type DocumentsListResponse ¶
type DocumentsListResponse struct {
Documents []*DocumentInfo `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentsListResponse) Descriptor
deprecated
func (*DocumentsListResponse) Descriptor() ([]byte, []int)
Deprecated: Use DocumentsListResponse.ProtoReflect.Descriptor instead.
func (*DocumentsListResponse) GetDocuments ¶
func (x *DocumentsListResponse) GetDocuments() []*DocumentInfo
func (*DocumentsListResponse) ProtoMessage ¶
func (*DocumentsListResponse) ProtoMessage()
func (*DocumentsListResponse) ProtoReflect ¶
func (x *DocumentsListResponse) ProtoReflect() protoreflect.Message
func (*DocumentsListResponse) Reset ¶
func (x *DocumentsListResponse) Reset()
func (*DocumentsListResponse) String ¶
func (x *DocumentsListResponse) String() string
type DownloadNamedGraphRevisionRequest ¶
type DownloadNamedGraphRevisionRequest struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*DownloadNamedGraphRevisionRequest) Descriptor
deprecated
func (*DownloadNamedGraphRevisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DownloadNamedGraphRevisionRequest.ProtoReflect.Descriptor instead.
func (*DownloadNamedGraphRevisionRequest) GetHash ¶
func (x *DownloadNamedGraphRevisionRequest) GetHash() []byte
func (*DownloadNamedGraphRevisionRequest) GetRepoName ¶
func (x *DownloadNamedGraphRevisionRequest) GetRepoName() string
func (*DownloadNamedGraphRevisionRequest) ProtoMessage ¶
func (*DownloadNamedGraphRevisionRequest) ProtoMessage()
func (*DownloadNamedGraphRevisionRequest) ProtoReflect ¶
func (x *DownloadNamedGraphRevisionRequest) ProtoReflect() protoreflect.Message
func (*DownloadNamedGraphRevisionRequest) Reset ¶
func (x *DownloadNamedGraphRevisionRequest) Reset()
func (*DownloadNamedGraphRevisionRequest) String ¶
func (x *DownloadNamedGraphRevisionRequest) String() string
type DownloadNamedGraphRevisionResponse ¶
type DownloadNamedGraphRevisionResponse struct {
Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
// contains filtered or unexported fields
}
func (*DownloadNamedGraphRevisionResponse) Descriptor
deprecated
func (*DownloadNamedGraphRevisionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadNamedGraphRevisionResponse.ProtoReflect.Descriptor instead.
func (*DownloadNamedGraphRevisionResponse) GetChunk ¶
func (x *DownloadNamedGraphRevisionResponse) GetChunk() []byte
func (*DownloadNamedGraphRevisionResponse) ProtoMessage ¶
func (*DownloadNamedGraphRevisionResponse) ProtoMessage()
func (*DownloadNamedGraphRevisionResponse) ProtoReflect ¶
func (x *DownloadNamedGraphRevisionResponse) ProtoReflect() protoreflect.Message
func (*DownloadNamedGraphRevisionResponse) Reset ¶
func (x *DownloadNamedGraphRevisionResponse) Reset()
func (*DownloadNamedGraphRevisionResponse) String ¶
func (x *DownloadNamedGraphRevisionResponse) String() string
type FindCommonParentRevisionRequest ¶
type FindCommonParentRevisionRequest struct {
DatasetId []byte `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
DatasetCommitRv1 []byte `protobuf:"bytes,2,opt,name=dataset_commit_rv1,json=datasetCommitRv1,proto3" json:"dataset_commit_rv1,omitempty"`
DatasetCommitRv2 []byte `protobuf:"bytes,3,opt,name=dataset_commit_rv2,json=datasetCommitRv2,proto3" json:"dataset_commit_rv2,omitempty"`
RepoName string `protobuf:"bytes,4,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*FindCommonParentRevisionRequest) Descriptor
deprecated
func (*FindCommonParentRevisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindCommonParentRevisionRequest.ProtoReflect.Descriptor instead.
func (*FindCommonParentRevisionRequest) GetDatasetCommitRv1 ¶
func (x *FindCommonParentRevisionRequest) GetDatasetCommitRv1() []byte
func (*FindCommonParentRevisionRequest) GetDatasetCommitRv2 ¶
func (x *FindCommonParentRevisionRequest) GetDatasetCommitRv2() []byte
func (*FindCommonParentRevisionRequest) GetDatasetId ¶
func (x *FindCommonParentRevisionRequest) GetDatasetId() []byte
func (*FindCommonParentRevisionRequest) GetRepoName ¶
func (x *FindCommonParentRevisionRequest) GetRepoName() string
func (*FindCommonParentRevisionRequest) ProtoMessage ¶
func (*FindCommonParentRevisionRequest) ProtoMessage()
func (*FindCommonParentRevisionRequest) ProtoReflect ¶
func (x *FindCommonParentRevisionRequest) ProtoReflect() protoreflect.Message
func (*FindCommonParentRevisionRequest) Reset ¶
func (x *FindCommonParentRevisionRequest) Reset()
func (*FindCommonParentRevisionRequest) String ¶
func (x *FindCommonParentRevisionRequest) String() string
type FindCommonParentRevisionResponse ¶
type FindCommonParentRevisionResponse struct {
CommonParentCommitRv []byte `protobuf:"bytes,1,opt,name=common_parent_commit_rv,json=commonParentCommitRv,proto3" json:"common_parent_commit_rv,omitempty"`
// contains filtered or unexported fields
}
func (*FindCommonParentRevisionResponse) Descriptor
deprecated
func (*FindCommonParentRevisionResponse) Descriptor() ([]byte, []int)
Deprecated: Use FindCommonParentRevisionResponse.ProtoReflect.Descriptor instead.
func (*FindCommonParentRevisionResponse) GetCommonParentCommitRv ¶
func (x *FindCommonParentRevisionResponse) GetCommonParentCommitRv() []byte
func (*FindCommonParentRevisionResponse) ProtoMessage ¶
func (*FindCommonParentRevisionResponse) ProtoMessage()
func (*FindCommonParentRevisionResponse) ProtoReflect ¶
func (x *FindCommonParentRevisionResponse) ProtoReflect() protoreflect.Message
func (*FindCommonParentRevisionResponse) Reset ¶
func (x *FindCommonParentRevisionResponse) Reset()
func (*FindCommonParentRevisionResponse) String ¶
func (x *FindCommonParentRevisionResponse) String() string
type GetBranchesRequest ¶
type GetBranchesRequest struct {
Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetBranchesRequest) Descriptor
deprecated
func (*GetBranchesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetBranchesRequest.ProtoReflect.Descriptor instead.
func (*GetBranchesRequest) GetRepoName ¶
func (x *GetBranchesRequest) GetRepoName() string
func (*GetBranchesRequest) GetUuid ¶
func (x *GetBranchesRequest) GetUuid() []byte
func (*GetBranchesRequest) ProtoMessage ¶
func (*GetBranchesRequest) ProtoMessage()
func (*GetBranchesRequest) ProtoReflect ¶
func (x *GetBranchesRequest) ProtoReflect() protoreflect.Message
func (*GetBranchesRequest) Reset ¶
func (x *GetBranchesRequest) Reset()
func (*GetBranchesRequest) String ¶
func (x *GetBranchesRequest) String() string
type GetBranchesResponse ¶
type GetBranchesResponse struct {
BranchRefs []*BranchRef `protobuf:"bytes,1,rep,name=BranchRefs,proto3" json:"BranchRefs,omitempty"`
// contains filtered or unexported fields
}
func (*GetBranchesResponse) Descriptor
deprecated
func (*GetBranchesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetBranchesResponse.ProtoReflect.Descriptor instead.
func (*GetBranchesResponse) GetBranchRefs ¶
func (x *GetBranchesResponse) GetBranchRefs() []*BranchRef
func (*GetBranchesResponse) ProtoMessage ¶
func (*GetBranchesResponse) ProtoMessage()
func (*GetBranchesResponse) ProtoReflect ¶
func (x *GetBranchesResponse) ProtoReflect() protoreflect.Message
func (*GetBranchesResponse) Reset ¶
func (x *GetBranchesResponse) Reset()
func (*GetBranchesResponse) String ¶
func (x *GetBranchesResponse) String() string
type GetCommitDetailsBatchRequest ¶
type GetCommitDetailsBatchRequest struct {
CommitIds [][]byte `protobuf:"bytes,1,rep,name=CommitIds,proto3" json:"CommitIds,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
Request for batch commit detail retrieval
func (*GetCommitDetailsBatchRequest) Descriptor
deprecated
func (*GetCommitDetailsBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCommitDetailsBatchRequest.ProtoReflect.Descriptor instead.
func (*GetCommitDetailsBatchRequest) GetCommitIds ¶
func (x *GetCommitDetailsBatchRequest) GetCommitIds() [][]byte
func (*GetCommitDetailsBatchRequest) GetRepoName ¶
func (x *GetCommitDetailsBatchRequest) GetRepoName() string
func (*GetCommitDetailsBatchRequest) ProtoMessage ¶
func (*GetCommitDetailsBatchRequest) ProtoMessage()
func (*GetCommitDetailsBatchRequest) ProtoReflect ¶
func (x *GetCommitDetailsBatchRequest) ProtoReflect() protoreflect.Message
func (*GetCommitDetailsBatchRequest) Reset ¶
func (x *GetCommitDetailsBatchRequest) Reset()
func (*GetCommitDetailsBatchRequest) String ¶
func (x *GetCommitDetailsBatchRequest) String() string
type GetCommitDetailsBatchResponse ¶
type GetCommitDetailsBatchResponse struct {
Details []*CommitDetail `protobuf:"bytes,1,rep,name=Details,proto3" json:"Details,omitempty"`
// contains filtered or unexported fields
}
Response containing commit details
func (*GetCommitDetailsBatchResponse) Descriptor
deprecated
func (*GetCommitDetailsBatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCommitDetailsBatchResponse.ProtoReflect.Descriptor instead.
func (*GetCommitDetailsBatchResponse) GetDetails ¶
func (x *GetCommitDetailsBatchResponse) GetDetails() []*CommitDetail
func (*GetCommitDetailsBatchResponse) ProtoMessage ¶
func (*GetCommitDetailsBatchResponse) ProtoMessage()
func (*GetCommitDetailsBatchResponse) ProtoReflect ¶
func (x *GetCommitDetailsBatchResponse) ProtoReflect() protoreflect.Message
func (*GetCommitDetailsBatchResponse) Reset ¶
func (x *GetCommitDetailsBatchResponse) Reset()
func (*GetCommitDetailsBatchResponse) String ¶
func (x *GetCommitDetailsBatchResponse) String() string
type GetCommitRequest ¶
type GetCommitRequest struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3" json:"dataset_uuid,omitempty"`
CommitId []byte `protobuf:"bytes,2,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
// Read mask that optionally specifies which Commit fields to return.
// If empty, all Commit fields will be returned.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
RepoName string `protobuf:"bytes,4,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetCommitRequest) Descriptor
deprecated
func (*GetCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCommitRequest.ProtoReflect.Descriptor instead.
func (*GetCommitRequest) FieldMask_Filter ¶
func (x *GetCommitRequest) FieldMask_Filter() *GetCommitRequest_FieldMask
FieldMask_Filter generates *GetCommitRequest_FieldMask with filter mode, so that only the fields in the GetCommitRequest.ReadMask will be appended into the GetCommitRequest.
func (*GetCommitRequest) FieldMask_Prune ¶
func (x *GetCommitRequest) FieldMask_Prune() *GetCommitRequest_FieldMask
FieldMask_Prune generates *GetCommitRequest_FieldMask with prune mode, so that only the fields NOT in the GetCommitRequest.ReadMask will be appended into the GetCommitRequest.
func (*GetCommitRequest) GetCommitId ¶
func (x *GetCommitRequest) GetCommitId() []byte
func (*GetCommitRequest) GetDatasetUuid ¶
func (x *GetCommitRequest) GetDatasetUuid() []byte
func (*GetCommitRequest) GetReadMask ¶
func (x *GetCommitRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*GetCommitRequest) GetRepoName ¶
func (x *GetCommitRequest) GetRepoName() string
func (*GetCommitRequest) MaskOut_AuthorTimestamp ¶
func (x *GetCommitRequest) MaskOut_AuthorTimestamp() *GetCommitRequest
MaskOut_AuthorTimestamp append Commit.AuthorTimestamp into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_AuthorTimestamp_Nanos ¶
func (x *GetCommitRequest) MaskOut_AuthorTimestamp_Nanos() *GetCommitRequest
MaskOut_AuthorTimestamp_Nanos append Commit.Nanos into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_AuthorTimestamp_Seconds ¶
func (x *GetCommitRequest) MaskOut_AuthorTimestamp_Seconds() *GetCommitRequest
MaskOut_AuthorTimestamp_Seconds append Commit.Seconds into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_AuthorUri ¶
func (x *GetCommitRequest) MaskOut_AuthorUri() *GetCommitRequest
MaskOut_AuthorUri append Commit.AuthorUri into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_CommitId ¶
func (x *GetCommitRequest) MaskOut_CommitId() *GetCommitRequest
MaskOut_CommitId append Commit.CommitId into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_Datasets ¶
func (x *GetCommitRequest) MaskOut_Datasets() *GetCommitRequest
MaskOut_Datasets append Commit.Datasets into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_Message ¶
func (x *GetCommitRequest) MaskOut_Message() *GetCommitRequest
MaskOut_Message append Commit.Message into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_NamedGraphs ¶
func (x *GetCommitRequest) MaskOut_NamedGraphs() *GetCommitRequest
MaskOut_NamedGraphs append Commit.NamedGraphs into GetCommitRequest.ReadMask.
func (*GetCommitRequest) MaskOut_Reason ¶
func (x *GetCommitRequest) MaskOut_Reason() *GetCommitRequest
MaskOut_Reason append Commit.Reason into GetCommitRequest.ReadMask.
func (*GetCommitRequest) ProtoMessage ¶
func (*GetCommitRequest) ProtoMessage()
func (*GetCommitRequest) ProtoReflect ¶
func (x *GetCommitRequest) ProtoReflect() protoreflect.Message
func (*GetCommitRequest) Reset ¶
func (x *GetCommitRequest) Reset()
func (*GetCommitRequest) String ¶
func (x *GetCommitRequest) String() string
type GetCommitRequest_FieldMask ¶
type GetCommitRequest_FieldMask struct {
// contains filtered or unexported fields
}
GetCommitRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*GetCommitRequest_FieldMask) Mask ¶
func (x *GetCommitRequest_FieldMask) Mask(m *Commit) *Commit
Mask only affects the fields in the GetCommitRequest.
func (*GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp() bool
MaskedOut_AuthorTimestamp indicates the field GetCommitRequest.AuthorTimestamp exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp_Nanos ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp_Nanos() bool
MaskedOut_AuthorTimestamp_Nanos indicates the field GetCommitRequest.Nanos exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp_Seconds ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorTimestamp_Seconds() bool
MaskedOut_AuthorTimestamp_Seconds indicates the field GetCommitRequest.Seconds exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_AuthorUri ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_AuthorUri() bool
MaskedOut_AuthorUri indicates the field GetCommitRequest.AuthorUri exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_CommitId ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_CommitId() bool
MaskedOut_CommitId indicates the field GetCommitRequest.CommitId exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_Datasets ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_Datasets() bool
MaskedOut_Datasets indicates the field GetCommitRequest.Datasets exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_Message ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_Message() bool
MaskedOut_Message indicates the field GetCommitRequest.Message exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_NamedGraphs ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_NamedGraphs() bool
MaskedOut_NamedGraphs indicates the field GetCommitRequest.NamedGraphs exists in the GetCommitRequest.ReadMask or not.
func (*GetCommitRequest_FieldMask) MaskedOut_Reason ¶
func (x *GetCommitRequest_FieldMask) MaskedOut_Reason() bool
MaskedOut_Reason indicates the field GetCommitRequest.Reason exists in the GetCommitRequest.ReadMask or not.
type GetDatasetRequest ¶
type GetDatasetRequest struct {
// Types that are valid to be assigned to DatasetId:
//
// *GetDatasetRequest_DatasetUuid
// *GetDatasetRequest_DatasetIri
DatasetId isGetDatasetRequest_DatasetId `protobuf_oneof:"dataset_id"`
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
RepoName string `protobuf:"bytes,4,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetDatasetRequest) Descriptor
deprecated
func (*GetDatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDatasetRequest.ProtoReflect.Descriptor instead.
func (*GetDatasetRequest) FieldMask_Filter ¶
func (x *GetDatasetRequest) FieldMask_Filter() *GetDatasetRequest_FieldMask
FieldMask_Filter generates *GetDatasetRequest_FieldMask with filter mode, so that only the fields in the GetDatasetRequest.ReadMask will be appended into the GetDatasetRequest.
func (*GetDatasetRequest) FieldMask_Prune ¶
func (x *GetDatasetRequest) FieldMask_Prune() *GetDatasetRequest_FieldMask
FieldMask_Prune generates *GetDatasetRequest_FieldMask with prune mode, so that only the fields NOT in the GetDatasetRequest.ReadMask will be appended into the GetDatasetRequest.
func (*GetDatasetRequest) GetDatasetId ¶
func (x *GetDatasetRequest) GetDatasetId() isGetDatasetRequest_DatasetId
func (*GetDatasetRequest) GetDatasetIri ¶
func (x *GetDatasetRequest) GetDatasetIri() string
func (*GetDatasetRequest) GetDatasetUuid ¶
func (x *GetDatasetRequest) GetDatasetUuid() []byte
func (*GetDatasetRequest) GetReadMask ¶
func (x *GetDatasetRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*GetDatasetRequest) GetRepoName ¶
func (x *GetDatasetRequest) GetRepoName() string
func (*GetDatasetRequest) MaskOut_Iri ¶
func (x *GetDatasetRequest) MaskOut_Iri() *GetDatasetRequest
MaskOut_Iri append Dataset.Iri into GetDatasetRequest.ReadMask.
func (*GetDatasetRequest) MaskOut_Uuid ¶
func (x *GetDatasetRequest) MaskOut_Uuid() *GetDatasetRequest
MaskOut_Uuid append Dataset.Uuid into GetDatasetRequest.ReadMask.
func (*GetDatasetRequest) ProtoMessage ¶
func (*GetDatasetRequest) ProtoMessage()
func (*GetDatasetRequest) ProtoReflect ¶
func (x *GetDatasetRequest) ProtoReflect() protoreflect.Message
func (*GetDatasetRequest) Reset ¶
func (x *GetDatasetRequest) Reset()
func (*GetDatasetRequest) String ¶
func (x *GetDatasetRequest) String() string
type GetDatasetRequest_DatasetIri ¶
type GetDatasetRequest_DatasetIri struct {
DatasetIri string `protobuf:"bytes,2,opt,name=dataset_iri,json=datasetIri,proto3,oneof"`
}
type GetDatasetRequest_DatasetUuid ¶
type GetDatasetRequest_DatasetUuid struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3,oneof"`
}
type GetDatasetRequest_FieldMask ¶
type GetDatasetRequest_FieldMask struct {
// contains filtered or unexported fields
}
GetDatasetRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*GetDatasetRequest_FieldMask) Mask ¶
func (x *GetDatasetRequest_FieldMask) Mask(m *Dataset) *Dataset
Mask only affects the fields in the GetDatasetRequest.
func (*GetDatasetRequest_FieldMask) MaskedOut_Iri ¶
func (x *GetDatasetRequest_FieldMask) MaskedOut_Iri() bool
MaskedOut_Iri indicates the field GetDatasetRequest.Iri exists in the GetDatasetRequest.ReadMask or not.
func (*GetDatasetRequest_FieldMask) MaskedOut_Uuid ¶
func (x *GetDatasetRequest_FieldMask) MaskedOut_Uuid() bool
MaskedOut_Uuid indicates the field GetDatasetRequest.Uuid exists in the GetDatasetRequest.ReadMask or not.
type GetLeafCommitsRequest ¶
type GetLeafCommitsRequest struct {
Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetLeafCommitsRequest) Descriptor
deprecated
func (*GetLeafCommitsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLeafCommitsRequest.ProtoReflect.Descriptor instead.
func (*GetLeafCommitsRequest) GetRepoName ¶
func (x *GetLeafCommitsRequest) GetRepoName() string
func (*GetLeafCommitsRequest) GetUuid ¶
func (x *GetLeafCommitsRequest) GetUuid() []byte
func (*GetLeafCommitsRequest) ProtoMessage ¶
func (*GetLeafCommitsRequest) ProtoMessage()
func (*GetLeafCommitsRequest) ProtoReflect ¶
func (x *GetLeafCommitsRequest) ProtoReflect() protoreflect.Message
func (*GetLeafCommitsRequest) Reset ¶
func (x *GetLeafCommitsRequest) Reset()
func (*GetLeafCommitsRequest) String ¶
func (x *GetLeafCommitsRequest) String() string
type GetLeafCommitsResponse ¶
type GetLeafCommitsResponse struct {
CommitHashes [][]byte `protobuf:"bytes,1,rep,name=commitHashes,proto3" json:"commitHashes,omitempty"`
// contains filtered or unexported fields
}
func (*GetLeafCommitsResponse) Descriptor
deprecated
func (*GetLeafCommitsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLeafCommitsResponse.ProtoReflect.Descriptor instead.
func (*GetLeafCommitsResponse) GetCommitHashes ¶
func (x *GetLeafCommitsResponse) GetCommitHashes() [][]byte
func (*GetLeafCommitsResponse) ProtoMessage ¶
func (*GetLeafCommitsResponse) ProtoMessage()
func (*GetLeafCommitsResponse) ProtoReflect ¶
func (x *GetLeafCommitsResponse) ProtoReflect() protoreflect.Message
func (*GetLeafCommitsResponse) Reset ¶
func (x *GetLeafCommitsResponse) Reset()
func (*GetLeafCommitsResponse) String ¶
func (x *GetLeafCommitsResponse) String() string
type GetRefRequest ¶
type GetRefRequest struct {
RefName *RefName `protobuf:"bytes,1,opt,name=ref_name,json=refName,proto3" json:"ref_name,omitempty"`
// Read mask that optionally specifies which Ref fields to return.
// If empty, all Ref fields will be returned.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
RepoName string `protobuf:"bytes,3,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetRefRequest) Descriptor
deprecated
func (*GetRefRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRefRequest.ProtoReflect.Descriptor instead.
func (*GetRefRequest) FieldMask_Filter ¶
func (x *GetRefRequest) FieldMask_Filter() *GetRefRequest_FieldMask
FieldMask_Filter generates *GetRefRequest_FieldMask with filter mode, so that only the fields in the GetRefRequest.ReadMask will be appended into the GetRefRequest.
func (*GetRefRequest) FieldMask_Prune ¶
func (x *GetRefRequest) FieldMask_Prune() *GetRefRequest_FieldMask
FieldMask_Prune generates *GetRefRequest_FieldMask with prune mode, so that only the fields NOT in the GetRefRequest.ReadMask will be appended into the GetRefRequest.
func (*GetRefRequest) GetReadMask ¶
func (x *GetRefRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*GetRefRequest) GetRefName ¶
func (x *GetRefRequest) GetRefName() *RefName
func (*GetRefRequest) GetRepoName ¶
func (x *GetRefRequest) GetRepoName() string
func (*GetRefRequest) MaskOut_CommitId ¶
func (x *GetRefRequest) MaskOut_CommitId() *GetRefRequest
MaskOut_CommitId append Ref.CommitId into GetRefRequest.ReadMask.
func (*GetRefRequest) MaskOut_Ref ¶
func (x *GetRefRequest) MaskOut_Ref() *GetRefRequest
MaskOut_Ref append Ref.Ref into GetRefRequest.ReadMask.
func (*GetRefRequest) MaskOut_Ref_Branch ¶
func (x *GetRefRequest) MaskOut_Ref_Branch() *GetRefRequest
MaskOut_Ref_Branch append Ref.Branch into GetRefRequest.ReadMask.
func (*GetRefRequest) MaskOut_Ref_DatasetIri ¶
func (x *GetRefRequest) MaskOut_Ref_DatasetIri() *GetRefRequest
MaskOut_Ref_DatasetIri append Ref.DatasetIri into GetRefRequest.ReadMask.
func (*GetRefRequest) MaskOut_Ref_DatasetUuid ¶
func (x *GetRefRequest) MaskOut_Ref_DatasetUuid() *GetRefRequest
MaskOut_Ref_DatasetUuid append Ref.DatasetUuid into GetRefRequest.ReadMask.
func (*GetRefRequest) MaskOut_Ref_Leaf ¶
func (x *GetRefRequest) MaskOut_Ref_Leaf() *GetRefRequest
MaskOut_Ref_Leaf append Ref.Leaf into GetRefRequest.ReadMask.
func (*GetRefRequest) ProtoMessage ¶
func (*GetRefRequest) ProtoMessage()
func (*GetRefRequest) ProtoReflect ¶
func (x *GetRefRequest) ProtoReflect() protoreflect.Message
func (*GetRefRequest) Reset ¶
func (x *GetRefRequest) Reset()
func (*GetRefRequest) String ¶
func (x *GetRefRequest) String() string
type GetRefRequest_FieldMask ¶
type GetRefRequest_FieldMask struct {
// contains filtered or unexported fields
}
GetRefRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*GetRefRequest_FieldMask) Mask ¶
func (x *GetRefRequest_FieldMask) Mask(m *Ref) *Ref
Mask only affects the fields in the GetRefRequest.
func (*GetRefRequest_FieldMask) MaskedOut_CommitId ¶
func (x *GetRefRequest_FieldMask) MaskedOut_CommitId() bool
MaskedOut_CommitId indicates the field GetRefRequest.CommitId exists in the GetRefRequest.ReadMask or not.
func (*GetRefRequest_FieldMask) MaskedOut_Ref ¶
func (x *GetRefRequest_FieldMask) MaskedOut_Ref() bool
MaskedOut_Ref indicates the field GetRefRequest.Ref exists in the GetRefRequest.ReadMask or not.
func (*GetRefRequest_FieldMask) MaskedOut_Ref_Branch ¶
func (x *GetRefRequest_FieldMask) MaskedOut_Ref_Branch() bool
MaskedOut_Ref_Branch indicates the field GetRefRequest.Branch exists in the GetRefRequest.ReadMask or not.
func (*GetRefRequest_FieldMask) MaskedOut_Ref_DatasetIri ¶
func (x *GetRefRequest_FieldMask) MaskedOut_Ref_DatasetIri() bool
MaskedOut_Ref_DatasetIri indicates the field GetRefRequest.DatasetIri exists in the GetRefRequest.ReadMask or not.
func (*GetRefRequest_FieldMask) MaskedOut_Ref_DatasetUuid ¶
func (x *GetRefRequest_FieldMask) MaskedOut_Ref_DatasetUuid() bool
MaskedOut_Ref_DatasetUuid indicates the field GetRefRequest.DatasetUuid exists in the GetRefRequest.ReadMask or not.
func (*GetRefRequest_FieldMask) MaskedOut_Ref_Leaf ¶
func (x *GetRefRequest_FieldMask) MaskedOut_Ref_Leaf() bool
MaskedOut_Ref_Leaf indicates the field GetRefRequest.Leaf exists in the GetRefRequest.ReadMask or not.
type GetRepoBleveInfoRequest ¶
type GetRepoBleveInfoRequest struct {
// contains filtered or unexported fields
}
func (*GetRepoBleveInfoRequest) Descriptor
deprecated
func (*GetRepoBleveInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRepoBleveInfoRequest.ProtoReflect.Descriptor instead.
func (*GetRepoBleveInfoRequest) ProtoMessage ¶
func (*GetRepoBleveInfoRequest) ProtoMessage()
func (*GetRepoBleveInfoRequest) ProtoReflect ¶
func (x *GetRepoBleveInfoRequest) ProtoReflect() protoreflect.Message
func (*GetRepoBleveInfoRequest) Reset ¶
func (x *GetRepoBleveInfoRequest) Reset()
func (*GetRepoBleveInfoRequest) String ¶
func (x *GetRepoBleveInfoRequest) String() string
type GetRepoBleveInfoResponse ¶
type GetRepoBleveInfoResponse struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*GetRepoBleveInfoResponse) Descriptor
deprecated
func (*GetRepoBleveInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRepoBleveInfoResponse.ProtoReflect.Descriptor instead.
func (*GetRepoBleveInfoResponse) GetName ¶
func (x *GetRepoBleveInfoResponse) GetName() string
func (*GetRepoBleveInfoResponse) GetVersion ¶
func (x *GetRepoBleveInfoResponse) GetVersion() string
func (*GetRepoBleveInfoResponse) ProtoMessage ¶
func (*GetRepoBleveInfoResponse) ProtoMessage()
func (*GetRepoBleveInfoResponse) ProtoReflect ¶
func (x *GetRepoBleveInfoResponse) ProtoReflect() protoreflect.Message
func (*GetRepoBleveInfoResponse) Reset ¶
func (x *GetRepoBleveInfoResponse) Reset()
func (*GetRepoBleveInfoResponse) String ¶
func (x *GetRepoBleveInfoResponse) String() string
type GetRepositoryInfoRequest ¶
type GetRepositoryInfoRequest struct {
BranchName string `protobuf:"bytes,1,opt,name=branchName,proto3" json:"branchName,omitempty"`
RepoName string `protobuf:"bytes,2,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetRepositoryInfoRequest) Descriptor
deprecated
func (*GetRepositoryInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRepositoryInfoRequest.ProtoReflect.Descriptor instead.
func (*GetRepositoryInfoRequest) GetBranchName ¶
func (x *GetRepositoryInfoRequest) GetBranchName() string
func (*GetRepositoryInfoRequest) GetRepoName ¶
func (x *GetRepositoryInfoRequest) GetRepoName() string
func (*GetRepositoryInfoRequest) ProtoMessage ¶
func (*GetRepositoryInfoRequest) ProtoMessage()
func (*GetRepositoryInfoRequest) ProtoReflect ¶
func (x *GetRepositoryInfoRequest) ProtoReflect() protoreflect.Message
func (*GetRepositoryInfoRequest) Reset ¶
func (x *GetRepositoryInfoRequest) Reset()
func (*GetRepositoryInfoRequest) String ¶
func (x *GetRepositoryInfoRequest) String() string
type GetRepositoryInfoResponse ¶
type GetRepositoryInfoResponse struct {
BboltSize int32 `protobuf:"varint,1,opt,name=bbolt_size,json=bboltSize,proto3" json:"bbolt_size,omitempty"`
BleveSize int32 `protobuf:"varint,2,opt,name=bleve_size,json=bleveSize,proto3" json:"bleve_size,omitempty"`
NumberOfDatasets int32 `protobuf:"varint,3,opt,name=number_of_datasets,json=numberOfDatasets,proto3" json:"number_of_datasets,omitempty"`
NumberOfDatasetRevisions int32 `` /* 138-byte string literal not displayed */
NumberOfNamedGraphRevisions int32 `` /* 149-byte string literal not displayed */
NumberOfCommits int32 `protobuf:"varint,6,opt,name=number_of_commits,json=numberOfCommits,proto3" json:"number_of_commits,omitempty"`
NumberOfRepositoryLogs int32 `` /* 132-byte string literal not displayed */
NumberOfDatasetsInBranch int32 `` /* 140-byte string literal not displayed */
DocumentDbSize int32 `protobuf:"varint,9,opt,name=document_db_size,json=documentDbSize,proto3" json:"document_db_size,omitempty"`
NumberOfDocuments int32 `protobuf:"varint,10,opt,name=number_of_documents,json=numberOfDocuments,proto3" json:"number_of_documents,omitempty"`
AccessRight string `protobuf:"bytes,11,opt,name=access_right,json=accessRight,proto3" json:"access_right,omitempty"`
VersionHash string `protobuf:"bytes,12,opt,name=version_hash,json=versionHash,proto3" json:"version_hash,omitempty"`
// contains filtered or unexported fields
}
func (*GetRepositoryInfoResponse) Descriptor
deprecated
func (*GetRepositoryInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRepositoryInfoResponse.ProtoReflect.Descriptor instead.
func (*GetRepositoryInfoResponse) GetAccessRight ¶
func (x *GetRepositoryInfoResponse) GetAccessRight() string
func (*GetRepositoryInfoResponse) GetBboltSize ¶
func (x *GetRepositoryInfoResponse) GetBboltSize() int32
func (*GetRepositoryInfoResponse) GetBleveSize ¶
func (x *GetRepositoryInfoResponse) GetBleveSize() int32
func (*GetRepositoryInfoResponse) GetDocumentDbSize ¶
func (x *GetRepositoryInfoResponse) GetDocumentDbSize() int32
func (*GetRepositoryInfoResponse) GetNumberOfCommits ¶
func (x *GetRepositoryInfoResponse) GetNumberOfCommits() int32
func (*GetRepositoryInfoResponse) GetNumberOfDatasetRevisions ¶
func (x *GetRepositoryInfoResponse) GetNumberOfDatasetRevisions() int32
func (*GetRepositoryInfoResponse) GetNumberOfDatasets ¶
func (x *GetRepositoryInfoResponse) GetNumberOfDatasets() int32
func (*GetRepositoryInfoResponse) GetNumberOfDatasetsInBranch ¶
func (x *GetRepositoryInfoResponse) GetNumberOfDatasetsInBranch() int32
func (*GetRepositoryInfoResponse) GetNumberOfDocuments ¶
func (x *GetRepositoryInfoResponse) GetNumberOfDocuments() int32
func (*GetRepositoryInfoResponse) GetNumberOfNamedGraphRevisions ¶
func (x *GetRepositoryInfoResponse) GetNumberOfNamedGraphRevisions() int32
func (*GetRepositoryInfoResponse) GetNumberOfRepositoryLogs ¶
func (x *GetRepositoryInfoResponse) GetNumberOfRepositoryLogs() int32
func (*GetRepositoryInfoResponse) GetVersionHash ¶
func (x *GetRepositoryInfoResponse) GetVersionHash() string
func (*GetRepositoryInfoResponse) ProtoMessage ¶
func (*GetRepositoryInfoResponse) ProtoMessage()
func (*GetRepositoryInfoResponse) ProtoReflect ¶
func (x *GetRepositoryInfoResponse) ProtoReflect() protoreflect.Message
func (*GetRepositoryInfoResponse) Reset ¶
func (x *GetRepositoryInfoResponse) Reset()
func (*GetRepositoryInfoResponse) String ¶
func (x *GetRepositoryInfoResponse) String() string
type GetRepositoryLogRequest ¶
type GetRepositoryLogRequest struct {
Start *int64 `protobuf:"varint,1,opt,name=start,proto3,oneof" json:"start,omitempty"`
End *int64 `protobuf:"varint,2,opt,name=end,proto3,oneof" json:"end,omitempty"`
RepoName string `protobuf:"bytes,3,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*GetRepositoryLogRequest) Descriptor
deprecated
func (*GetRepositoryLogRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRepositoryLogRequest.ProtoReflect.Descriptor instead.
func (*GetRepositoryLogRequest) GetEnd ¶
func (x *GetRepositoryLogRequest) GetEnd() int64
func (*GetRepositoryLogRequest) GetRepoName ¶
func (x *GetRepositoryLogRequest) GetRepoName() string
func (*GetRepositoryLogRequest) GetStart ¶
func (x *GetRepositoryLogRequest) GetStart() int64
func (*GetRepositoryLogRequest) ProtoMessage ¶
func (*GetRepositoryLogRequest) ProtoMessage()
func (*GetRepositoryLogRequest) ProtoReflect ¶
func (x *GetRepositoryLogRequest) ProtoReflect() protoreflect.Message
func (*GetRepositoryLogRequest) Reset ¶
func (x *GetRepositoryLogRequest) Reset()
func (*GetRepositoryLogRequest) String ¶
func (x *GetRepositoryLogRequest) String() string
type GetRepositoryLogResponse ¶
type GetRepositoryLogResponse struct {
Entries []*RepositoryLogEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
// contains filtered or unexported fields
}
func (*GetRepositoryLogResponse) Descriptor
deprecated
func (*GetRepositoryLogResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRepositoryLogResponse.ProtoReflect.Descriptor instead.
func (*GetRepositoryLogResponse) GetEntries ¶
func (x *GetRepositoryLogResponse) GetEntries() []*RepositoryLogEntry
func (*GetRepositoryLogResponse) ProtoMessage ¶
func (*GetRepositoryLogResponse) ProtoMessage()
func (*GetRepositoryLogResponse) ProtoReflect ¶
func (x *GetRepositoryLogResponse) ProtoReflect() protoreflect.Message
func (*GetRepositoryLogResponse) Reset ¶
func (x *GetRepositoryLogResponse) Reset()
func (*GetRepositoryLogResponse) String ¶
func (x *GetRepositoryLogResponse) String() string
type ListCommitsRequest ¶
type ListCommitsRequest struct {
RefName *RefName `protobuf:"bytes,1,opt,name=ref_name,json=refName,proto3" json:"ref_name,omitempty"`
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Read mask that optionally specifies which Commit fields to return.
// If empty, all Commit fields will be returned.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,4,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// contains filtered or unexported fields
}
func (*ListCommitsRequest) Descriptor
deprecated
func (*ListCommitsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListCommitsRequest.ProtoReflect.Descriptor instead.
func (*ListCommitsRequest) FieldMask_Filter ¶
func (x *ListCommitsRequest) FieldMask_Filter() *ListCommitsRequest_FieldMask
FieldMask_Filter generates *ListCommitsRequest_FieldMask with filter mode, so that only the fields in the ListCommitsRequest.ReadMask will be appended into the ListCommitsRequest.
func (*ListCommitsRequest) FieldMask_Prune ¶
func (x *ListCommitsRequest) FieldMask_Prune() *ListCommitsRequest_FieldMask
FieldMask_Prune generates *ListCommitsRequest_FieldMask with prune mode, so that only the fields NOT in the ListCommitsRequest.ReadMask will be appended into the ListCommitsRequest.
func (*ListCommitsRequest) GetPageSize ¶
func (x *ListCommitsRequest) GetPageSize() int32
func (*ListCommitsRequest) GetPageToken ¶
func (x *ListCommitsRequest) GetPageToken() string
func (*ListCommitsRequest) GetReadMask ¶
func (x *ListCommitsRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*ListCommitsRequest) GetRefName ¶
func (x *ListCommitsRequest) GetRefName() *RefName
func (*ListCommitsRequest) MaskOut_AuthorTimestamp ¶
func (x *ListCommitsRequest) MaskOut_AuthorTimestamp() *ListCommitsRequest
MaskOut_AuthorTimestamp append Commit.AuthorTimestamp into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_AuthorTimestamp_Nanos ¶
func (x *ListCommitsRequest) MaskOut_AuthorTimestamp_Nanos() *ListCommitsRequest
MaskOut_AuthorTimestamp_Nanos append Commit.Nanos into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_AuthorTimestamp_Seconds ¶
func (x *ListCommitsRequest) MaskOut_AuthorTimestamp_Seconds() *ListCommitsRequest
MaskOut_AuthorTimestamp_Seconds append Commit.Seconds into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_AuthorUri ¶
func (x *ListCommitsRequest) MaskOut_AuthorUri() *ListCommitsRequest
MaskOut_AuthorUri append Commit.AuthorUri into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_CommitId ¶
func (x *ListCommitsRequest) MaskOut_CommitId() *ListCommitsRequest
MaskOut_CommitId append Commit.CommitId into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_Datasets ¶
func (x *ListCommitsRequest) MaskOut_Datasets() *ListCommitsRequest
MaskOut_Datasets append Commit.Datasets into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_Message ¶
func (x *ListCommitsRequest) MaskOut_Message() *ListCommitsRequest
MaskOut_Message append Commit.Message into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_NamedGraphs ¶
func (x *ListCommitsRequest) MaskOut_NamedGraphs() *ListCommitsRequest
MaskOut_NamedGraphs append Commit.NamedGraphs into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) MaskOut_Reason ¶
func (x *ListCommitsRequest) MaskOut_Reason() *ListCommitsRequest
MaskOut_Reason append Commit.Reason into ListCommitsRequest.ReadMask.
func (*ListCommitsRequest) ProtoMessage ¶
func (*ListCommitsRequest) ProtoMessage()
func (*ListCommitsRequest) ProtoReflect ¶
func (x *ListCommitsRequest) ProtoReflect() protoreflect.Message
func (*ListCommitsRequest) Reset ¶
func (x *ListCommitsRequest) Reset()
func (*ListCommitsRequest) String ¶
func (x *ListCommitsRequest) String() string
type ListCommitsRequest_FieldMask ¶
type ListCommitsRequest_FieldMask struct {
// contains filtered or unexported fields
}
ListCommitsRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*ListCommitsRequest_FieldMask) Mask ¶
func (x *ListCommitsRequest_FieldMask) Mask(m *Commit) *Commit
Mask only affects the fields in the ListCommitsRequest.
func (*ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp() bool
MaskedOut_AuthorTimestamp indicates the field ListCommitsRequest.AuthorTimestamp exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp_Nanos ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp_Nanos() bool
MaskedOut_AuthorTimestamp_Nanos indicates the field ListCommitsRequest.Nanos exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp_Seconds ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorTimestamp_Seconds() bool
MaskedOut_AuthorTimestamp_Seconds indicates the field ListCommitsRequest.Seconds exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_AuthorUri ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_AuthorUri() bool
MaskedOut_AuthorUri indicates the field ListCommitsRequest.AuthorUri exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_CommitId ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_CommitId() bool
MaskedOut_CommitId indicates the field ListCommitsRequest.CommitId exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_Datasets ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_Datasets() bool
MaskedOut_Datasets indicates the field ListCommitsRequest.Datasets exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_Message ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_Message() bool
MaskedOut_Message indicates the field ListCommitsRequest.Message exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_NamedGraphs ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_NamedGraphs() bool
MaskedOut_NamedGraphs indicates the field ListCommitsRequest.NamedGraphs exists in the ListCommitsRequest.ReadMask or not.
func (*ListCommitsRequest_FieldMask) MaskedOut_Reason ¶
func (x *ListCommitsRequest_FieldMask) MaskedOut_Reason() bool
MaskedOut_Reason indicates the field ListCommitsRequest.Reason exists in the ListCommitsRequest.ReadMask or not.
type ListCommitsResponse ¶
type ListCommitsResponse struct {
Commits []*Commit `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListCommitsResponse) Descriptor
deprecated
func (*ListCommitsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListCommitsResponse.ProtoReflect.Descriptor instead.
func (*ListCommitsResponse) GetCommits ¶
func (x *ListCommitsResponse) GetCommits() []*Commit
func (*ListCommitsResponse) GetNextPageToken ¶
func (x *ListCommitsResponse) GetNextPageToken() string
func (*ListCommitsResponse) ProtoMessage ¶
func (*ListCommitsResponse) ProtoMessage()
func (*ListCommitsResponse) ProtoReflect ¶
func (x *ListCommitsResponse) ProtoReflect() protoreflect.Message
func (*ListCommitsResponse) Reset ¶
func (x *ListCommitsResponse) Reset()
func (*ListCommitsResponse) String ¶
func (x *ListCommitsResponse) String() string
type ListCommitsResponse_NextPageToken ¶
type ListCommitsResponse_NextPageToken struct {
NextCommitId []byte `protobuf:"bytes,1,opt,name=next_commit_id,json=nextCommitId,proto3" json:"next_commit_id,omitempty"`
// contains filtered or unexported fields
}
func (*ListCommitsResponse_NextPageToken) Descriptor
deprecated
func (*ListCommitsResponse_NextPageToken) Descriptor() ([]byte, []int)
Deprecated: Use ListCommitsResponse_NextPageToken.ProtoReflect.Descriptor instead.
func (*ListCommitsResponse_NextPageToken) GetNextCommitId ¶
func (x *ListCommitsResponse_NextPageToken) GetNextCommitId() []byte
func (*ListCommitsResponse_NextPageToken) ProtoMessage ¶
func (*ListCommitsResponse_NextPageToken) ProtoMessage()
func (*ListCommitsResponse_NextPageToken) ProtoReflect ¶
func (x *ListCommitsResponse_NextPageToken) ProtoReflect() protoreflect.Message
func (*ListCommitsResponse_NextPageToken) Reset ¶
func (x *ListCommitsResponse_NextPageToken) Reset()
func (*ListCommitsResponse_NextPageToken) String ¶
func (x *ListCommitsResponse_NextPageToken) String() string
type ListDatasetsRequest ¶
type ListDatasetsRequest struct {
PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Read mask that optionally specifies which Dataset fields to return.
// If empty, all Dataset fields will be returned.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
RepoName string `protobuf:"bytes,4,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*ListDatasetsRequest) Descriptor
deprecated
func (*ListDatasetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDatasetsRequest.ProtoReflect.Descriptor instead.
func (*ListDatasetsRequest) FieldMask_Filter ¶
func (x *ListDatasetsRequest) FieldMask_Filter() *ListDatasetsRequest_FieldMask
FieldMask_Filter generates *ListDatasetsRequest_FieldMask with filter mode, so that only the fields in the ListDatasetsRequest.ReadMask will be appended into the ListDatasetsRequest.
func (*ListDatasetsRequest) FieldMask_Prune ¶
func (x *ListDatasetsRequest) FieldMask_Prune() *ListDatasetsRequest_FieldMask
FieldMask_Prune generates *ListDatasetsRequest_FieldMask with prune mode, so that only the fields NOT in the ListDatasetsRequest.ReadMask will be appended into the ListDatasetsRequest.
func (*ListDatasetsRequest) GetPageSize ¶
func (x *ListDatasetsRequest) GetPageSize() int32
func (*ListDatasetsRequest) GetPageToken ¶
func (x *ListDatasetsRequest) GetPageToken() string
func (*ListDatasetsRequest) GetReadMask ¶
func (x *ListDatasetsRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*ListDatasetsRequest) GetRepoName ¶
func (x *ListDatasetsRequest) GetRepoName() string
func (*ListDatasetsRequest) MaskOut_Iri ¶
func (x *ListDatasetsRequest) MaskOut_Iri() *ListDatasetsRequest
MaskOut_Iri append Dataset.Iri into ListDatasetsRequest.ReadMask.
func (*ListDatasetsRequest) MaskOut_Uuid ¶
func (x *ListDatasetsRequest) MaskOut_Uuid() *ListDatasetsRequest
MaskOut_Uuid append Dataset.Uuid into ListDatasetsRequest.ReadMask.
func (*ListDatasetsRequest) ProtoMessage ¶
func (*ListDatasetsRequest) ProtoMessage()
func (*ListDatasetsRequest) ProtoReflect ¶
func (x *ListDatasetsRequest) ProtoReflect() protoreflect.Message
func (*ListDatasetsRequest) Reset ¶
func (x *ListDatasetsRequest) Reset()
func (*ListDatasetsRequest) String ¶
func (x *ListDatasetsRequest) String() string
type ListDatasetsRequest_FieldMask ¶
type ListDatasetsRequest_FieldMask struct {
// contains filtered or unexported fields
}
ListDatasetsRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*ListDatasetsRequest_FieldMask) Mask ¶
func (x *ListDatasetsRequest_FieldMask) Mask(m *Dataset) *Dataset
Mask only affects the fields in the ListDatasetsRequest.
func (*ListDatasetsRequest_FieldMask) MaskedOut_Iri ¶
func (x *ListDatasetsRequest_FieldMask) MaskedOut_Iri() bool
MaskedOut_Iri indicates the field ListDatasetsRequest.Iri exists in the ListDatasetsRequest.ReadMask or not.
func (*ListDatasetsRequest_FieldMask) MaskedOut_Uuid ¶
func (x *ListDatasetsRequest_FieldMask) MaskedOut_Uuid() bool
MaskedOut_Uuid indicates the field ListDatasetsRequest.Uuid exists in the ListDatasetsRequest.ReadMask or not.
type ListDatasetsResponse ¶
type ListDatasetsResponse struct {
Datasets []*Dataset `protobuf:"bytes,2,rep,name=datasets,proto3" json:"datasets,omitempty"`
// Token to retrieve the next page of results, or empty if there are no more
// results in the list.
NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListDatasetsResponse) Descriptor
deprecated
func (*ListDatasetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDatasetsResponse.ProtoReflect.Descriptor instead.
func (*ListDatasetsResponse) GetDatasets ¶
func (x *ListDatasetsResponse) GetDatasets() []*Dataset
func (*ListDatasetsResponse) GetNextPageToken ¶
func (x *ListDatasetsResponse) GetNextPageToken() string
func (*ListDatasetsResponse) ProtoMessage ¶
func (*ListDatasetsResponse) ProtoMessage()
func (*ListDatasetsResponse) ProtoReflect ¶
func (x *ListDatasetsResponse) ProtoReflect() protoreflect.Message
func (*ListDatasetsResponse) Reset ¶
func (x *ListDatasetsResponse) Reset()
func (*ListDatasetsResponse) String ¶
func (x *ListDatasetsResponse) String() string
type ListDatasetsResponse_NextPageToken ¶
type ListDatasetsResponse_NextPageToken struct {
NextId []byte `protobuf:"bytes,1,opt,name=next_id,json=nextId,proto3" json:"next_id,omitempty"`
// contains filtered or unexported fields
}
func (*ListDatasetsResponse_NextPageToken) Descriptor
deprecated
func (*ListDatasetsResponse_NextPageToken) Descriptor() ([]byte, []int)
Deprecated: Use ListDatasetsResponse_NextPageToken.ProtoReflect.Descriptor instead.
func (*ListDatasetsResponse_NextPageToken) GetNextId ¶
func (x *ListDatasetsResponse_NextPageToken) GetNextId() []byte
func (*ListDatasetsResponse_NextPageToken) ProtoMessage ¶
func (*ListDatasetsResponse_NextPageToken) ProtoMessage()
func (*ListDatasetsResponse_NextPageToken) ProtoReflect ¶
func (x *ListDatasetsResponse_NextPageToken) ProtoReflect() protoreflect.Message
func (*ListDatasetsResponse_NextPageToken) Reset ¶
func (x *ListDatasetsResponse_NextPageToken) Reset()
func (*ListDatasetsResponse_NextPageToken) String ¶
func (x *ListDatasetsResponse_NextPageToken) String() string
type ListRefsRequest ¶
type ListRefsRequest struct {
// Types that are valid to be assigned to DatasetId:
//
// *ListRefsRequest_DatasetUuid
// *ListRefsRequest_DatasetIri
DatasetId isListRefsRequest_DatasetId `protobuf_oneof:"dataset_id"`
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Read mask that optionally specifies which Ref fields to return.
// If empty, all Ref fields will be returned.
ReadMask *fieldmaskpb.FieldMask `protobuf:"bytes,5,opt,name=read_mask,json=readMask,proto3" json:"read_mask,omitempty"`
// contains filtered or unexported fields
}
func (*ListRefsRequest) Descriptor
deprecated
func (*ListRefsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRefsRequest.ProtoReflect.Descriptor instead.
func (*ListRefsRequest) FieldMask_Filter ¶
func (x *ListRefsRequest) FieldMask_Filter() *ListRefsRequest_FieldMask
FieldMask_Filter generates *ListRefsRequest_FieldMask with filter mode, so that only the fields in the ListRefsRequest.ReadMask will be appended into the ListRefsRequest.
func (*ListRefsRequest) FieldMask_Prune ¶
func (x *ListRefsRequest) FieldMask_Prune() *ListRefsRequest_FieldMask
FieldMask_Prune generates *ListRefsRequest_FieldMask with prune mode, so that only the fields NOT in the ListRefsRequest.ReadMask will be appended into the ListRefsRequest.
func (*ListRefsRequest) GetDatasetId ¶
func (x *ListRefsRequest) GetDatasetId() isListRefsRequest_DatasetId
func (*ListRefsRequest) GetDatasetIri ¶
func (x *ListRefsRequest) GetDatasetIri() string
func (*ListRefsRequest) GetDatasetUuid ¶
func (x *ListRefsRequest) GetDatasetUuid() []byte
func (*ListRefsRequest) GetPageSize ¶
func (x *ListRefsRequest) GetPageSize() int32
func (*ListRefsRequest) GetPageToken ¶
func (x *ListRefsRequest) GetPageToken() string
func (*ListRefsRequest) GetReadMask ¶
func (x *ListRefsRequest) GetReadMask() *fieldmaskpb.FieldMask
func (*ListRefsRequest) MaskOut_CommitId ¶
func (x *ListRefsRequest) MaskOut_CommitId() *ListRefsRequest
MaskOut_CommitId append Ref.CommitId into ListRefsRequest.ReadMask.
func (*ListRefsRequest) MaskOut_Ref ¶
func (x *ListRefsRequest) MaskOut_Ref() *ListRefsRequest
MaskOut_Ref append Ref.Ref into ListRefsRequest.ReadMask.
func (*ListRefsRequest) MaskOut_Ref_Branch ¶
func (x *ListRefsRequest) MaskOut_Ref_Branch() *ListRefsRequest
MaskOut_Ref_Branch append Ref.Branch into ListRefsRequest.ReadMask.
func (*ListRefsRequest) MaskOut_Ref_DatasetIri ¶
func (x *ListRefsRequest) MaskOut_Ref_DatasetIri() *ListRefsRequest
MaskOut_Ref_DatasetIri append Ref.DatasetIri into ListRefsRequest.ReadMask.
func (*ListRefsRequest) MaskOut_Ref_DatasetUuid ¶
func (x *ListRefsRequest) MaskOut_Ref_DatasetUuid() *ListRefsRequest
MaskOut_Ref_DatasetUuid append Ref.DatasetUuid into ListRefsRequest.ReadMask.
func (*ListRefsRequest) MaskOut_Ref_Leaf ¶
func (x *ListRefsRequest) MaskOut_Ref_Leaf() *ListRefsRequest
MaskOut_Ref_Leaf append Ref.Leaf into ListRefsRequest.ReadMask.
func (*ListRefsRequest) ProtoMessage ¶
func (*ListRefsRequest) ProtoMessage()
func (*ListRefsRequest) ProtoReflect ¶
func (x *ListRefsRequest) ProtoReflect() protoreflect.Message
func (*ListRefsRequest) Reset ¶
func (x *ListRefsRequest) Reset()
func (*ListRefsRequest) String ¶
func (x *ListRefsRequest) String() string
type ListRefsRequest_DatasetIri ¶
type ListRefsRequest_DatasetIri struct {
DatasetIri string `protobuf:"bytes,2,opt,name=dataset_iri,json=datasetIri,proto3,oneof"`
}
type ListRefsRequest_DatasetUuid ¶
type ListRefsRequest_DatasetUuid struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3,oneof"`
}
type ListRefsRequest_FieldMask ¶
type ListRefsRequest_FieldMask struct {
// contains filtered or unexported fields
}
ListRefsRequest_FieldMask provide provide helper functions to deal with FieldMask.
func (*ListRefsRequest_FieldMask) Mask ¶
func (x *ListRefsRequest_FieldMask) Mask(m *Ref) *Ref
Mask only affects the fields in the ListRefsRequest.
func (*ListRefsRequest_FieldMask) MaskedOut_CommitId ¶
func (x *ListRefsRequest_FieldMask) MaskedOut_CommitId() bool
MaskedOut_CommitId indicates the field ListRefsRequest.CommitId exists in the ListRefsRequest.ReadMask or not.
func (*ListRefsRequest_FieldMask) MaskedOut_Ref ¶
func (x *ListRefsRequest_FieldMask) MaskedOut_Ref() bool
MaskedOut_Ref indicates the field ListRefsRequest.Ref exists in the ListRefsRequest.ReadMask or not.
func (*ListRefsRequest_FieldMask) MaskedOut_Ref_Branch ¶
func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_Branch() bool
MaskedOut_Ref_Branch indicates the field ListRefsRequest.Branch exists in the ListRefsRequest.ReadMask or not.
func (*ListRefsRequest_FieldMask) MaskedOut_Ref_DatasetIri ¶
func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_DatasetIri() bool
MaskedOut_Ref_DatasetIri indicates the field ListRefsRequest.DatasetIri exists in the ListRefsRequest.ReadMask or not.
func (*ListRefsRequest_FieldMask) MaskedOut_Ref_DatasetUuid ¶
func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_DatasetUuid() bool
MaskedOut_Ref_DatasetUuid indicates the field ListRefsRequest.DatasetUuid exists in the ListRefsRequest.ReadMask or not.
func (*ListRefsRequest_FieldMask) MaskedOut_Ref_Leaf ¶
func (x *ListRefsRequest_FieldMask) MaskedOut_Ref_Leaf() bool
MaskedOut_Ref_Leaf indicates the field ListRefsRequest.Leaf exists in the ListRefsRequest.ReadMask or not.
type ListRefsResponse ¶
type ListRefsResponse struct {
Refs []*Ref `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListRefsResponse) Descriptor
deprecated
func (*ListRefsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRefsResponse.ProtoReflect.Descriptor instead.
func (*ListRefsResponse) GetNextPageToken ¶
func (x *ListRefsResponse) GetNextPageToken() string
func (*ListRefsResponse) GetRefs ¶
func (x *ListRefsResponse) GetRefs() []*Ref
func (*ListRefsResponse) ProtoMessage ¶
func (*ListRefsResponse) ProtoMessage()
func (*ListRefsResponse) ProtoReflect ¶
func (x *ListRefsResponse) ProtoReflect() protoreflect.Message
func (*ListRefsResponse) Reset ¶
func (x *ListRefsResponse) Reset()
func (*ListRefsResponse) String ¶
func (x *ListRefsResponse) String() string
type ListRefsResponse_NextPageToken ¶
type ListRefsResponse_NextPageToken struct {
NextDatasetUuid []byte `protobuf:"bytes,1,opt,name=next_dataset_uuid,json=nextDatasetUuid,proto3" json:"next_dataset_uuid,omitempty"`
// Types that are valid to be assigned to NextRefName:
//
// *ListRefsResponse_NextPageToken_NextBranch
// *ListRefsResponse_NextPageToken_NextLeaf
NextRefName isListRefsResponse_NextPageToken_NextRefName `protobuf_oneof:"next_ref_name"`
// contains filtered or unexported fields
}
func (*ListRefsResponse_NextPageToken) Descriptor
deprecated
func (*ListRefsResponse_NextPageToken) Descriptor() ([]byte, []int)
Deprecated: Use ListRefsResponse_NextPageToken.ProtoReflect.Descriptor instead.
func (*ListRefsResponse_NextPageToken) GetNextBranch ¶
func (x *ListRefsResponse_NextPageToken) GetNextBranch() string
func (*ListRefsResponse_NextPageToken) GetNextDatasetUuid ¶
func (x *ListRefsResponse_NextPageToken) GetNextDatasetUuid() []byte
func (*ListRefsResponse_NextPageToken) GetNextLeaf ¶
func (x *ListRefsResponse_NextPageToken) GetNextLeaf() []byte
func (*ListRefsResponse_NextPageToken) GetNextRefName ¶
func (x *ListRefsResponse_NextPageToken) GetNextRefName() isListRefsResponse_NextPageToken_NextRefName
func (*ListRefsResponse_NextPageToken) ProtoMessage ¶
func (*ListRefsResponse_NextPageToken) ProtoMessage()
func (*ListRefsResponse_NextPageToken) ProtoReflect ¶
func (x *ListRefsResponse_NextPageToken) ProtoReflect() protoreflect.Message
func (*ListRefsResponse_NextPageToken) Reset ¶
func (x *ListRefsResponse_NextPageToken) Reset()
func (*ListRefsResponse_NextPageToken) String ¶
func (x *ListRefsResponse_NextPageToken) String() string
type ListRefsResponse_NextPageToken_NextBranch ¶
type ListRefsResponse_NextPageToken_NextBranch struct {
NextBranch string `protobuf:"bytes,2,opt,name=next_branch,json=nextBranch,proto3,oneof"`
}
type ListRefsResponse_NextPageToken_NextLeaf ¶
type ListRefsResponse_NextPageToken_NextLeaf struct {
NextLeaf []byte `protobuf:"bytes,3,opt,name=next_leaf,json=nextLeaf,proto3,oneof"`
}
type ListRefsResponse_NextPageToken_NextRefName ¶
type ListRefsResponse_NextPageToken_NextRefName = isListRefsResponse_NextPageToken_NextRefName //nolint:revive
type ListReposReply ¶
type ListReposReply struct {
Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
// contains filtered or unexported fields
}
func (*ListReposReply) Descriptor
deprecated
func (*ListReposReply) Descriptor() ([]byte, []int)
Deprecated: Use ListReposReply.ProtoReflect.Descriptor instead.
func (*ListReposReply) GetNames ¶
func (x *ListReposReply) GetNames() []string
func (*ListReposReply) ProtoMessage ¶
func (*ListReposReply) ProtoMessage()
func (*ListReposReply) ProtoReflect ¶
func (x *ListReposReply) ProtoReflect() protoreflect.Message
func (*ListReposReply) Reset ¶
func (x *ListReposReply) Reset()
func (*ListReposReply) String ¶
func (x *ListReposReply) String() string
type ListReposRequest ¶
type ListReposRequest struct {
// contains filtered or unexported fields
}
func (*ListReposRequest) Descriptor
deprecated
func (*ListReposRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListReposRequest.ProtoReflect.Descriptor instead.
func (*ListReposRequest) ProtoMessage ¶
func (*ListReposRequest) ProtoMessage()
func (*ListReposRequest) ProtoReflect ¶
func (x *ListReposRequest) ProtoReflect() protoreflect.Message
func (*ListReposRequest) Reset ¶
func (x *ListReposRequest) Reset()
func (*ListReposRequest) String ¶
func (x *ListReposRequest) String() string
type NamedGraphRevision ¶
type NamedGraphRevision struct {
Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // binary NamedGraph format
// contains filtered or unexported fields
}
func (*NamedGraphRevision) Descriptor
deprecated
func (*NamedGraphRevision) Descriptor() ([]byte, []int)
Deprecated: Use NamedGraphRevision.ProtoReflect.Descriptor instead.
func (*NamedGraphRevision) GetContent ¶
func (x *NamedGraphRevision) GetContent() []byte
func (*NamedGraphRevision) GetHash ¶
func (x *NamedGraphRevision) GetHash() []byte
func (*NamedGraphRevision) ProtoMessage ¶
func (*NamedGraphRevision) ProtoMessage()
func (*NamedGraphRevision) ProtoReflect ¶
func (x *NamedGraphRevision) ProtoReflect() protoreflect.Message
func (*NamedGraphRevision) Reset ¶
func (x *NamedGraphRevision) Reset()
func (*NamedGraphRevision) String ¶
func (x *NamedGraphRevision) String() string
type NamedGraphSignature ¶
type NamedGraphSignature struct {
NgUuid []byte `protobuf:"bytes,1,opt,name=ng_uuid,json=ngUuid,proto3" json:"ng_uuid,omitempty"`
NgHash []byte `protobuf:"bytes,2,opt,name=ng_hash,json=ngHash,proto3" json:"ng_hash,omitempty"`
// contains filtered or unexported fields
}
func (*NamedGraphSignature) Descriptor
deprecated
func (*NamedGraphSignature) Descriptor() ([]byte, []int)
Deprecated: Use NamedGraphSignature.ProtoReflect.Descriptor instead.
func (*NamedGraphSignature) GetNgHash ¶
func (x *NamedGraphSignature) GetNgHash() []byte
func (*NamedGraphSignature) GetNgUuid ¶
func (x *NamedGraphSignature) GetNgUuid() []byte
func (*NamedGraphSignature) ProtoMessage ¶
func (*NamedGraphSignature) ProtoMessage()
func (*NamedGraphSignature) ProtoReflect ¶
func (x *NamedGraphSignature) ProtoReflect() protoreflect.Message
func (*NamedGraphSignature) Reset ¶
func (x *NamedGraphSignature) Reset()
func (*NamedGraphSignature) String ¶
func (x *NamedGraphSignature) String() string
type ParentCommit ¶
type ParentCommit struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3" json:"dataset_uuid,omitempty"`
CommitId []byte `protobuf:"bytes,2,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
// contains filtered or unexported fields
}
func (*ParentCommit) Descriptor
deprecated
func (*ParentCommit) Descriptor() ([]byte, []int)
Deprecated: Use ParentCommit.ProtoReflect.Descriptor instead.
func (*ParentCommit) GetCommitId ¶
func (x *ParentCommit) GetCommitId() []byte
func (*ParentCommit) GetDatasetUuid ¶
func (x *ParentCommit) GetDatasetUuid() []byte
func (*ParentCommit) ProtoMessage ¶
func (*ParentCommit) ProtoMessage()
func (*ParentCommit) ProtoReflect ¶
func (x *ParentCommit) ProtoReflect() protoreflect.Message
func (*ParentCommit) Reset ¶
func (x *ParentCommit) Reset()
func (*ParentCommit) String ¶
func (x *ParentCommit) String() string
type ParentHashes ¶
type ParentHashes struct {
Hashes [][]byte `protobuf:"bytes,1,rep,name=Hashes,proto3" json:"Hashes,omitempty"`
// contains filtered or unexported fields
}
func (*ParentHashes) Descriptor
deprecated
func (*ParentHashes) Descriptor() ([]byte, []int)
Deprecated: Use ParentHashes.ProtoReflect.Descriptor instead.
func (*ParentHashes) GetHashes ¶
func (x *ParentHashes) GetHashes() [][]byte
func (*ParentHashes) ProtoMessage ¶
func (*ParentHashes) ProtoMessage()
func (*ParentHashes) ProtoReflect ¶
func (x *ParentHashes) ProtoReflect() protoreflect.Message
func (*ParentHashes) Reset ¶
func (x *ParentHashes) Reset()
func (*ParentHashes) String ¶
func (x *ParentHashes) String() string
type Ref ¶
type Ref struct {
Ref *RefName `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
CommitId []byte `protobuf:"bytes,2,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
// contains filtered or unexported fields
}
`Ref` stands for Dataset Reference that can indirectly identify the Dataset revision of any commit. Refs aer not limited to the data in Dataset bucket. A Ref is either:
- branch => refers to the tip commit of this branch
- tag (not done yet)
- lead/individual commit id (sha hash)
func (*Ref) Descriptor
deprecated
func (*Ref) GetCommitId ¶
func (*Ref) ProtoMessage ¶
func (*Ref) ProtoMessage()
func (*Ref) ProtoReflect ¶
func (x *Ref) ProtoReflect() protoreflect.Message
type RefName ¶
type RefName struct {
// Types that are valid to be assigned to DatasetId:
//
// *RefName_DatasetUuid
// *RefName_DatasetIri
DatasetId isRefName_DatasetId `protobuf_oneof:"dataset_id"`
// ref_name is one of following:
// - branch => refers to the tip commit of this branch
// - tag (not implemented yet)
// - leaf or individual commit id (sha hash)
//
// Types that are valid to be assigned to RefName:
//
// *RefName_Branch
// *RefName_Leaf
RefName isRefName_RefName `protobuf_oneof:"ref_name"`
// contains filtered or unexported fields
}
func (*RefName) Descriptor
deprecated
func (*RefName) GetDatasetId ¶
func (x *RefName) GetDatasetId() isRefName_DatasetId
func (*RefName) GetDatasetIri ¶
func (*RefName) GetDatasetUuid ¶
func (*RefName) GetRefName ¶
func (x *RefName) GetRefName() isRefName_RefName
func (*RefName) ProtoMessage ¶
func (*RefName) ProtoMessage()
func (*RefName) ProtoReflect ¶
func (x *RefName) ProtoReflect() protoreflect.Message
type RefName_Branch ¶
type RefName_Branch struct {
Branch string `protobuf:"bytes,8,opt,name=branch,proto3,oneof"`
}
type RefName_DatasetIri ¶
type RefName_DatasetIri struct {
DatasetIri string `protobuf:"bytes,2,opt,name=dataset_iri,json=datasetIri,proto3,oneof"`
}
type RefName_DatasetUuid ¶
type RefName_DatasetUuid struct {
DatasetUuid []byte `protobuf:"bytes,1,opt,name=dataset_uuid,json=datasetUuid,proto3,oneof"`
}
type RefName_Leaf ¶
type RefName_Leaf struct {
Leaf []byte `protobuf:"bytes,10,opt,name=leaf,proto3,oneof"`
}
type RefServiceClient ¶
type RefServiceClient interface {
ListRefs(ctx context.Context, in *ListRefsRequest, opts ...grpc.CallOption) (*ListRefsResponse, error)
GetRef(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[GetRefRequest, Ref], error)
}
RefServiceClient is the client API for RefService 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 NewRefServiceClient ¶
func NewRefServiceClient(cc grpc.ClientConnInterface) RefServiceClient
type RefServiceServer ¶
type RefServiceServer interface {
ListRefs(context.Context, *ListRefsRequest) (*ListRefsResponse, error)
GetRef(grpc.ClientStreamingServer[GetRefRequest, Ref]) error
// contains filtered or unexported methods
}
RefServiceServer is the server API for RefService service. All implementations must embed UnimplementedRefServiceServer for forward compatibility.
type RefService_GetRefClient ¶
type RefService_GetRefClient = grpc.ClientStreamingClient[GetRefRequest, Ref]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RefService_GetRefServer ¶
type RefService_GetRefServer = grpc.ClientStreamingServer[GetRefRequest, Ref]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RemoveBranchRequest ¶
type RemoveBranchRequest struct {
Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
RepoName string `protobuf:"bytes,3,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveBranchRequest) Descriptor
deprecated
func (*RemoveBranchRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveBranchRequest.ProtoReflect.Descriptor instead.
func (*RemoveBranchRequest) GetBranch ¶
func (x *RemoveBranchRequest) GetBranch() string
func (*RemoveBranchRequest) GetRepoName ¶
func (x *RemoveBranchRequest) GetRepoName() string
func (*RemoveBranchRequest) GetUuid ¶
func (x *RemoveBranchRequest) GetUuid() []byte
func (*RemoveBranchRequest) ProtoMessage ¶
func (*RemoveBranchRequest) ProtoMessage()
func (*RemoveBranchRequest) ProtoReflect ¶
func (x *RemoveBranchRequest) ProtoReflect() protoreflect.Message
func (*RemoveBranchRequest) Reset ¶
func (x *RemoveBranchRequest) Reset()
func (*RemoveBranchRequest) String ¶
func (x *RemoveBranchRequest) String() string
type RemoveBranchResponse ¶
type RemoveBranchResponse struct {
// contains filtered or unexported fields
}
func (*RemoveBranchResponse) Descriptor
deprecated
func (*RemoveBranchResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveBranchResponse.ProtoReflect.Descriptor instead.
func (*RemoveBranchResponse) ProtoMessage ¶
func (*RemoveBranchResponse) ProtoMessage()
func (*RemoveBranchResponse) ProtoReflect ¶
func (x *RemoveBranchResponse) ProtoReflect() protoreflect.Message
func (*RemoveBranchResponse) Reset ¶
func (x *RemoveBranchResponse) Reset()
func (*RemoveBranchResponse) String ¶
func (x *RemoveBranchResponse) String() string
type RepoManagerServiceClient ¶
type RepoManagerServiceClient interface {
ListRepos(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposReply, error)
CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*CreateRepoReply, error)
DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*DeleteRepoReply, error)
}
RepoManagerServiceClient is the client API for RepoManagerService 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 NewRepoManagerServiceClient ¶
func NewRepoManagerServiceClient(cc grpc.ClientConnInterface) RepoManagerServiceClient
type RepoManagerServiceServer ¶
type RepoManagerServiceServer interface {
ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error)
CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoReply, error)
DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoReply, error)
// contains filtered or unexported methods
}
RepoManagerServiceServer is the server API for RepoManagerService service. All implementations must embed UnimplementedRepoManagerServiceServer for forward compatibility.
type RepositoryLogEntry ¶
type RepositoryLogEntry struct {
LogKey uint64 `protobuf:"varint,1,opt,name=log_key,json=logKey,proto3" json:"log_key,omitempty"`
Fields map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*RepositoryLogEntry) Descriptor
deprecated
func (*RepositoryLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use RepositoryLogEntry.ProtoReflect.Descriptor instead.
func (*RepositoryLogEntry) GetFields ¶
func (x *RepositoryLogEntry) GetFields() map[string]string
func (*RepositoryLogEntry) GetLogKey ¶
func (x *RepositoryLogEntry) GetLogKey() uint64
func (*RepositoryLogEntry) ProtoMessage ¶
func (*RepositoryLogEntry) ProtoMessage()
func (*RepositoryLogEntry) ProtoReflect ¶
func (x *RepositoryLogEntry) ProtoReflect() protoreflect.Message
func (*RepositoryLogEntry) Reset ¶
func (x *RepositoryLogEntry) Reset()
func (*RepositoryLogEntry) String ¶
func (x *RepositoryLogEntry) String() string
type SetBranchRequest ¶
type SetBranchRequest struct {
Uuid []byte `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
CommitHash []byte `protobuf:"bytes,3,opt,name=commitHash,proto3" json:"commitHash,omitempty"`
RepoName string `protobuf:"bytes,4,opt,name=repoName,proto3" json:"repoName,omitempty"`
// contains filtered or unexported fields
}
func (*SetBranchRequest) Descriptor
deprecated
func (*SetBranchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetBranchRequest.ProtoReflect.Descriptor instead.
func (*SetBranchRequest) GetBranch ¶
func (x *SetBranchRequest) GetBranch() string
func (*SetBranchRequest) GetCommitHash ¶
func (x *SetBranchRequest) GetCommitHash() []byte
func (*SetBranchRequest) GetRepoName ¶
func (x *SetBranchRequest) GetRepoName() string
func (*SetBranchRequest) GetUuid ¶
func (x *SetBranchRequest) GetUuid() []byte
func (*SetBranchRequest) ProtoMessage ¶
func (*SetBranchRequest) ProtoMessage()
func (*SetBranchRequest) ProtoReflect ¶
func (x *SetBranchRequest) ProtoReflect() protoreflect.Message
func (*SetBranchRequest) Reset ¶
func (x *SetBranchRequest) Reset()
func (*SetBranchRequest) String ¶
func (x *SetBranchRequest) String() string
type SetBranchResponse ¶
type SetBranchResponse struct {
// contains filtered or unexported fields
}
func (*SetBranchResponse) Descriptor
deprecated
func (*SetBranchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetBranchResponse.ProtoReflect.Descriptor instead.
func (*SetBranchResponse) ProtoMessage ¶
func (*SetBranchResponse) ProtoMessage()
func (*SetBranchResponse) ProtoReflect ¶
func (x *SetBranchResponse) ProtoReflect() protoreflect.Message
func (*SetBranchResponse) Reset ¶
func (x *SetBranchResponse) Reset()
func (*SetBranchResponse) String ¶
func (x *SetBranchResponse) String() string
type SyncFromBucketData ¶
type SyncFromBucketData struct {
BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"` // "ngr", "dsr", "c", "ds", "document_info"
Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
IsBucket bool `protobuf:"varint,4,opt,name=is_bucket,json=isBucket,proto3" json:"is_bucket,omitempty"` // true if this is a sub-bucket entry
SubKey []byte `protobuf:"bytes,5,opt,name=sub_key,json=subKey,proto3" json:"sub_key,omitempty"` // sub-key if is_bucket is true
SubValue []byte `protobuf:"bytes,6,opt,name=sub_value,json=subValue,proto3" json:"sub_value,omitempty"` // sub-value if is_bucket is true
// contains filtered or unexported fields
}
func (*SyncFromBucketData) Descriptor
deprecated
func (*SyncFromBucketData) Descriptor() ([]byte, []int)
Deprecated: Use SyncFromBucketData.ProtoReflect.Descriptor instead.
func (*SyncFromBucketData) GetBucketName ¶
func (x *SyncFromBucketData) GetBucketName() string
func (*SyncFromBucketData) GetIsBucket ¶
func (x *SyncFromBucketData) GetIsBucket() bool
func (*SyncFromBucketData) GetKey ¶
func (x *SyncFromBucketData) GetKey() []byte
func (*SyncFromBucketData) GetSubKey ¶
func (x *SyncFromBucketData) GetSubKey() []byte
func (*SyncFromBucketData) GetSubValue ¶
func (x *SyncFromBucketData) GetSubValue() []byte
func (*SyncFromBucketData) GetValue ¶
func (x *SyncFromBucketData) GetValue() []byte
func (*SyncFromBucketData) ProtoMessage ¶
func (*SyncFromBucketData) ProtoMessage()
func (*SyncFromBucketData) ProtoReflect ¶
func (x *SyncFromBucketData) ProtoReflect() protoreflect.Message
func (*SyncFromBucketData) Reset ¶
func (x *SyncFromBucketData) Reset()
func (*SyncFromBucketData) String ¶
func (x *SyncFromBucketData) String() string
type SyncFromMetadata ¶
type SyncFromMetadata struct {
// Initial metadata sent at the start of sync
RepoName string `protobuf:"bytes,1,opt,name=repoName,proto3" json:"repoName,omitempty"`
// Optional: list of dataset UUIDs to sync. If empty, sync all datasets.
DatasetIds [][]byte `protobuf:"bytes,2,rep,name=dataset_ids,json=datasetIds,proto3" json:"dataset_ids,omitempty"`
// Optional: branch name to sync. If empty or "*", sync all branches.
BranchName string `protobuf:"bytes,3,opt,name=branch_name,json=branchName,proto3" json:"branch_name,omitempty"`
// contains filtered or unexported fields
}
func (*SyncFromMetadata) Descriptor
deprecated
func (*SyncFromMetadata) Descriptor() ([]byte, []int)
Deprecated: Use SyncFromMetadata.ProtoReflect.Descriptor instead.
func (*SyncFromMetadata) GetBranchName ¶
func (x *SyncFromMetadata) GetBranchName() string
func (*SyncFromMetadata) GetDatasetIds ¶
func (x *SyncFromMetadata) GetDatasetIds() [][]byte
func (*SyncFromMetadata) GetRepoName ¶
func (x *SyncFromMetadata) GetRepoName() string
func (*SyncFromMetadata) ProtoMessage ¶
func (*SyncFromMetadata) ProtoMessage()
func (*SyncFromMetadata) ProtoReflect ¶
func (x *SyncFromMetadata) ProtoReflect() protoreflect.Message
func (*SyncFromMetadata) Reset ¶
func (x *SyncFromMetadata) Reset()
func (*SyncFromMetadata) String ¶
func (x *SyncFromMetadata) String() string
type SyncFromRequest ¶
type SyncFromRequest struct {
// Types that are valid to be assigned to Data:
//
// *SyncFromRequest_Metadata
// *SyncFromRequest_BucketData
Data isSyncFromRequest_Data `protobuf_oneof:"data"`
// contains filtered or unexported fields
}
func (*SyncFromRequest) Descriptor
deprecated
func (*SyncFromRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncFromRequest.ProtoReflect.Descriptor instead.
func (*SyncFromRequest) GetBucketData ¶
func (x *SyncFromRequest) GetBucketData() *SyncFromBucketData
func (*SyncFromRequest) GetData ¶
func (x *SyncFromRequest) GetData() isSyncFromRequest_Data
func (*SyncFromRequest) GetMetadata ¶
func (x *SyncFromRequest) GetMetadata() *SyncFromMetadata
func (*SyncFromRequest) ProtoMessage ¶
func (*SyncFromRequest) ProtoMessage()
func (*SyncFromRequest) ProtoReflect ¶
func (x *SyncFromRequest) ProtoReflect() protoreflect.Message
func (*SyncFromRequest) Reset ¶
func (x *SyncFromRequest) Reset()
func (*SyncFromRequest) String ¶
func (x *SyncFromRequest) String() string
type SyncFromRequest_BucketData ¶
type SyncFromRequest_BucketData struct {
BucketData *SyncFromBucketData `protobuf:"bytes,2,opt,name=bucket_data,json=bucketData,proto3,oneof"`
}
type SyncFromRequest_Metadata ¶
type SyncFromRequest_Metadata struct {
Metadata *SyncFromMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}
type SyncFromResponse ¶
type SyncFromResponse struct {
// Statistics about what was synced
NamedGraphRevisionsSynced int32 `` /* 141-byte string literal not displayed */
DatasetRevisionsSynced int32 `` /* 130-byte string literal not displayed */
DatasetsSynced int32 `protobuf:"varint,3,opt,name=datasets_synced,json=datasetsSynced,proto3" json:"datasets_synced,omitempty"`
CommitsSynced int32 `protobuf:"varint,4,opt,name=commits_synced,json=commitsSynced,proto3" json:"commits_synced,omitempty"`
DocumentInfoSynced int32 `protobuf:"varint,5,opt,name=document_info_synced,json=documentInfoSynced,proto3" json:"document_info_synced,omitempty"`
// contains filtered or unexported fields
}
func (*SyncFromResponse) Descriptor
deprecated
func (*SyncFromResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncFromResponse.ProtoReflect.Descriptor instead.
func (*SyncFromResponse) GetCommitsSynced ¶
func (x *SyncFromResponse) GetCommitsSynced() int32
func (*SyncFromResponse) GetDatasetRevisionsSynced ¶
func (x *SyncFromResponse) GetDatasetRevisionsSynced() int32
func (*SyncFromResponse) GetDatasetsSynced ¶
func (x *SyncFromResponse) GetDatasetsSynced() int32
func (*SyncFromResponse) GetDocumentInfoSynced ¶
func (x *SyncFromResponse) GetDocumentInfoSynced() int32
func (*SyncFromResponse) GetNamedGraphRevisionsSynced ¶
func (x *SyncFromResponse) GetNamedGraphRevisionsSynced() int32
func (*SyncFromResponse) ProtoMessage ¶
func (*SyncFromResponse) ProtoMessage()
func (*SyncFromResponse) ProtoReflect ¶
func (x *SyncFromResponse) ProtoReflect() protoreflect.Message
func (*SyncFromResponse) Reset ¶
func (x *SyncFromResponse) Reset()
func (*SyncFromResponse) String ¶
func (x *SyncFromResponse) String() string
type SyncToBucketData ¶
type SyncToBucketData struct {
BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"` // "ngr", "dsr", "c", "ds", "document_info"
Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
IsBucket bool `protobuf:"varint,4,opt,name=is_bucket,json=isBucket,proto3" json:"is_bucket,omitempty"` // true if this is a sub-bucket entry
SubKey []byte `protobuf:"bytes,5,opt,name=sub_key,json=subKey,proto3" json:"sub_key,omitempty"` // sub-key if is_bucket is true
SubValue []byte `protobuf:"bytes,6,opt,name=sub_value,json=subValue,proto3" json:"sub_value,omitempty"` // sub-value if is_bucket is true
// contains filtered or unexported fields
}
func (*SyncToBucketData) Descriptor
deprecated
func (*SyncToBucketData) Descriptor() ([]byte, []int)
Deprecated: Use SyncToBucketData.ProtoReflect.Descriptor instead.
func (*SyncToBucketData) GetBucketName ¶
func (x *SyncToBucketData) GetBucketName() string
func (*SyncToBucketData) GetIsBucket ¶
func (x *SyncToBucketData) GetIsBucket() bool
func (*SyncToBucketData) GetKey ¶
func (x *SyncToBucketData) GetKey() []byte
func (*SyncToBucketData) GetSubKey ¶
func (x *SyncToBucketData) GetSubKey() []byte
func (*SyncToBucketData) GetSubValue ¶
func (x *SyncToBucketData) GetSubValue() []byte
func (*SyncToBucketData) GetValue ¶
func (x *SyncToBucketData) GetValue() []byte
func (*SyncToBucketData) ProtoMessage ¶
func (*SyncToBucketData) ProtoMessage()
func (*SyncToBucketData) ProtoReflect ¶
func (x *SyncToBucketData) ProtoReflect() protoreflect.Message
func (*SyncToBucketData) Reset ¶
func (x *SyncToBucketData) Reset()
func (*SyncToBucketData) String ¶
func (x *SyncToBucketData) String() string
type SyncToComplete ¶
type SyncToComplete struct {
// Statistics about what was synced
NamedGraphRevisionsSynced int32 `` /* 141-byte string literal not displayed */
DatasetRevisionsSynced int32 `` /* 130-byte string literal not displayed */
DatasetsSynced int32 `protobuf:"varint,3,opt,name=datasets_synced,json=datasetsSynced,proto3" json:"datasets_synced,omitempty"`
CommitsSynced int32 `protobuf:"varint,4,opt,name=commits_synced,json=commitsSynced,proto3" json:"commits_synced,omitempty"`
DocumentInfoSynced int32 `protobuf:"varint,5,opt,name=document_info_synced,json=documentInfoSynced,proto3" json:"document_info_synced,omitempty"`
// contains filtered or unexported fields
}
func (*SyncToComplete) Descriptor
deprecated
func (*SyncToComplete) Descriptor() ([]byte, []int)
Deprecated: Use SyncToComplete.ProtoReflect.Descriptor instead.
func (*SyncToComplete) GetCommitsSynced ¶
func (x *SyncToComplete) GetCommitsSynced() int32
func (*SyncToComplete) GetDatasetRevisionsSynced ¶
func (x *SyncToComplete) GetDatasetRevisionsSynced() int32
func (*SyncToComplete) GetDatasetsSynced ¶
func (x *SyncToComplete) GetDatasetsSynced() int32
func (*SyncToComplete) GetDocumentInfoSynced ¶
func (x *SyncToComplete) GetDocumentInfoSynced() int32
func (*SyncToComplete) GetNamedGraphRevisionsSynced ¶
func (x *SyncToComplete) GetNamedGraphRevisionsSynced() int32
func (*SyncToComplete) ProtoMessage ¶
func (*SyncToComplete) ProtoMessage()
func (*SyncToComplete) ProtoReflect ¶
func (x *SyncToComplete) ProtoReflect() protoreflect.Message
func (*SyncToComplete) Reset ¶
func (x *SyncToComplete) Reset()
func (*SyncToComplete) String ¶
func (x *SyncToComplete) String() string
type SyncToMetadata ¶
type SyncToMetadata struct {
// Metadata for sync request
// Optional: list of dataset UUIDs to sync. If empty, sync all datasets.
DatasetIds [][]byte `protobuf:"bytes,1,rep,name=dataset_ids,json=datasetIds,proto3" json:"dataset_ids,omitempty"`
// Optional: branch name to sync. If empty or "*", sync all branches.
BranchName string `protobuf:"bytes,2,opt,name=branch_name,json=branchName,proto3" json:"branch_name,omitempty"`
// contains filtered or unexported fields
}
func (*SyncToMetadata) Descriptor
deprecated
func (*SyncToMetadata) Descriptor() ([]byte, []int)
Deprecated: Use SyncToMetadata.ProtoReflect.Descriptor instead.
func (*SyncToMetadata) GetBranchName ¶
func (x *SyncToMetadata) GetBranchName() string
func (*SyncToMetadata) GetDatasetIds ¶
func (x *SyncToMetadata) GetDatasetIds() [][]byte
func (*SyncToMetadata) ProtoMessage ¶
func (*SyncToMetadata) ProtoMessage()
func (*SyncToMetadata) ProtoReflect ¶
func (x *SyncToMetadata) ProtoReflect() protoreflect.Message
func (*SyncToMetadata) Reset ¶
func (x *SyncToMetadata) Reset()
func (*SyncToMetadata) String ¶
func (x *SyncToMetadata) String() string
type SyncToRequest ¶
type SyncToRequest struct {
// Initial request to start sync
Metadata *SyncToMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
SyncTo is used for remote to local sync (server streams data to client)
func (*SyncToRequest) Descriptor
deprecated
func (*SyncToRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncToRequest.ProtoReflect.Descriptor instead.
func (*SyncToRequest) GetMetadata ¶
func (x *SyncToRequest) GetMetadata() *SyncToMetadata
func (*SyncToRequest) ProtoMessage ¶
func (*SyncToRequest) ProtoMessage()
func (*SyncToRequest) ProtoReflect ¶
func (x *SyncToRequest) ProtoReflect() protoreflect.Message
func (*SyncToRequest) Reset ¶
func (x *SyncToRequest) Reset()
func (*SyncToRequest) String ¶
func (x *SyncToRequest) String() string
type SyncToResponse ¶
type SyncToResponse struct {
// Types that are valid to be assigned to Data:
//
// *SyncToResponse_BucketData
// *SyncToResponse_Complete
Data isSyncToResponse_Data `protobuf_oneof:"data"`
// contains filtered or unexported fields
}
func (*SyncToResponse) Descriptor
deprecated
func (*SyncToResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncToResponse.ProtoReflect.Descriptor instead.
func (*SyncToResponse) GetBucketData ¶
func (x *SyncToResponse) GetBucketData() *SyncToBucketData
func (*SyncToResponse) GetComplete ¶
func (x *SyncToResponse) GetComplete() *SyncToComplete
func (*SyncToResponse) GetData ¶
func (x *SyncToResponse) GetData() isSyncToResponse_Data
func (*SyncToResponse) ProtoMessage ¶
func (*SyncToResponse) ProtoMessage()
func (*SyncToResponse) ProtoReflect ¶
func (x *SyncToResponse) ProtoReflect() protoreflect.Message
func (*SyncToResponse) Reset ¶
func (x *SyncToResponse) Reset()
func (*SyncToResponse) String ¶
func (x *SyncToResponse) String() string
type SyncToResponse_BucketData ¶
type SyncToResponse_BucketData struct {
BucketData *SyncToBucketData `protobuf:"bytes,1,opt,name=bucket_data,json=bucketData,proto3,oneof"`
}
type SyncToResponse_Complete ¶
type SyncToResponse_Complete struct {
Complete *SyncToComplete `protobuf:"bytes,2,opt,name=complete,proto3,oneof"`
}
type UnimplementedCommitServiceServer ¶
type UnimplementedCommitServiceServer struct{}
UnimplementedCommitServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCommitServiceServer) CompareCommits ¶
func (UnimplementedCommitServiceServer) CompareCommits(context.Context, *CompareCommitsRequest) (*CompareCommitsResponse, error)
func (UnimplementedCommitServiceServer) CreateCommit ¶
func (UnimplementedCommitServiceServer) CreateCommit(context.Context, *CreateCommitRequest) (*CreateCommitResponse, error)
func (UnimplementedCommitServiceServer) GetCommit ¶
func (UnimplementedCommitServiceServer) GetCommit(grpc.ClientStreamingServer[GetCommitRequest, Commit]) error
func (UnimplementedCommitServiceServer) GetCommitDetailsBatch ¶
func (UnimplementedCommitServiceServer) GetCommitDetailsBatch(context.Context, *GetCommitDetailsBatchRequest) (*GetCommitDetailsBatchResponse, error)
func (UnimplementedCommitServiceServer) ListCommits ¶
func (UnimplementedCommitServiceServer) ListCommits(grpc.ClientStreamingServer[ListCommitsRequest, ListCommitsResponse]) error
type UnimplementedDatasetServiceServer ¶
type UnimplementedDatasetServiceServer struct{}
UnimplementedDatasetServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedDatasetServiceServer) CreateDataset ¶
func (UnimplementedDatasetServiceServer) CreateDataset(context.Context, *CreateDatasetRequest) (*Dataset, error)
func (UnimplementedDatasetServiceServer) Document ¶
func (UnimplementedDatasetServiceServer) Document(*DocumentRequest, grpc.ServerStreamingServer[DocumentResponse]) error
func (UnimplementedDatasetServiceServer) DocumentDelete ¶
func (UnimplementedDatasetServiceServer) DocumentDelete(context.Context, *DocumentDeleteRequest) (*DocumentDeleteResponse, error)
func (UnimplementedDatasetServiceServer) DocumentSet ¶
func (UnimplementedDatasetServiceServer) DocumentSet(grpc.ClientStreamingServer[DocumentSetRequest, DocumentSetResponse]) error
func (UnimplementedDatasetServiceServer) Documents ¶
func (UnimplementedDatasetServiceServer) Documents(context.Context, *DocumentsListRequest) (*DocumentsListResponse, error)
func (UnimplementedDatasetServiceServer) DownloadNamedGraphRevision ¶
func (UnimplementedDatasetServiceServer) DownloadNamedGraphRevision(*DownloadNamedGraphRevisionRequest, grpc.ServerStreamingServer[DownloadNamedGraphRevisionResponse]) error
func (UnimplementedDatasetServiceServer) FetchDatasets ¶
func (UnimplementedDatasetServiceServer) FetchDatasets(grpc.BidiStreamingServer[DatasetInquiry, DatasetObject]) error
func (UnimplementedDatasetServiceServer) FindCommonParentRevision ¶
func (UnimplementedDatasetServiceServer) FindCommonParentRevision(context.Context, *FindCommonParentRevisionRequest) (*FindCommonParentRevisionResponse, error)
func (UnimplementedDatasetServiceServer) GetBleveInfo ¶
func (UnimplementedDatasetServiceServer) GetBleveInfo(context.Context, *GetRepoBleveInfoRequest) (*GetRepoBleveInfoResponse, error)
func (UnimplementedDatasetServiceServer) GetBranches ¶
func (UnimplementedDatasetServiceServer) GetBranches(context.Context, *GetBranchesRequest) (*GetBranchesResponse, error)
func (UnimplementedDatasetServiceServer) GetDataset ¶
func (UnimplementedDatasetServiceServer) GetDataset(grpc.ClientStreamingServer[GetDatasetRequest, Dataset]) error
func (UnimplementedDatasetServiceServer) GetLeafCommits ¶
func (UnimplementedDatasetServiceServer) GetLeafCommits(context.Context, *GetLeafCommitsRequest) (*GetLeafCommitsResponse, error)
func (UnimplementedDatasetServiceServer) GetRepositoryInfo ¶
func (UnimplementedDatasetServiceServer) GetRepositoryInfo(context.Context, *GetRepositoryInfoRequest) (*GetRepositoryInfoResponse, error)
func (UnimplementedDatasetServiceServer) GetRepositoryLog ¶
func (UnimplementedDatasetServiceServer) GetRepositoryLog(context.Context, *GetRepositoryLogRequest) (*GetRepositoryLogResponse, error)
func (UnimplementedDatasetServiceServer) ListDatasets ¶
func (UnimplementedDatasetServiceServer) ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
func (UnimplementedDatasetServiceServer) PushDatasets ¶
func (UnimplementedDatasetServiceServer) PushDatasets(grpc.BidiStreamingServer[DatasetSuggestion, DatasetInquiry]) error
func (UnimplementedDatasetServiceServer) RemoveBranch ¶
func (UnimplementedDatasetServiceServer) RemoveBranch(context.Context, *RemoveBranchRequest) (*RemoveBranchResponse, error)
func (UnimplementedDatasetServiceServer) SetBranch ¶
func (UnimplementedDatasetServiceServer) SetBranch(context.Context, *SetBranchRequest) (*SetBranchResponse, error)
func (UnimplementedDatasetServiceServer) SyncFrom ¶
func (UnimplementedDatasetServiceServer) SyncFrom(grpc.ClientStreamingServer[SyncFromRequest, SyncFromResponse]) error
func (UnimplementedDatasetServiceServer) SyncTo ¶
func (UnimplementedDatasetServiceServer) SyncTo(*SyncToRequest, grpc.ServerStreamingServer[SyncToResponse]) error
type UnimplementedRefServiceServer ¶
type UnimplementedRefServiceServer struct{}
UnimplementedRefServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedRefServiceServer) GetRef ¶
func (UnimplementedRefServiceServer) GetRef(grpc.ClientStreamingServer[GetRefRequest, Ref]) error
func (UnimplementedRefServiceServer) ListRefs ¶
func (UnimplementedRefServiceServer) ListRefs(context.Context, *ListRefsRequest) (*ListRefsResponse, error)
type UnimplementedRepoManagerServiceServer ¶
type UnimplementedRepoManagerServiceServer struct{}
UnimplementedRepoManagerServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedRepoManagerServiceServer) CreateRepo ¶
func (UnimplementedRepoManagerServiceServer) CreateRepo(context.Context, *CreateRepoRequest) (*CreateRepoReply, error)
func (UnimplementedRepoManagerServiceServer) DeleteRepo ¶
func (UnimplementedRepoManagerServiceServer) DeleteRepo(context.Context, *DeleteRepoRequest) (*DeleteRepoReply, error)
func (UnimplementedRepoManagerServiceServer) ListRepos ¶
func (UnimplementedRepoManagerServiceServer) ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error)
type UnsafeCommitServiceServer ¶
type UnsafeCommitServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCommitServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommitServiceServer will result in compilation errors.
type UnsafeDatasetServiceServer ¶
type UnsafeDatasetServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDatasetServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatasetServiceServer will result in compilation errors.
type UnsafeRefServiceServer ¶
type UnsafeRefServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRefServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RefServiceServer will result in compilation errors.
type UnsafeRepoManagerServiceServer ¶
type UnsafeRepoManagerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRepoManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RepoManagerServiceServer will result in compilation errors.