grpcapi

package
v0.17.0 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KopiaRepository_Session_FullMethodName = "/kopia_repository.KopiaRepository/Session"
)

Variables

View Source
var (
	ErrorResponse_Code_name = map[int32]string{
		0: "UNKNOWN_ERROR",
		1: "CLIENT_ERROR",
		2: "CONTENT_NOT_FOUND",
		3: "MANIFEST_NOT_FOUND",
		4: "OBJECT_NOT_FOUND",
		5: "ACCESS_DENIED",
		6: "STREAM_BROKEN",
	}
	ErrorResponse_Code_value = map[string]int32{
		"UNKNOWN_ERROR":      0,
		"CLIENT_ERROR":       1,
		"CONTENT_NOT_FOUND":  2,
		"MANIFEST_NOT_FOUND": 3,
		"OBJECT_NOT_FOUND":   4,
		"ACCESS_DENIED":      5,
		"STREAM_BROKEN":      6,
	}
)

Enum value maps for ErrorResponse_Code.

View Source
var File_repository_server_proto protoreflect.FileDescriptor
View Source
var KopiaRepository_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kopia_repository.KopiaRepository",
	HandlerType: (*KopiaRepositoryServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Session",
			Handler:       _KopiaRepository_Session_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "repository_server.proto",
}

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

Functions

func RegisterKopiaRepositoryServer

func RegisterKopiaRepositoryServer(s grpc.ServiceRegistrar, srv KopiaRepositoryServer)

Types

type ApplyRetentionPolicyRequest added in v0.14.0

