grpcapi

package
v0.11.3 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 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) Descriptor() protoreflect.EnumDescriptor

func (ErrorResponse_Code) Enum 

func (x ErrorResponse_Code) Enum() *ErrorResponse_Code

func (ErrorResponse_Code) EnumDescriptor deprecated 

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

Deprecated: Use ErrorResponse_Code.Descriptor instead.

func (ErrorResponse_Code) Number 

func (x ErrorResponse_Code) Number() protoreflect.EnumNumber

func (ErrorResponse_Code) String 

func (x ErrorResponse_Code) String() string

func (ErrorResponse_Code) Type 

func (ErrorResponse_Code) Type() protoreflect.EnumType

type FindManifestsRequest 

type FindManifestsRequest struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// 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) 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 (x *InitializeSessionResponse) ProtoReflect() protoreflect.Message

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.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKopiaRepositoryClient 

func NewKopiaRepositoryClient(cc grpc.ClientConnInterface) KopiaRepositoryClient

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"`
	// 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
	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) 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) 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_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
	// 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
	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) 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) 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_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 

func (UnimplementedKopiaRepositoryServer) Session(KopiaRepository_SessionServer) error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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