type ApplyRetentionPolicyRequest struct {
	SourcePath   string `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	ReallyDelete bool   `protobuf:"varint,2,opt,name=really_delete,json=reallyDelete,proto3" json:"really_delete,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRetentionPolicyRequest) Descriptor deprecated added in v0.14.0

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

Deprecated: Use ApplyRetentionPolicyRequest.ProtoReflect.Descriptor instead.

func (*ApplyRetentionPolicyRequest) GetReallyDelete added in v0.14.0

func (x *ApplyRetentionPolicyRequest) GetReallyDelete() bool

func (*ApplyRetentionPolicyRequest) GetSourcePath added in v0.14.0

func (x *ApplyRetentionPolicyRequest) GetSourcePath() string

func (*ApplyRetentionPolicyRequest) ProtoMessage added in v0.14.0

func (*ApplyRetentionPolicyRequest) ProtoMessage()

func (*ApplyRetentionPolicyRequest) ProtoReflect added in v0.14.0

func (*ApplyRetentionPolicyRequest) Reset added in v0.14.0

func (x *ApplyRetentionPolicyRequest) Reset()

func (*ApplyRetentionPolicyRequest) String added in v0.14.0

func (x *ApplyRetentionPolicyRequest) String() string

type ApplyRetentionPolicyResponse added in v0.14.0

type ApplyRetentionPolicyResponse struct {
	ManifestIds []string `protobuf:"bytes,1,rep,name=manifest_ids,json=manifestIds,proto3" json:"manifest_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRetentionPolicyResponse) Descriptor deprecated added in v0.14.0

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

Deprecated: Use ApplyRetentionPolicyResponse.ProtoReflect.Descriptor instead.

func (*ApplyRetentionPolicyResponse) GetManifestIds added in v0.14.0

func (x *ApplyRetentionPolicyResponse) GetManifestIds() []string

func (*ApplyRetentionPolicyResponse) ProtoMessage added in v0.14.0

func (*ApplyRetentionPolicyResponse) ProtoMessage()

func (*ApplyRetentionPolicyResponse) ProtoReflect added in v0.14.0

func (*ApplyRetentionPolicyResponse) Reset added in v0.14.0

func (x *ApplyRetentionPolicyResponse) Reset()

func (*ApplyRetentionPolicyResponse) String added in v0.14.0

type ContentInfo

type ContentInfo struct {
	Id               string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PackedLength     uint32 `protobuf:"varint,2,opt,name=packed_length,json=packedLength,proto3" json:"packed_length,omitempty"`
	TimestampSeconds int64  `protobuf:"varint,3,opt,name=timestamp_seconds,json=timestampSeconds,proto3" json:"timestamp_seconds,omitempty"`
	PackBlobId       string `protobuf:"bytes,4,opt,name=pack_blob_id,json=packBlobId,proto3" json:"pack_blob_id,omitempty"`
	PackOffset       uint32 `protobuf:"varint,5,opt,name=pack_offset,json=packOffset,proto3" json:"pack_offset,omitempty"`
	Deleted          bool   `protobuf:"varint,6,opt,name=deleted,proto3" json:"deleted,omitempty"`
	FormatVersion    uint32 `protobuf:"varint,7,opt,name=format_version,json=formatVersion,proto3" json:"format_version,omitempty"`
	OriginalLength   uint32 `protobuf:"varint,8,opt,name=original_length,json=originalLength,proto3" json:"original_length,omitempty"`
	// contains filtered or unexported fields
}

corresponds to content.Info

func (*ContentInfo) Descriptor deprecated

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

Deprecated: Use ContentInfo.ProtoReflect.Descriptor instead.

func (*ContentInfo) GetDeleted

func (x *ContentInfo) GetDeleted() bool

func (*ContentInfo) GetFormatVersion

func (x *ContentInfo) GetFormatVersion() uint32

func (*ContentInfo) GetId

func (x *ContentInfo) GetId() string

func (*ContentInfo) GetOriginalLength added in v0.9.0

func (x *ContentInfo) GetOriginalLength() uint32

func (*ContentInfo) GetPackBlobId

func (x *ContentInfo) GetPackBlobId() string

func (*ContentInfo) GetPackOffset

func (x *ContentInfo) GetPackOffset() uint32

func (*ContentInfo) GetPackedLength added in v0.9.0

func (x *ContentInfo) GetPackedLength() uint32

func (*ContentInfo) GetTimestampSeconds

func (x *ContentInfo) GetTimestampSeconds() int64

func (*ContentInfo) ProtoMessage

func (*ContentInfo) ProtoMessage()

func (*ContentInfo) ProtoReflect

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

func (*ContentInfo) Reset

func (x *ContentInfo) Reset()

func (*ContentInfo) String

func (x *ContentInfo) String() string

type DeleteManifestRequest

type DeleteManifestRequest struct {
	ManifestId string `protobuf:"bytes,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteManifestRequest) Descriptor deprecated

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

Deprecated: Use DeleteManifestRequest.ProtoReflect.Descriptor instead.

func (*DeleteManifestRequest) GetManifestId

func (x *DeleteManifestRequest) GetManifestId() string

func (*DeleteManifestRequest) ProtoMessage

func (*DeleteManifestRequest) ProtoMessage()

func (*DeleteManifestRequest) ProtoReflect

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

func (*DeleteManifestRequest) Reset

func (x *DeleteManifestRequest) Reset()

func (*DeleteManifestRequest) String

func (x *DeleteManifestRequest) String() string

type DeleteManifestResponse

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

func (*DeleteManifestResponse) Descriptor deprecated

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

Deprecated: Use DeleteManifestResponse.ProtoReflect.Descriptor instead.

func (*DeleteManifestResponse) ProtoMessage

func (*DeleteManifestResponse) ProtoMessage()

func (*DeleteManifestResponse) ProtoReflect

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

func (*DeleteManifestResponse) Reset

func (x *DeleteManifestResponse) Reset()

func (*DeleteManifestResponse) String

func (x *DeleteManifestResponse) String() string

type ErrorResponse

type ErrorResponse struct {
	Code    ErrorResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=kopia_repository.ErrorResponse_Code" json:"code,omitempty"`
	Message string             `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ErrorResponse can be sent in response to any request.

func (*ErrorResponse) Descriptor deprecated

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

Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.

func (*ErrorResponse) GetCode

func (x *ErrorResponse) GetCode() ErrorResponse_Code

func (*ErrorResponse) GetMessage

func (x *ErrorResponse) GetMessage() string

func (*ErrorResponse) ProtoMessage

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoReflect

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

func (*ErrorResponse) Reset

func (x *ErrorResponse) Reset()

func (*ErrorResponse) String

func (x *ErrorResponse) String() string

type ErrorResponse_Code

type ErrorResponse_Code int32
const (
	ErrorResponse_UNKNOWN_ERROR      ErrorResponse_Code = 0
	ErrorResponse_CLIENT_ERROR       ErrorResponse_Code = 1
	ErrorResponse_CONTENT_NOT_FOUND  ErrorResponse_Code = 2
	ErrorResponse_MANIFEST_NOT_FOUND ErrorResponse_Code = 3
	ErrorResponse_OBJECT_NOT_FOUND   ErrorResponse_Code = 4
	ErrorResponse_ACCESS_DENIED      ErrorResponse_Code = 5
	ErrorResponse_STREAM_BROKEN      ErrorResponse_Code = 6
)

func (ErrorResponse_Code) Descriptor

func (ErrorResponse_Code) Enum

func (ErrorResponse_Code) EnumDescriptor deprecated

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

Deprecated: Use ErrorResponse_Code.Descriptor instead.

func (ErrorResponse_Code) Number

func (ErrorResponse_Code) String

func (x ErrorResponse_Code) String() string

func (ErrorResponse_Code) Type

type FindManifestsRequest

type FindManifestsRequest struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// if set to non-zero, the server will return up to N entries.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

func (*FindManifestsRequest) Descriptor deprecated

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

Deprecated: Use FindManifestsRequest.ProtoReflect.Descriptor instead.

func (*FindManifestsRequest) GetLabels

func (x *FindManifestsRequest) GetLabels() map[string]string

func (*FindManifestsRequest) GetPageSize added in v0.13.0

func (x *FindManifestsRequest) GetPageSize() int32

func (*FindManifestsRequest) ProtoMessage

func (*FindManifestsRequest) ProtoMessage()

func (*FindManifestsRequest) ProtoReflect

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

func (*FindManifestsRequest) Reset

func (x *FindManifestsRequest) Reset()

func (*FindManifestsRequest) String

func (x *FindManifestsRequest) String() string

type FindManifestsResponse

type FindManifestsResponse struct {
	Metadata []*ManifestEntryMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*FindManifestsResponse) Descriptor deprecated

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

Deprecated: Use FindManifestsResponse.ProtoReflect.Descriptor instead.

func (*FindManifestsResponse) GetMetadata

func (x *FindManifestsResponse) GetMetadata() []*ManifestEntryMetadata

func (*FindManifestsResponse) ProtoMessage

func (*FindManifestsResponse) ProtoMessage()

func (*FindManifestsResponse) ProtoReflect

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

func (*FindManifestsResponse) Reset

func (x *FindManifestsResponse) Reset()

func (*FindManifestsResponse) String

func (x *FindManifestsResponse) String() string

type FlushRequest

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

func (*FlushRequest) Descriptor deprecated

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

Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.

func (*FlushRequest) ProtoMessage

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) ProtoReflect

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

func (*FlushRequest) Reset

func (x *FlushRequest) Reset()

func (*FlushRequest) String

func (x *FlushRequest) String() string

type FlushResponse

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

func (*FlushResponse) Descriptor deprecated

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) ProtoMessage

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect

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

func (*FlushResponse) Reset

func (x *FlushResponse) Reset()

func (*FlushResponse) String

func (x *FlushResponse) String() string

type GetContentInfoRequest

type GetContentInfoRequest struct {
	ContentId string `protobuf:"bytes,1,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContentInfoRequest) Descriptor deprecated

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

Deprecated: Use GetContentInfoRequest.ProtoReflect.Descriptor instead.

func (*GetContentInfoRequest) GetContentId

func (x *GetContentInfoRequest) GetContentId() string

func (*GetContentInfoRequest) ProtoMessage

func (*GetContentInfoRequest) ProtoMessage()

func (*GetContentInfoRequest) ProtoReflect

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

func (*GetContentInfoRequest) Reset

func (x *GetContentInfoRequest) Reset()

func (*GetContentInfoRequest) String

func (x *GetContentInfoRequest) String() string

type GetContentInfoResponse

type GetContentInfoResponse struct {
	Info *ContentInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContentInfoResponse) Descriptor deprecated

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

Deprecated: Use GetContentInfoResponse.ProtoReflect.Descriptor instead.

func (*GetContentInfoResponse) GetInfo

func (x *GetContentInfoResponse) GetInfo() *ContentInfo

func (*GetContentInfoResponse) ProtoMessage

func (*GetContentInfoResponse) ProtoMessage()

func (*GetContentInfoResponse) ProtoReflect

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

func (*GetContentInfoResponse) Reset

func (x *GetContentInfoResponse) Reset()

func (*GetContentInfoResponse) String

func (x *GetContentInfoResponse) String() string

type GetContentRequest

type GetContentRequest struct {
	ContentId string `protobuf:"bytes,1,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContentRequest) Descriptor deprecated

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

Deprecated: Use GetContentRequest.ProtoReflect.Descriptor instead.

func (*GetContentRequest) GetContentId

func (x *GetContentRequest) GetContentId() string

func (*GetContentRequest) ProtoMessage

func (*GetContentRequest) ProtoMessage()

func (*GetContentRequest) ProtoReflect

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

func (*GetContentRequest) Reset

func (x *GetContentRequest) Reset()

func (*GetContentRequest) String

func (x *GetContentRequest) String() string

type GetContentResponse

type GetContentResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetContentResponse) Descriptor deprecated

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

Deprecated: Use GetContentResponse.ProtoReflect.Descriptor instead.

func (*GetContentResponse) GetData

func (x *GetContentResponse) GetData() []byte

func (*GetContentResponse) ProtoMessage

func (*GetContentResponse) ProtoMessage()

func (*GetContentResponse) ProtoReflect

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

func (*GetContentResponse) Reset

func (x *GetContentResponse) Reset()

func (*GetContentResponse) String

func (x *GetContentResponse) String() string

type GetManifestRequest

type GetManifestRequest struct {
	ManifestId string `protobuf:"bytes,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetManifestRequest) Descriptor deprecated

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

Deprecated: Use GetManifestRequest.ProtoReflect.Descriptor instead.

func (*GetManifestRequest) GetManifestId

func (x *GetManifestRequest) GetManifestId() string

func (*GetManifestRequest) ProtoMessage

func (*GetManifestRequest) ProtoMessage()

func (*GetManifestRequest) ProtoReflect

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

func (*GetManifestRequest) Reset

func (x *GetManifestRequest) Reset()

func (*GetManifestRequest) String

func (x *GetManifestRequest) String() string

type GetManifestResponse

type GetManifestResponse struct {
	JsonData []byte                 `protobuf:"bytes,1,opt,name=json_data,json=jsonData,proto3" json:"json_data,omitempty"`
	Metadata *ManifestEntryMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*GetManifestResponse) Descriptor deprecated

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

Deprecated: Use GetManifestResponse.ProtoReflect.Descriptor instead.

func (*GetManifestResponse) GetJsonData

func (x *GetManifestResponse) GetJsonData() []byte

func (*GetManifestResponse) GetMetadata

func (x *GetManifestResponse) GetMetadata() *ManifestEntryMetadata

func (*GetManifestResponse) ProtoMessage

func (*GetManifestResponse) ProtoMessage()

func (*GetManifestResponse) ProtoReflect

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

func (*GetManifestResponse) Reset

func (x *GetManifestResponse) Reset()

func (*GetManifestResponse) String

func (x *GetManifestResponse) String() string

type InitializeSessionRequest

type InitializeSessionRequest struct {
	Purpose  string `protobuf:"bytes,1,opt,name=purpose,proto3" json:"purpose,omitempty"`
	ReadOnly bool   `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// contains filtered or unexported fields
}

InitializeSessionRequest must be sent by the client as the first request in a session.

func (*InitializeSessionRequest) Descriptor deprecated

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

Deprecated: Use InitializeSessionRequest.ProtoReflect.Descriptor instead.

func (*InitializeSessionRequest) GetPurpose

func (x *InitializeSessionRequest) GetPurpose() string

func (*InitializeSessionRequest) GetReadOnly

func (x *InitializeSessionRequest) GetReadOnly() bool

func (*InitializeSessionRequest) ProtoMessage

func (*InitializeSessionRequest) ProtoMessage()

func (*InitializeSessionRequest) ProtoReflect

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

func (*InitializeSessionRequest) Reset

func (x *InitializeSessionRequest) Reset()

func (*InitializeSessionRequest) String

func (x *InitializeSessionRequest) String() string

type InitializeSessionResponse

type InitializeSessionResponse struct {
	Parameters *RepositoryParameters `protobuf:"bytes,1,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

InitializeSessionResponse will be sent as the first response by the server.

func (*InitializeSessionResponse) Descriptor deprecated

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

Deprecated: Use InitializeSessionResponse.ProtoReflect.Descriptor instead.

func (*InitializeSessionResponse) GetParameters

func (x *InitializeSessionResponse) GetParameters() *RepositoryParameters

func (*InitializeSessionResponse) ProtoMessage

func (*InitializeSessionResponse) ProtoMessage()

func (*InitializeSessionResponse) ProtoReflect

func (*InitializeSessionResponse) Reset

func (x *InitializeSessionResponse) Reset()

func (*InitializeSessionResponse) String

func (x *InitializeSessionResponse) String() string

type KopiaRepositoryClient

type KopiaRepositoryClient interface {
	// Session starts a long-running repository session.
	Session(ctx context.Context, opts ...grpc.CallOption) (KopiaRepository_SessionClient, error)
}

KopiaRepositoryClient is the client API for KopiaRepository service.

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

type KopiaRepositoryServer

type KopiaRepositoryServer interface {
	// Session starts a long-running repository session.
	Session(KopiaRepository_SessionServer) error
	// contains filtered or unexported methods
}

KopiaRepositoryServer is the server API for KopiaRepository service. All implementations must embed UnimplementedKopiaRepositoryServer for forward compatibility

type KopiaRepository_SessionClient

type KopiaRepository_SessionClient interface {
	Send(*SessionRequest) error
	Recv() (*SessionResponse, error)
	grpc.ClientStream
}

type KopiaRepository_SessionServer

type KopiaRepository_SessionServer interface {
	Send(*SessionResponse) error
	Recv() (*SessionRequest, error)
	grpc.ServerStream
}

type ManifestEntryMetadata

type ManifestEntryMetadata struct {
	Id           string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ModTimeNanos int64             `protobuf:"varint,2,opt,name=mod_time_nanos,json=modTimeNanos,proto3" json:"mod_time_nanos,omitempty"`
	Length       int32             `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	Labels       map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

corresponds to manifest.EntryMetadata

func (*ManifestEntryMetadata) Descriptor deprecated

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

Deprecated: Use ManifestEntryMetadata.ProtoReflect.Descriptor instead.

func (*ManifestEntryMetadata) GetId

func (x *ManifestEntryMetadata) GetId() string

func (*ManifestEntryMetadata) GetLabels

func (x *ManifestEntryMetadata) GetLabels() map[string]string

func (*ManifestEntryMetadata) GetLength

func (x *ManifestEntryMetadata) GetLength() int32

func (*ManifestEntryMetadata) GetModTimeNanos

func (x *ManifestEntryMetadata) GetModTimeNanos() int64

func (*ManifestEntryMetadata) ProtoMessage

func (*ManifestEntryMetadata) ProtoMessage()

func (*ManifestEntryMetadata) ProtoReflect

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

func (*ManifestEntryMetadata) Reset

func (x *ManifestEntryMetadata) Reset()

func (*ManifestEntryMetadata) String

func (x *ManifestEntryMetadata) String() string

type PrefetchContentsRequest added in v0.10.7

type PrefetchContentsRequest struct {
	ContentIds []string `protobuf:"bytes,1,rep,name=content_ids,json=contentIds,proto3" json:"content_ids,omitempty"`
	Hint       string   `protobuf:"bytes,2,opt,name=hint,proto3" json:"hint,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefetchContentsRequest) Descriptor deprecated added in v0.10.7

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

Deprecated: Use PrefetchContentsRequest.ProtoReflect.Descriptor instead.

func (*PrefetchContentsRequest) GetContentIds added in v0.10.7

func (x *PrefetchContentsRequest) GetContentIds() []string

func (*PrefetchContentsRequest) GetHint added in v0.10.7

func (x *PrefetchContentsRequest) GetHint() string

func (*PrefetchContentsRequest) ProtoMessage added in v0.10.7

func (*PrefetchContentsRequest) ProtoMessage()

func (*PrefetchContentsRequest) ProtoReflect added in v0.10.7

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

func (*PrefetchContentsRequest) Reset added in v0.10.7

func (x *PrefetchContentsRequest) Reset()

func (*PrefetchContentsRequest) String added in v0.10.7

func (x *PrefetchContentsRequest) String() string

type PrefetchContentsResponse added in v0.10.7

type PrefetchContentsResponse struct {
	ContentIds []string `protobuf:"bytes,1,rep,name=content_ids,json=contentIds,proto3" json:"content_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefetchContentsResponse) Descriptor deprecated added in v0.10.7

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

Deprecated: Use PrefetchContentsResponse.ProtoReflect.Descriptor instead.

func (*PrefetchContentsResponse) GetContentIds added in v0.10.7

func (x *PrefetchContentsResponse) GetContentIds() []string

func (*PrefetchContentsResponse) ProtoMessage added in v0.10.7

func (*PrefetchContentsResponse) ProtoMessage()

func (*PrefetchContentsResponse) ProtoReflect added in v0.10.7

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

func (*PrefetchContentsResponse) Reset added in v0.10.7

func (x *PrefetchContentsResponse) Reset()

func (*PrefetchContentsResponse) String added in v0.10.7

func (x *PrefetchContentsResponse) String() string

type PutManifestRequest

type PutManifestRequest struct {
	JsonData []byte            `protobuf:"bytes,1,opt,name=json_data,json=jsonData,proto3" json:"json_data,omitempty"`
	Labels   map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PutManifestRequest) Descriptor deprecated

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

Deprecated: Use PutManifestRequest.ProtoReflect.Descriptor instead.

func (*PutManifestRequest) GetJsonData

func (x *PutManifestRequest) GetJsonData() []byte

func (*PutManifestRequest) GetLabels

func (x *PutManifestRequest) GetLabels() map[string]string

func (*PutManifestRequest) ProtoMessage

func (*PutManifestRequest) ProtoMessage()

func (*PutManifestRequest) ProtoReflect

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

func (*PutManifestRequest) Reset

func (x *PutManifestRequest) Reset()

func (*PutManifestRequest) String

func (x *PutManifestRequest) String() string

type PutManifestResponse

type PutManifestResponse struct {
	ManifestId string `protobuf:"bytes,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PutManifestResponse) Descriptor deprecated

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

Deprecated: Use PutManifestResponse.ProtoReflect.Descriptor instead.

func (*PutManifestResponse) GetManifestId

func (x *PutManifestResponse) GetManifestId() string

func (*PutManifestResponse) ProtoMessage

func (*PutManifestResponse) ProtoMessage()

func (*PutManifestResponse) ProtoReflect

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

func (*PutManifestResponse) Reset

func (x *PutManifestResponse) Reset()

func (*PutManifestResponse) String

func (x *PutManifestResponse) String() string

type RepositoryParameters

type RepositoryParameters struct {
	HashFunction               string `protobuf:"bytes,1,opt,name=hash_function,json=hashFunction,proto3" json:"hash_function,omitempty"`
	HmacSecret                 []byte `protobuf:"bytes,2,opt,name=hmac_secret,json=hmacSecret,proto3" json:"hmac_secret,omitempty"`
	Splitter                   string `protobuf:"bytes,3,opt,name=splitter,proto3" json:"splitter,omitempty"`
	SupportsContentCompression bool   `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

RepositoryParameters describes repository parameters.

func (*RepositoryParameters) Descriptor deprecated

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

Deprecated: Use RepositoryParameters.ProtoReflect.Descriptor instead.

func (*RepositoryParameters) GetHashFunction

func (x *RepositoryParameters) GetHashFunction() string

func (*RepositoryParameters) GetHmacSecret

func (x *RepositoryParameters) GetHmacSecret() []byte

func (*RepositoryParameters) GetSplitter

func (x *RepositoryParameters) GetSplitter() string

func (*RepositoryParameters) GetSupportsContentCompression added in v0.9.0

func (x *RepositoryParameters) GetSupportsContentCompression() bool

func (*RepositoryParameters) ProtoMessage

func (*RepositoryParameters) ProtoMessage()

func (*RepositoryParameters) ProtoReflect

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

func (*RepositoryParameters) Reset

func (x *RepositoryParameters) Reset()

func (*RepositoryParameters) String

func (x *RepositoryParameters) String() string

type SessionRequest

type SessionRequest struct {
	RequestId    int64             `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	TraceContext map[string]string `` /* 185-byte string literal not displayed */
	// each SessionRequest returns SessionResponse with request_id matching the request
	// and corresponding type specific to each request. In case of an error, ErrorResponse
	// is returned instead.
	//
	// Types that are assignable to Request:
	//
	//	*SessionRequest_InitializeSession
	//	*SessionRequest_GetContentInfo
	//	*SessionRequest_Flush
	//	*SessionRequest_WriteContent
	//	*SessionRequest_GetContent
	//	*SessionRequest_GetManifest
	//	*SessionRequest_PutManifest
	//	*SessionRequest_FindManifests
	//	*SessionRequest_DeleteManifest
	//	*SessionRequest_PrefetchContents
	//	*SessionRequest_ApplyRetentionPolicy
	Request isSessionRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*SessionRequest) Descriptor deprecated

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

Deprecated: Use SessionRequest.ProtoReflect.Descriptor instead.

func (*SessionRequest) GetApplyRetentionPolicy added in v0.14.0

func (x *SessionRequest) GetApplyRetentionPolicy() *ApplyRetentionPolicyRequest

func (*SessionRequest) GetDeleteManifest

func (x *SessionRequest) GetDeleteManifest() *DeleteManifestRequest

func (*SessionRequest) GetFindManifests

func (x *SessionRequest) GetFindManifests() *FindManifestsRequest

func (*SessionRequest) GetFlush

func (x *SessionRequest) GetFlush() *FlushRequest

func (*SessionRequest) GetGetContent

func (x *SessionRequest) GetGetContent() *GetContentRequest

func (*SessionRequest) GetGetContentInfo

func (x *SessionRequest) GetGetContentInfo() *GetContentInfoRequest

func (*SessionRequest) GetGetManifest

func (x *SessionRequest) GetGetManifest() *GetManifestRequest

func (*SessionRequest) GetInitializeSession

func (x *SessionRequest) GetInitializeSession() *InitializeSessionRequest

func (*SessionRequest) GetPrefetchContents added in v0.10.7

func (x *SessionRequest) GetPrefetchContents() *PrefetchContentsRequest

func (*SessionRequest) GetPutManifest

func (x *SessionRequest) GetPutManifest() *PutManifestRequest

func (*SessionRequest) GetRequest

func (m *SessionRequest) GetRequest() isSessionRequest_Request

func (*SessionRequest) GetRequestId

func (x *SessionRequest) GetRequestId() int64

func (*SessionRequest) GetTraceContext added in v0.12.0

func (x *SessionRequest) GetTraceContext() map[string]string

func (*SessionRequest) GetWriteContent

func (x *SessionRequest) GetWriteContent() *WriteContentRequest

func (*SessionRequest) ProtoMessage

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) ProtoReflect

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

func (*SessionRequest) Reset

func (x *SessionRequest) Reset()

func (*SessionRequest) String

func (x *SessionRequest) String() string

type SessionRequest_ApplyRetentionPolicy added in v0.14.0

type SessionRequest_ApplyRetentionPolicy struct {
	ApplyRetentionPolicy *ApplyRetentionPolicyRequest `protobuf:"bytes,20,opt,name=apply_retention_policy,json=applyRetentionPolicy,proto3,oneof"`
}

type SessionRequest_DeleteManifest

type SessionRequest_DeleteManifest struct {
	DeleteManifest *DeleteManifestRequest `protobuf:"bytes,18,opt,name=delete_manifest,json=deleteManifest,proto3,oneof"`
}

type SessionRequest_FindManifests

type SessionRequest_FindManifests struct {
	FindManifests *FindManifestsRequest `protobuf:"bytes,17,opt,name=find_manifests,json=findManifests,proto3,oneof"`
}

type SessionRequest_Flush

type SessionRequest_Flush struct {
	Flush *FlushRequest `protobuf:"bytes,12,opt,name=flush,proto3,oneof"`
}

type SessionRequest_GetContent

type SessionRequest_GetContent struct {
	GetContent *GetContentRequest `protobuf:"bytes,14,opt,name=get_content,json=getContent,proto3,oneof"`
}

type SessionRequest_GetContentInfo

type SessionRequest_GetContentInfo struct {
	GetContentInfo *GetContentInfoRequest `protobuf:"bytes,11,opt,name=get_content_info,json=getContentInfo,proto3,oneof"`
}

type SessionRequest_GetManifest

type SessionRequest_GetManifest struct {
	GetManifest *GetManifestRequest `protobuf:"bytes,15,opt,name=get_manifest,json=getManifest,proto3,oneof"`
}

type SessionRequest_InitializeSession

type SessionRequest_InitializeSession struct {
	InitializeSession *InitializeSessionRequest `protobuf:"bytes,10,opt,name=initialize_session,json=initializeSession,proto3,oneof"`
}

type SessionRequest_PrefetchContents added in v0.10.7

type SessionRequest_PrefetchContents struct {
	PrefetchContents *PrefetchContentsRequest `protobuf:"bytes,19,opt,name=prefetch_contents,json=prefetchContents,proto3,oneof"`
}

type SessionRequest_PutManifest

type SessionRequest_PutManifest struct {
	PutManifest *PutManifestRequest `protobuf:"bytes,16,opt,name=put_manifest,json=putManifest,proto3,oneof"`
}

type SessionRequest_WriteContent

type SessionRequest_WriteContent struct {
	WriteContent *WriteContentRequest `protobuf:"bytes,13,opt,name=write_content,json=writeContent,proto3,oneof"`
}

type SessionResponse

type SessionResponse struct {
	RequestId int64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // corresponds to request ID
	HasMore   bool  `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`       // if set to true, the client should expect more responses with the same request_id.
	// Types that are assignable to Response:
	//
	//	*SessionResponse_Error
	//	*SessionResponse_InitializeSession
	//	*SessionResponse_GetContentInfo
	//	*SessionResponse_Flush
	//	*SessionResponse_WriteContent
	//	*SessionResponse_GetContent
	//	*SessionResponse_GetManifest
	//	*SessionResponse_PutManifest
	//	*SessionResponse_FindManifests
	//	*SessionResponse_DeleteManifest
	//	*SessionResponse_PrefetchContents
	//	*SessionResponse_ApplyRetentionPolicy
	Response isSessionResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*SessionResponse) Descriptor deprecated

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

Deprecated: Use SessionResponse.ProtoReflect.Descriptor instead.

func (*SessionResponse) GetApplyRetentionPolicy added in v0.14.0

func (x *SessionResponse) GetApplyRetentionPolicy() *ApplyRetentionPolicyResponse

func (*SessionResponse) GetDeleteManifest

func (x *SessionResponse) GetDeleteManifest() *DeleteManifestResponse

func (*SessionResponse) GetError

func (x *SessionResponse) GetError() *ErrorResponse

func (*SessionResponse) GetFindManifests

func (x *SessionResponse) GetFindManifests() *FindManifestsResponse

func (*SessionResponse) GetFlush

func (x *SessionResponse) GetFlush() *FlushResponse

func (*SessionResponse) GetGetContent

func (x *SessionResponse) GetGetContent() *GetContentResponse

func (*SessionResponse) GetGetContentInfo

func (x *SessionResponse) GetGetContentInfo() *GetContentInfoResponse

func (*SessionResponse) GetGetManifest

func (x *SessionResponse) GetGetManifest() *GetManifestResponse

func (*SessionResponse) GetHasMore added in v0.13.0

func (x *SessionResponse) GetHasMore() bool

func (*SessionResponse) GetInitializeSession

func (x *SessionResponse) GetInitializeSession() *InitializeSessionResponse

func (*SessionResponse) GetPrefetchContents added in v0.10.7

func (x *SessionResponse) GetPrefetchContents() *PrefetchContentsResponse

func (*SessionResponse) GetPutManifest

func (x *SessionResponse) GetPutManifest() *PutManifestResponse

func (*SessionResponse) GetRequestId

func (x *SessionResponse) GetRequestId() int64

func (*SessionResponse) GetResponse

func (m *SessionResponse) GetResponse() isSessionResponse_Response

func (*SessionResponse) GetWriteContent

func (x *SessionResponse) GetWriteContent() *WriteContentResponse

func (*SessionResponse) ProtoMessage

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) ProtoReflect

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

func (*SessionResponse) Reset

func (x *SessionResponse) Reset()

func (*SessionResponse) String

func (x *SessionResponse) String() string

type SessionResponse_ApplyRetentionPolicy added in v0.14.0

type SessionResponse_ApplyRetentionPolicy struct {
	ApplyRetentionPolicy *ApplyRetentionPolicyResponse `protobuf:"bytes,20,opt,name=apply_retention_policy,json=applyRetentionPolicy,proto3,oneof"`
}

type SessionResponse_DeleteManifest

type SessionResponse_DeleteManifest struct {
	DeleteManifest *DeleteManifestResponse `protobuf:"bytes,18,opt,name=delete_manifest,json=deleteManifest,proto3,oneof"`
}

type SessionResponse_Error

type SessionResponse_Error struct {
	Error *ErrorResponse `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type SessionResponse_FindManifests

type SessionResponse_FindManifests struct {
	FindManifests *FindManifestsResponse `protobuf:"bytes,17,opt,name=find_manifests,json=findManifests,proto3,oneof"`
}

type SessionResponse_Flush

type SessionResponse_Flush struct {
	Flush *FlushResponse `protobuf:"bytes,12,opt,name=flush,proto3,oneof"`
}

type SessionResponse_GetContent

type SessionResponse_GetContent struct {
	GetContent *GetContentResponse `protobuf:"bytes,14,opt,name=get_content,json=getContent,proto3,oneof"`
}

type SessionResponse_GetContentInfo

type SessionResponse_GetContentInfo struct {
	GetContentInfo *GetContentInfoResponse `protobuf:"bytes,11,opt,name=get_content_info,json=getContentInfo,proto3,oneof"`
}

type SessionResponse_GetManifest

type SessionResponse_GetManifest struct {
	GetManifest *GetManifestResponse `protobuf:"bytes,15,opt,name=get_manifest,json=getManifest,proto3,oneof"`
}

type SessionResponse_InitializeSession

type SessionResponse_InitializeSession struct {
	InitializeSession *InitializeSessionResponse `protobuf:"bytes,10,opt,name=initialize_session,json=initializeSession,proto3,oneof"`
}

type SessionResponse_PrefetchContents added in v0.10.7

type SessionResponse_PrefetchContents struct {
	PrefetchContents *PrefetchContentsResponse `protobuf:"bytes,19,opt,name=prefetch_contents,json=prefetchContents,proto3,oneof"`
}

type SessionResponse_PutManifest

type SessionResponse_PutManifest struct {
	PutManifest *PutManifestResponse `protobuf:"bytes,16,opt,name=put_manifest,json=putManifest,proto3,oneof"`
}

type SessionResponse_WriteContent

type SessionResponse_WriteContent struct {
	WriteContent *WriteContentResponse `protobuf:"bytes,13,opt,name=write_content,json=writeContent,proto3,oneof"`
}

type UnimplementedKopiaRepositoryServer

type UnimplementedKopiaRepositoryServer struct {
}

UnimplementedKopiaRepositoryServer must be embedded to have forward compatible implementations.

func (UnimplementedKopiaRepositoryServer) Session

type UnsafeKopiaRepositoryServer

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

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

type WriteContentRequest

type WriteContentRequest struct {
	Prefix      string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Data        []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Compression uint32 `protobuf:"varint,3,opt,name=compression,proto3" json:"compression,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteContentRequest) Descriptor deprecated

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

Deprecated: Use WriteContentRequest.ProtoReflect.Descriptor instead.

func (*WriteContentRequest) GetCompression added in v0.9.0

func (x *WriteContentRequest) GetCompression() uint32

func (*WriteContentRequest) GetData

func (x *WriteContentRequest) GetData() []byte

func (*WriteContentRequest) GetPrefix

func (x *WriteContentRequest) GetPrefix() string

func (*WriteContentRequest) ProtoMessage

func (*WriteContentRequest) ProtoMessage()

func (*WriteContentRequest) ProtoReflect

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

func (*WriteContentRequest) Reset

func (x *WriteContentRequest) Reset()

func (*WriteContentRequest) String

func (x *WriteContentRequest) String() string

type WriteContentResponse

type WriteContentResponse struct {
	ContentId string `protobuf:"bytes,1,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteContentResponse) Descriptor deprecated

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

Deprecated: Use WriteContentResponse.ProtoReflect.Descriptor instead.

func (*WriteContentResponse) GetContentId

func (x *WriteContentResponse) GetContentId() string

func (*WriteContentResponse) ProtoMessage

func (*WriteContentResponse) ProtoMessage()

func (*WriteContentResponse) ProtoReflect

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

func (*WriteContentResponse) Reset

func (x *WriteContentResponse) Reset()

func (*WriteContentResponse) String

func (x *WriteContentResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL