proto

package
v0.0.0-...-443e884 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BlobCache_GetContent_FullMethodName                     = "/blobcache.BlobCache/GetContent"
	BlobCache_HasContent_FullMethodName                     = "/blobcache.BlobCache/HasContent"
	BlobCache_GetContentStream_FullMethodName               = "/blobcache.BlobCache/GetContentStream"
	BlobCache_StoreContent_FullMethodName                   = "/blobcache.BlobCache/StoreContent"
	BlobCache_StoreContentFromSource_FullMethodName         = "/blobcache.BlobCache/StoreContentFromSource"
	BlobCache_StoreContentFromSourceWithLock_FullMethodName = "/blobcache.BlobCache/StoreContentFromSourceWithLock"
	BlobCache_GetState_FullMethodName                       = "/blobcache.BlobCache/GetState"
	BlobCache_GetAvailableHosts_FullMethodName              = "/blobcache.BlobCache/GetAvailableHosts"
	BlobCache_GetRegionConfig_FullMethodName                = "/blobcache.BlobCache/GetRegionConfig"
	BlobCache_SetClientLock_FullMethodName                  = "/blobcache.BlobCache/SetClientLock"
	BlobCache_RemoveClientLock_FullMethodName               = "/blobcache.BlobCache/RemoveClientLock"
	BlobCache_SetStoreFromContentLock_FullMethodName        = "/blobcache.BlobCache/SetStoreFromContentLock"
	BlobCache_RemoveStoreFromContentLock_FullMethodName     = "/blobcache.BlobCache/RemoveStoreFromContentLock"
	BlobCache_RefreshStoreFromContentLock_FullMethodName    = "/blobcache.BlobCache/RefreshStoreFromContentLock"
	BlobCache_SetFsNode_FullMethodName                      = "/blobcache.BlobCache/SetFsNode"
	BlobCache_GetFsNode_FullMethodName                      = "/blobcache.BlobCache/GetFsNode"
	BlobCache_GetFsNodeChildren_FullMethodName              = "/blobcache.BlobCache/GetFsNodeChildren"
	BlobCache_AddFsNodeChild_FullMethodName                 = "/blobcache.BlobCache/AddFsNodeChild"
	BlobCache_RemoveFsNode_FullMethodName                   = "/blobcache.BlobCache/RemoveFsNode"
	BlobCache_RemoveFsNodeChild_FullMethodName              = "/blobcache.BlobCache/RemoveFsNodeChild"
	BlobCache_AddHostToIndex_FullMethodName                 = "/blobcache.BlobCache/AddHostToIndex"
	BlobCache_SetHostKeepAlive_FullMethodName               = "/blobcache.BlobCache/SetHostKeepAlive"
)

Variables

View Source 
var BlobCache_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "blobcache.BlobCache",
	HandlerType: (*BlobCacheServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetContent",
			Handler:    _BlobCache_GetContent_Handler,
		},
		{
			MethodName: "HasContent",
			Handler:    _BlobCache_HasContent_Handler,
		},
		{
			MethodName: "StoreContentFromSource",
			Handler:    _BlobCache_StoreContentFromSource_Handler,
		},
		{
			MethodName: "StoreContentFromSourceWithLock",
			Handler:    _BlobCache_StoreContentFromSourceWithLock_Handler,
		},
		{
			MethodName: "GetState",
			Handler:    _BlobCache_GetState_Handler,
		},
		{
			MethodName: "GetAvailableHosts",
			Handler:    _BlobCache_GetAvailableHosts_Handler,
		},
		{
			MethodName: "GetRegionConfig",
			Handler:    _BlobCache_GetRegionConfig_Handler,
		},
		{
			MethodName: "SetClientLock",
			Handler:    _BlobCache_SetClientLock_Handler,
		},
		{
			MethodName: "RemoveClientLock",
			Handler:    _BlobCache_RemoveClientLock_Handler,
		},
		{
			MethodName: "SetStoreFromContentLock",
			Handler:    _BlobCache_SetStoreFromContentLock_Handler,
		},
		{
			MethodName: "RemoveStoreFromContentLock",
			Handler:    _BlobCache_RemoveStoreFromContentLock_Handler,
		},
		{
			MethodName: "RefreshStoreFromContentLock",
			Handler:    _BlobCache_RefreshStoreFromContentLock_Handler,
		},
		{
			MethodName: "SetFsNode",
			Handler:    _BlobCache_SetFsNode_Handler,
		},
		{
			MethodName: "GetFsNode",
			Handler:    _BlobCache_GetFsNode_Handler,
		},
		{
			MethodName: "GetFsNodeChildren",
			Handler:    _BlobCache_GetFsNodeChildren_Handler,
		},
		{
			MethodName: "AddFsNodeChild",
			Handler:    _BlobCache_AddFsNodeChild_Handler,
		},
		{
			MethodName: "RemoveFsNode",
			Handler:    _BlobCache_RemoveFsNode_Handler,
		},
		{
			MethodName: "RemoveFsNodeChild",
			Handler:    _BlobCache_RemoveFsNodeChild_Handler,
		},
		{
			MethodName: "AddHostToIndex",
			Handler:    _BlobCache_AddHostToIndex_Handler,
		},
		{
			MethodName: "SetHostKeepAlive",
			Handler:    _BlobCache_SetHostKeepAlive_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetContentStream",
			Handler:       _BlobCache_GetContentStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StoreContent",
			Handler:       _BlobCache_StoreContent_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "blobcache.proto",
}

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

View Source 
var File_blobcache_proto protoreflect.FileDescriptor

Functions

func RegisterBlobCacheServer 

func RegisterBlobCacheServer(s grpc.ServiceRegistrar, srv BlobCacheServer)

Types

type AddFsNodeChildRequest 

type AddFsNodeChildRequest struct {
	Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Id  string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddFsNodeChildRequest) Descriptor deprecated 

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

Deprecated: Use AddFsNodeChildRequest.ProtoReflect.Descriptor instead.

func (*AddFsNodeChildRequest) GetId 

func (x *AddFsNodeChildRequest) GetId() string

func (*AddFsNodeChildRequest) GetPid 

func (x *AddFsNodeChildRequest) GetPid() string

func (*AddFsNodeChildRequest) ProtoMessage 

func (*AddFsNodeChildRequest) ProtoMessage()

func (*AddFsNodeChildRequest) ProtoReflect 

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

func (*AddFsNodeChildRequest) Reset 

func (x *AddFsNodeChildRequest) Reset()

func (*AddFsNodeChildRequest) String 

func (x *AddFsNodeChildRequest) String() string

type AddFsNodeChildResponse 

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

func (*AddFsNodeChildResponse) Descriptor deprecated 

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

Deprecated: Use AddFsNodeChildResponse.ProtoReflect.Descriptor instead.

func (*AddFsNodeChildResponse) GetOk 

func (x *AddFsNodeChildResponse) GetOk() bool

func (*AddFsNodeChildResponse) ProtoMessage 

func (*AddFsNodeChildResponse) ProtoMessage()

func (*AddFsNodeChildResponse) ProtoReflect 

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

func (*AddFsNodeChildResponse) Reset 

func (x *AddFsNodeChildResponse) Reset()

func (*AddFsNodeChildResponse) String 

func (x *AddFsNodeChildResponse) String() string

type AddHostToIndexRequest 

type AddHostToIndexRequest struct {
	Locality string         `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	Host     *BlobCacheHost `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*AddHostToIndexRequest) Descriptor deprecated 

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

Deprecated: Use AddHostToIndexRequest.ProtoReflect.Descriptor instead.

func (*AddHostToIndexRequest) GetHost 

func (x *AddHostToIndexRequest) GetHost() *BlobCacheHost

func (*AddHostToIndexRequest) GetLocality 

func (x *AddHostToIndexRequest) GetLocality() string

func (*AddHostToIndexRequest) ProtoMessage 

func (*AddHostToIndexRequest) ProtoMessage()

func (*AddHostToIndexRequest) ProtoReflect 

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

func (*AddHostToIndexRequest) Reset 

func (x *AddHostToIndexRequest) Reset()

func (*AddHostToIndexRequest) String 

func (x *AddHostToIndexRequest) String() string

type AddHostToIndexResponse 

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

func (*AddHostToIndexResponse) Descriptor deprecated 

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

Deprecated: Use AddHostToIndexResponse.ProtoReflect.Descriptor instead.

func (*AddHostToIndexResponse) GetOk 

func (x *AddHostToIndexResponse) GetOk() bool

func (*AddHostToIndexResponse) ProtoMessage 

func (*AddHostToIndexResponse) ProtoMessage()

func (*AddHostToIndexResponse) ProtoReflect 

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

func (*AddHostToIndexResponse) Reset 

func (x *AddHostToIndexResponse) Reset()

func (*AddHostToIndexResponse) String 

func (x *AddHostToIndexResponse) String() string

type BlobCacheClient 

type BlobCacheClient interface {
	// Cache RPCs
	GetContent(ctx context.Context, in *GetContentRequest, opts ...grpc.CallOption) (*GetContentResponse, error)
	HasContent(ctx context.Context, in *HasContentRequest, opts ...grpc.CallOption) (*HasContentResponse, error)
	GetContentStream(ctx context.Context, in *GetContentRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetContentResponse], error)
	StoreContent(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[StoreContentRequest, StoreContentResponse], error)
	StoreContentFromSource(ctx context.Context, in *StoreContentFromSourceRequest, opts ...grpc.CallOption) (*StoreContentFromSourceResponse, error)
	StoreContentFromSourceWithLock(ctx context.Context, in *StoreContentFromSourceRequest, opts ...grpc.CallOption) (*StoreContentFromSourceWithLockResponse, error)
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
	// Coordinator RPCs
	GetAvailableHosts(ctx context.Context, in *GetAvailableHostsRequest, opts ...grpc.CallOption) (*GetAvailableHostsResponse, error)
	GetRegionConfig(ctx context.Context, in *GetRegionConfigRequest, opts ...grpc.CallOption) (*GetRegionConfigResponse, error)
	SetClientLock(ctx context.Context, in *SetClientLockRequest, opts ...grpc.CallOption) (*SetClientLockResponse, error)
	RemoveClientLock(ctx context.Context, in *RemoveClientLockRequest, opts ...grpc.CallOption) (*RemoveClientLockResponse, error)
	SetStoreFromContentLock(ctx context.Context, in *SetStoreFromContentLockRequest, opts ...grpc.CallOption) (*SetStoreFromContentLockResponse, error)
	RemoveStoreFromContentLock(ctx context.Context, in *RemoveStoreFromContentLockRequest, opts ...grpc.CallOption) (*RemoveStoreFromContentLockResponse, error)
	RefreshStoreFromContentLock(ctx context.Context, in *RefreshStoreFromContentLockRequest, opts ...grpc.CallOption) (*RefreshStoreFromContentLockResponse, error)
	SetFsNode(ctx context.Context, in *SetFsNodeRequest, opts ...grpc.CallOption) (*SetFsNodeResponse, error)
	GetFsNode(ctx context.Context, in *GetFsNodeRequest, opts ...grpc.CallOption) (*GetFsNodeResponse, error)
	GetFsNodeChildren(ctx context.Context, in *GetFsNodeChildrenRequest, opts ...grpc.CallOption) (*GetFsNodeChildrenResponse, error)
	AddFsNodeChild(ctx context.Context, in *AddFsNodeChildRequest, opts ...grpc.CallOption) (*AddFsNodeChildResponse, error)
	RemoveFsNode(ctx context.Context, in *RemoveFsNodeRequest, opts ...grpc.CallOption) (*RemoveFsNodeResponse, error)
	RemoveFsNodeChild(ctx context.Context, in *RemoveFsNodeChildRequest, opts ...grpc.CallOption) (*RemoveFsNodeChildResponse, error)
	AddHostToIndex(ctx context.Context, in *AddHostToIndexRequest, opts ...grpc.CallOption) (*AddHostToIndexResponse, error)
	SetHostKeepAlive(ctx context.Context, in *SetHostKeepAliveRequest, opts ...grpc.CallOption) (*SetHostKeepAliveResponse, error)
}

BlobCacheClient is the client API for BlobCache 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 NewBlobCacheClient 

func NewBlobCacheClient(cc grpc.ClientConnInterface) BlobCacheClient

type BlobCacheHost 

type BlobCacheHost struct {
	HostId           string  `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Addr             string  `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	PrivateIpAddr    string  `protobuf:"bytes,3,opt,name=private_ip_addr,json=privateIpAddr,proto3" json:"private_ip_addr,omitempty"`
	CapacityUsagePct float32 `protobuf:"fixed32,4,opt,name=capacity_usage_pct,json=capacityUsagePct,proto3" json:"capacity_usage_pct,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobCacheHost) Descriptor deprecated 

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

Deprecated: Use BlobCacheHost.ProtoReflect.Descriptor instead.

func (*BlobCacheHost) GetAddr 

func (x *BlobCacheHost) GetAddr() string

func (*BlobCacheHost) GetCapacityUsagePct 

func (x *BlobCacheHost) GetCapacityUsagePct() float32

func (*BlobCacheHost) GetHostId 

func (x *BlobCacheHost) GetHostId() string

func (*BlobCacheHost) GetPrivateIpAddr 

func (x *BlobCacheHost) GetPrivateIpAddr() string

func (*BlobCacheHost) ProtoMessage 

func (*BlobCacheHost) ProtoMessage()

func (*BlobCacheHost) ProtoReflect 

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

func (*BlobCacheHost) Reset 

func (x *BlobCacheHost) Reset()

func (*BlobCacheHost) String 

func (x *BlobCacheHost) String() string

type BlobCacheServer 

type BlobCacheServer interface {
	// Cache RPCs
	GetContent(context.Context, *GetContentRequest) (*GetContentResponse, error)
	HasContent(context.Context, *HasContentRequest) (*HasContentResponse, error)
	GetContentStream(*GetContentRequest, grpc.ServerStreamingServer[GetContentResponse]) error
	StoreContent(grpc.ClientStreamingServer[StoreContentRequest, StoreContentResponse]) error
	StoreContentFromSource(context.Context, *StoreContentFromSourceRequest) (*StoreContentFromSourceResponse, error)
	StoreContentFromSourceWithLock(context.Context, *StoreContentFromSourceRequest) (*StoreContentFromSourceWithLockResponse, error)
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	// Coordinator RPCs
	GetAvailableHosts(context.Context, *GetAvailableHostsRequest) (*GetAvailableHostsResponse, error)
	GetRegionConfig(context.Context, *GetRegionConfigRequest) (*GetRegionConfigResponse, error)
	SetClientLock(context.Context, *SetClientLockRequest) (*SetClientLockResponse, error)
	RemoveClientLock(context.Context, *RemoveClientLockRequest) (*RemoveClientLockResponse, error)
	SetStoreFromContentLock(context.Context, *SetStoreFromContentLockRequest) (*SetStoreFromContentLockResponse, error)
	RemoveStoreFromContentLock(context.Context, *RemoveStoreFromContentLockRequest) (*RemoveStoreFromContentLockResponse, error)
	RefreshStoreFromContentLock(context.Context, *RefreshStoreFromContentLockRequest) (*RefreshStoreFromContentLockResponse, error)
	SetFsNode(context.Context, *SetFsNodeRequest) (*SetFsNodeResponse, error)
	GetFsNode(context.Context, *GetFsNodeRequest) (*GetFsNodeResponse, error)
	GetFsNodeChildren(context.Context, *GetFsNodeChildrenRequest) (*GetFsNodeChildrenResponse, error)
	AddFsNodeChild(context.Context, *AddFsNodeChildRequest) (*AddFsNodeChildResponse, error)
	RemoveFsNode(context.Context, *RemoveFsNodeRequest) (*RemoveFsNodeResponse, error)
	RemoveFsNodeChild(context.Context, *RemoveFsNodeChildRequest) (*RemoveFsNodeChildResponse, error)
	AddHostToIndex(context.Context, *AddHostToIndexRequest) (*AddHostToIndexResponse, error)
	SetHostKeepAlive(context.Context, *SetHostKeepAliveRequest) (*SetHostKeepAliveResponse, error)
	// contains filtered or unexported methods
}

BlobCacheServer is the server API for BlobCache service. All implementations must embed UnimplementedBlobCacheServer for forward compatibility.

type BlobCacheServerConfig 

type BlobCacheServerConfig struct {
	Mode                 string          `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"`
	DiskCacheDir         string          `protobuf:"bytes,2,opt,name=disk_cache_dir,json=diskCacheDir,proto3" json:"disk_cache_dir,omitempty"`
	DiskCacheMaxUsagePct float32         `` /* 129-byte string literal not displayed */
	MaxCachePct          int64           `protobuf:"varint,4,opt,name=max_cache_pct,json=maxCachePct,proto3" json:"max_cache_pct,omitempty"`
	PageSizeBytes        int64           `protobuf:"varint,5,opt,name=page_size_bytes,json=pageSizeBytes,proto3" json:"page_size_bytes,omitempty"`
	ObjectTtlS           int64           `protobuf:"varint,6,opt,name=object_ttl_s,json=objectTtlS,proto3" json:"object_ttl_s,omitempty"`
	PrettyLogs           bool            `protobuf:"varint,7,opt,name=pretty_logs,json=prettyLogs,proto3" json:"pretty_logs,omitempty"`
	Token                string          `protobuf:"bytes,8,opt,name=token,proto3" json:"token,omitempty"`
	Sources              []*SourceConfig `protobuf:"bytes,9,rep,name=sources,proto3" json:"sources,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobCacheServerConfig) Descriptor deprecated 

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

Deprecated: Use BlobCacheServerConfig.ProtoReflect.Descriptor instead.

func (*BlobCacheServerConfig) GetDiskCacheDir 

func (x *BlobCacheServerConfig) GetDiskCacheDir() string

func (*BlobCacheServerConfig) GetDiskCacheMaxUsagePct 

func (x *BlobCacheServerConfig) GetDiskCacheMaxUsagePct() float32

func (*BlobCacheServerConfig) GetMaxCachePct 

func (x *BlobCacheServerConfig) GetMaxCachePct() int64

func (*BlobCacheServerConfig) GetMode 

func (x *BlobCacheServerConfig) GetMode() string

func (*BlobCacheServerConfig) GetObjectTtlS 

func (x *BlobCacheServerConfig) GetObjectTtlS() int64

func (*BlobCacheServerConfig) GetPageSizeBytes 

func (x *BlobCacheServerConfig) GetPageSizeBytes() int64

func (*BlobCacheServerConfig) GetPrettyLogs 

func (x *BlobCacheServerConfig) GetPrettyLogs() bool

func (*BlobCacheServerConfig) GetSources 

func (x *BlobCacheServerConfig) GetSources() []*SourceConfig

func (*BlobCacheServerConfig) GetToken 

func (x *BlobCacheServerConfig) GetToken() string

func (*BlobCacheServerConfig) ProtoMessage 

func (*BlobCacheServerConfig) ProtoMessage()

func (*BlobCacheServerConfig) ProtoReflect 

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

func (*BlobCacheServerConfig) Reset 

func (x *BlobCacheServerConfig) Reset()

func (*BlobCacheServerConfig) String 

func (x *BlobCacheServerConfig) String() string

type BlobCache_GetContentStreamClient 

type BlobCache_GetContentStreamClient = grpc.ServerStreamingClient[GetContentResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type BlobCache_GetContentStreamServer 

type BlobCache_GetContentStreamServer = grpc.ServerStreamingServer[GetContentResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type BlobCache_StoreContentClient 

type BlobCache_StoreContentClient = grpc.ClientStreamingClient[StoreContentRequest, StoreContentResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type BlobCache_StoreContentServer 

type BlobCache_StoreContentServer = grpc.ClientStreamingServer[StoreContentRequest, StoreContentResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type BlobFsMetadata 

type BlobFsMetadata struct {
	Pid       string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Path      string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	Hash      string `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	Ino       uint64 `protobuf:"varint,6,opt,name=ino,proto3" json:"ino,omitempty"`
	Size      uint64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	Blocks    uint64 `protobuf:"varint,8,opt,name=blocks,proto3" json:"blocks,omitempty"`
	Atime     uint64 `protobuf:"varint,9,opt,name=atime,proto3" json:"atime,omitempty"`
	Mtime     uint64 `protobuf:"varint,10,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Ctime     uint64 `protobuf:"varint,11,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Atimensec uint32 `protobuf:"varint,12,opt,name=atimensec,proto3" json:"atimensec,omitempty"`
	Mtimensec uint32 `protobuf:"varint,13,opt,name=mtimensec,proto3" json:"mtimensec,omitempty"`
	Ctimensec uint32 `protobuf:"varint,14,opt,name=ctimensec,proto3" json:"ctimensec,omitempty"`
	Mode      uint32 `protobuf:"varint,15,opt,name=mode,proto3" json:"mode,omitempty"`
	Nlink     uint32 `protobuf:"varint,16,opt,name=nlink,proto3" json:"nlink,omitempty"`
	Rdev      uint32 `protobuf:"varint,17,opt,name=rdev,proto3" json:"rdev,omitempty"`
	Blksize   uint32 `protobuf:"varint,18,opt,name=blksize,proto3" json:"blksize,omitempty"`
	Padding   uint32 `protobuf:"varint,19,opt,name=padding,proto3" json:"padding,omitempty"`
	Uid       uint32 `protobuf:"varint,20,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid       uint32 `protobuf:"varint,21,opt,name=gid,proto3" json:"gid,omitempty"`
	Gen       uint64 `protobuf:"varint,22,opt,name=gen,proto3" json:"gen,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobFsMetadata) Descriptor deprecated 

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

Deprecated: Use BlobFsMetadata.ProtoReflect.Descriptor instead.

func (*BlobFsMetadata) GetAtime 

func (x *BlobFsMetadata) GetAtime() uint64

func (*BlobFsMetadata) GetAtimensec 

func (x *BlobFsMetadata) GetAtimensec() uint32

func (*BlobFsMetadata) GetBlksize 

func (x *BlobFsMetadata) GetBlksize() uint32

func (*BlobFsMetadata) GetBlocks 

func (x *BlobFsMetadata) GetBlocks() uint64

func (*BlobFsMetadata) GetCtime 

func (x *BlobFsMetadata) GetCtime() uint64

func (*BlobFsMetadata) GetCtimensec 

func (x *BlobFsMetadata) GetCtimensec() uint32

func (*BlobFsMetadata) GetGen 

func (x *BlobFsMetadata) GetGen() uint64

func (*BlobFsMetadata) GetGid 

func (x *BlobFsMetadata) GetGid() uint32

func (*BlobFsMetadata) GetHash 

func (x *BlobFsMetadata) GetHash() string

func (*BlobFsMetadata) GetId 

func (x *BlobFsMetadata) GetId() string

func (*BlobFsMetadata) GetIno 

func (x *BlobFsMetadata) GetIno() uint64

func (*BlobFsMetadata) GetMode 

func (x *BlobFsMetadata) GetMode() uint32

func (*BlobFsMetadata) GetMtime 

func (x *BlobFsMetadata) GetMtime() uint64

func (*BlobFsMetadata) GetMtimensec 

func (x *BlobFsMetadata) GetMtimensec() uint32

func (*BlobFsMetadata) GetName 

func (x *BlobFsMetadata) GetName() string
func (x *BlobFsMetadata) GetNlink() uint32

func (*BlobFsMetadata) GetPadding 

func (x *BlobFsMetadata) GetPadding() uint32

func (*BlobFsMetadata) GetPath 

func (x *BlobFsMetadata) GetPath() string

func (*BlobFsMetadata) GetPid 

func (x *BlobFsMetadata) GetPid() string

func (*BlobFsMetadata) GetRdev 

func (x *BlobFsMetadata) GetRdev() uint32

func (*BlobFsMetadata) GetSize 

func (x *BlobFsMetadata) GetSize() uint64

func (*BlobFsMetadata) GetUid 

func (x *BlobFsMetadata) GetUid() uint32

func (*BlobFsMetadata) ProtoMessage 

func (*BlobFsMetadata) ProtoMessage()

func (*BlobFsMetadata) ProtoReflect 

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

func (*BlobFsMetadata) Reset 

func (x *BlobFsMetadata) Reset()

func (*BlobFsMetadata) String 

func (x *BlobFsMetadata) String() string

type CacheSource 

type CacheSource struct {
	Path        string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	BucketName  string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	Region      string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	EndpointUrl string `protobuf:"bytes,4,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	AccessKey   string `protobuf:"bytes,5,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey   string `protobuf:"bytes,6,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheSource) Descriptor deprecated 

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

Deprecated: Use CacheSource.ProtoReflect.Descriptor instead.

func (*CacheSource) GetAccessKey 

func (x *CacheSource) GetAccessKey() string

func (*CacheSource) GetBucketName 

func (x *CacheSource) GetBucketName() string

func (*CacheSource) GetEndpointUrl 

func (x *CacheSource) GetEndpointUrl() string

func (*CacheSource) GetPath 

func (x *CacheSource) GetPath() string

func (*CacheSource) GetRegion 

func (x *CacheSource) GetRegion() string

func (*CacheSource) GetSecretKey 

func (x *CacheSource) GetSecretKey() string

func (*CacheSource) ProtoMessage 

func (*CacheSource) ProtoMessage()

func (*CacheSource) ProtoReflect 

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

func (*CacheSource) Reset 

func (x *CacheSource) Reset()

func (*CacheSource) String 

func (x *CacheSource) String() string

type GetAvailableHostsRequest 

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

func (*GetAvailableHostsRequest) Descriptor deprecated 

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

Deprecated: Use GetAvailableHostsRequest.ProtoReflect.Descriptor instead.

func (*GetAvailableHostsRequest) GetLocality 

func (x *GetAvailableHostsRequest) GetLocality() string

func (*GetAvailableHostsRequest) ProtoMessage 

func (*GetAvailableHostsRequest) ProtoMessage()

func (*GetAvailableHostsRequest) ProtoReflect 

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

func (*GetAvailableHostsRequest) Reset 

func (x *GetAvailableHostsRequest) Reset()

func (*GetAvailableHostsRequest) String 

func (x *GetAvailableHostsRequest) String() string

type GetAvailableHostsResponse 

type GetAvailableHostsResponse struct {
	Ok    bool             `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Hosts []*BlobCacheHost `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAvailableHostsResponse) Descriptor deprecated 

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

Deprecated: Use GetAvailableHostsResponse.ProtoReflect.Descriptor instead.

func (*GetAvailableHostsResponse) GetHosts 

func (x *GetAvailableHostsResponse) GetHosts() []*BlobCacheHost

func (*GetAvailableHostsResponse) GetOk 

func (x *GetAvailableHostsResponse) GetOk() bool

func (*GetAvailableHostsResponse) ProtoMessage 

func (*GetAvailableHostsResponse) ProtoMessage()

func (*GetAvailableHostsResponse) ProtoReflect 

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

func (*GetAvailableHostsResponse) Reset 

func (x *GetAvailableHostsResponse) Reset()

func (*GetAvailableHostsResponse) String 

func (x *GetAvailableHostsResponse) String() string

type GetContentRequest 

type GetContentRequest struct {
	Hash   string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`      // Hash of the content to retrieve
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` // Offset into the content
	Length int64  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"` // Length of the content to retrieve
	// contains filtered or unexported fields
}

func (*GetContentRequest) Descriptor deprecated 

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

Deprecated: Use GetContentRequest.ProtoReflect.Descriptor instead.

func (*GetContentRequest) GetHash 

func (x *GetContentRequest) GetHash() string

func (*GetContentRequest) GetLength 

func (x *GetContentRequest) GetLength() int64

func (*GetContentRequest) GetOffset 

func (x *GetContentRequest) GetOffset() int64

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 {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // Content data
	// contains filtered or unexported fields
}

func (*GetContentResponse) Descriptor deprecated 

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

Deprecated: Use GetContentResponse.ProtoReflect.Descriptor instead.

func (*GetContentResponse) GetContent 

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

func (*GetContentResponse) GetOk 

func (x *GetContentResponse) GetOk() bool

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 GetFsNodeChildrenRequest 

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

func (*GetFsNodeChildrenRequest) Descriptor deprecated 

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

Deprecated: Use GetFsNodeChildrenRequest.ProtoReflect.Descriptor instead.

func (*GetFsNodeChildrenRequest) GetId 

func (x *GetFsNodeChildrenRequest) GetId() string

func (*GetFsNodeChildrenRequest) ProtoMessage 

func (*GetFsNodeChildrenRequest) ProtoMessage()

func (*GetFsNodeChildrenRequest) ProtoReflect 

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

func (*GetFsNodeChildrenRequest) Reset 

func (x *GetFsNodeChildrenRequest) Reset()

func (*GetFsNodeChildrenRequest) String 

func (x *GetFsNodeChildrenRequest) String() string

type GetFsNodeChildrenResponse 

type GetFsNodeChildrenResponse struct {
	Ok       bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Children []*BlobFsMetadata `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFsNodeChildrenResponse) Descriptor deprecated 

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

Deprecated: Use GetFsNodeChildrenResponse.ProtoReflect.Descriptor instead.

func (*GetFsNodeChildrenResponse) GetChildren 

func (x *GetFsNodeChildrenResponse) GetChildren() []*BlobFsMetadata

func (*GetFsNodeChildrenResponse) GetOk 

func (x *GetFsNodeChildrenResponse) GetOk() bool

func (*GetFsNodeChildrenResponse) ProtoMessage 

func (*GetFsNodeChildrenResponse) ProtoMessage()

func (*GetFsNodeChildrenResponse) ProtoReflect 

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

func (*GetFsNodeChildrenResponse) Reset 

func (x *GetFsNodeChildrenResponse) Reset()

func (*GetFsNodeChildrenResponse) String 

func (x *GetFsNodeChildrenResponse) String() string

type GetFsNodeRequest 

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

func (*GetFsNodeRequest) Descriptor deprecated 

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

Deprecated: Use GetFsNodeRequest.ProtoReflect.Descriptor instead.

func (*GetFsNodeRequest) GetId 

func (x *GetFsNodeRequest) GetId() string

func (*GetFsNodeRequest) ProtoMessage 

func (*GetFsNodeRequest) ProtoMessage()

func (*GetFsNodeRequest) ProtoReflect 

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

func (*GetFsNodeRequest) Reset 

func (x *GetFsNodeRequest) Reset()

func (*GetFsNodeRequest) String 

func (x *GetFsNodeRequest) String() string

type GetFsNodeResponse 

type GetFsNodeResponse struct {
	Ok       bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Metadata *BlobFsMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFsNodeResponse) Descriptor deprecated 

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

Deprecated: Use GetFsNodeResponse.ProtoReflect.Descriptor instead.

func (*GetFsNodeResponse) GetMetadata 

func (x *GetFsNodeResponse) GetMetadata() *BlobFsMetadata

func (*GetFsNodeResponse) GetOk 

func (x *GetFsNodeResponse) GetOk() bool

func (*GetFsNodeResponse) ProtoMessage 

func (*GetFsNodeResponse) ProtoMessage()

func (*GetFsNodeResponse) ProtoReflect 

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

func (*GetFsNodeResponse) Reset 

func (x *GetFsNodeResponse) Reset()

func (*GetFsNodeResponse) String 

func (x *GetFsNodeResponse) String() string

type GetRegionConfigRequest 

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

func (*GetRegionConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetRegionConfigRequest.ProtoReflect.Descriptor instead.

func (*GetRegionConfigRequest) GetLocality 

func (x *GetRegionConfigRequest) GetLocality() string

func (*GetRegionConfigRequest) ProtoMessage 

func (*GetRegionConfigRequest) ProtoMessage()

func (*GetRegionConfigRequest) ProtoReflect 

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

func (*GetRegionConfigRequest) Reset 

func (x *GetRegionConfigRequest) Reset()

func (*GetRegionConfigRequest) String 

func (x *GetRegionConfigRequest) String() string

type GetRegionConfigResponse 

type GetRegionConfigResponse struct {
	Ok           bool                   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ServerConfig *BlobCacheServerConfig `protobuf:"bytes,2,opt,name=server_config,json=serverConfig,proto3" json:"server_config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegionConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetRegionConfigResponse.ProtoReflect.Descriptor instead.

func (*GetRegionConfigResponse) GetOk 

func (x *GetRegionConfigResponse) GetOk() bool

func (*GetRegionConfigResponse) GetServerConfig 

func (x *GetRegionConfigResponse) GetServerConfig() *BlobCacheServerConfig

func (*GetRegionConfigResponse) ProtoMessage 

func (*GetRegionConfigResponse) ProtoMessage()

func (*GetRegionConfigResponse) ProtoReflect 

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

func (*GetRegionConfigResponse) Reset 

func (x *GetRegionConfigResponse) Reset()

func (*GetRegionConfigResponse) String 

func (x *GetRegionConfigResponse) String() string

type GetStateRequest 

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

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

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

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {
	Ok               bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Version          string  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	CapacityUsagePct float32 `protobuf:"fixed32,3,opt,name=capacity_usage_pct,json=capacityUsagePct,proto3" json:"capacity_usage_pct,omitempty"`
	PrivateIpAddr    string  `protobuf:"bytes,4,opt,name=private_ip_addr,json=privateIpAddr,proto3" json:"private_ip_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetCapacityUsagePct 

func (x *GetStateResponse) GetCapacityUsagePct() float32

func (*GetStateResponse) GetOk 

func (x *GetStateResponse) GetOk() bool

func (*GetStateResponse) GetPrivateIpAddr 

func (x *GetStateResponse) GetPrivateIpAddr() string

func (*GetStateResponse) GetVersion 

func (x *GetStateResponse) GetVersion() string

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type HasContentRequest 

type HasContentRequest struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // Hash of the content to check
	// contains filtered or unexported fields
}

func (*HasContentRequest) Descriptor deprecated 

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

Deprecated: Use HasContentRequest.ProtoReflect.Descriptor instead.

func (*HasContentRequest) GetHash 

func (x *HasContentRequest) GetHash() string

func (*HasContentRequest) ProtoMessage 

func (*HasContentRequest) ProtoMessage()

func (*HasContentRequest) ProtoReflect 

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

func (*HasContentRequest) Reset 

func (x *HasContentRequest) Reset()

func (*HasContentRequest) String 

func (x *HasContentRequest) String() string

type HasContentResponse 

type HasContentResponse struct {
	Ok     bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Exists bool `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*HasContentResponse) Descriptor deprecated 

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

Deprecated: Use HasContentResponse.ProtoReflect.Descriptor instead.

func (*HasContentResponse) GetExists 

func (x *HasContentResponse) GetExists() bool

func (*HasContentResponse) GetOk 

func (x *HasContentResponse) GetOk() bool

func (*HasContentResponse) ProtoMessage 

func (*HasContentResponse) ProtoMessage()

func (*HasContentResponse) ProtoReflect 

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

func (*HasContentResponse) Reset 

func (x *HasContentResponse) Reset()

func (*HasContentResponse) String 

func (x *HasContentResponse) String() string

type JuiceFSConfig 

type JuiceFSConfig struct {
	RedisUri  string `protobuf:"bytes,1,opt,name=redis_uri,json=redisUri,proto3" json:"redis_uri,omitempty"`
	Bucket    string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	AccessKey string `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey string `protobuf:"bytes,4,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*JuiceFSConfig) Descriptor deprecated 

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

Deprecated: Use JuiceFSConfig.ProtoReflect.Descriptor instead.

func (*JuiceFSConfig) GetAccessKey 

func (x *JuiceFSConfig) GetAccessKey() string

func (*JuiceFSConfig) GetBucket 

func (x *JuiceFSConfig) GetBucket() string

func (*JuiceFSConfig) GetRedisUri 

func (x *JuiceFSConfig) GetRedisUri() string

func (*JuiceFSConfig) GetSecretKey 

func (x *JuiceFSConfig) GetSecretKey() string

func (*JuiceFSConfig) ProtoMessage 

func (*JuiceFSConfig) ProtoMessage()

func (*JuiceFSConfig) ProtoReflect 

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

func (*JuiceFSConfig) Reset 

func (x *JuiceFSConfig) Reset()

func (*JuiceFSConfig) String 

func (x *JuiceFSConfig) String() string

type MountPointConfig 

type MountPointConfig struct {
	BucketName     string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	AccessKey      string `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey      string `protobuf:"bytes,3,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	Region         string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
	EndpointUrl    string `protobuf:"bytes,5,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	ForcePathStyle bool   `protobuf:"varint,6,opt,name=force_path_style,json=forcePathStyle,proto3" json:"force_path_style,omitempty"`
	// contains filtered or unexported fields
}

func (*MountPointConfig) Descriptor deprecated 

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

Deprecated: Use MountPointConfig.ProtoReflect.Descriptor instead.

func (*MountPointConfig) GetAccessKey 

func (x *MountPointConfig) GetAccessKey() string

func (*MountPointConfig) GetBucketName 

func (x *MountPointConfig) GetBucketName() string

func (*MountPointConfig) GetEndpointUrl 

func (x *MountPointConfig) GetEndpointUrl() string

func (*MountPointConfig) GetForcePathStyle 

func (x *MountPointConfig) GetForcePathStyle() bool

func (*MountPointConfig) GetRegion 

func (x *MountPointConfig) GetRegion() string

func (*MountPointConfig) GetSecretKey 

func (x *MountPointConfig) GetSecretKey() string

func (*MountPointConfig) ProtoMessage 

func (*MountPointConfig) ProtoMessage()

func (*MountPointConfig) ProtoReflect 

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

func (*MountPointConfig) Reset 

func (x *MountPointConfig) Reset()

func (*MountPointConfig) String 

func (x *MountPointConfig) String() string

type RefreshStoreFromContentLockRequest 

type RefreshStoreFromContentLockRequest struct {
	Locality   string `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	SourcePath string `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStoreFromContentLockRequest) Descriptor deprecated 

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

Deprecated: Use RefreshStoreFromContentLockRequest.ProtoReflect.Descriptor instead.

func (*RefreshStoreFromContentLockRequest) GetLocality 

func (x *RefreshStoreFromContentLockRequest) GetLocality() string

func (*RefreshStoreFromContentLockRequest) GetSourcePath 

func (x *RefreshStoreFromContentLockRequest) GetSourcePath() string

func (*RefreshStoreFromContentLockRequest) ProtoMessage 

func (*RefreshStoreFromContentLockRequest) ProtoMessage()

func (*RefreshStoreFromContentLockRequest) ProtoReflect 

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

func (*RefreshStoreFromContentLockRequest) Reset 

func (x *RefreshStoreFromContentLockRequest) Reset()

func (*RefreshStoreFromContentLockRequest) String 

func (x *RefreshStoreFromContentLockRequest) String() string

type RefreshStoreFromContentLockResponse 

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

func (*RefreshStoreFromContentLockResponse) Descriptor deprecated 

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

Deprecated: Use RefreshStoreFromContentLockResponse.ProtoReflect.Descriptor instead.

func (*RefreshStoreFromContentLockResponse) GetOk 

func (x *RefreshStoreFromContentLockResponse) GetOk() bool

func (*RefreshStoreFromContentLockResponse) ProtoMessage 

func (*RefreshStoreFromContentLockResponse) ProtoMessage()

func (*RefreshStoreFromContentLockResponse) ProtoReflect 

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

func (*RefreshStoreFromContentLockResponse) Reset 

func (x *RefreshStoreFromContentLockResponse) Reset()

func (*RefreshStoreFromContentLockResponse) String 

func (x *RefreshStoreFromContentLockResponse) String() string

type RemoveClientLockRequest 

type RemoveClientLockRequest struct {
	Hash   string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	HostId string `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveClientLockRequest) Descriptor deprecated 

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

Deprecated: Use RemoveClientLockRequest.ProtoReflect.Descriptor instead.

func (*RemoveClientLockRequest) GetHash 

func (x *RemoveClientLockRequest) GetHash() string

func (*RemoveClientLockRequest) GetHostId 

func (x *RemoveClientLockRequest) GetHostId() string

func (*RemoveClientLockRequest) ProtoMessage 

func (*RemoveClientLockRequest) ProtoMessage()

func (*RemoveClientLockRequest) ProtoReflect 

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

func (*RemoveClientLockRequest) Reset 

func (x *RemoveClientLockRequest) Reset()

func (*RemoveClientLockRequest) String 

func (x *RemoveClientLockRequest) String() string

type RemoveClientLockResponse 

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

func (*RemoveClientLockResponse) Descriptor deprecated 

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

Deprecated: Use RemoveClientLockResponse.ProtoReflect.Descriptor instead.

func (*RemoveClientLockResponse) GetOk 

func (x *RemoveClientLockResponse) GetOk() bool

func (*RemoveClientLockResponse) ProtoMessage 

func (*RemoveClientLockResponse) ProtoMessage()

func (*RemoveClientLockResponse) ProtoReflect 

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

func (*RemoveClientLockResponse) Reset 

func (x *RemoveClientLockResponse) Reset()

func (*RemoveClientLockResponse) String 

func (x *RemoveClientLockResponse) String() string

type RemoveFsNodeChildRequest 

type RemoveFsNodeChildRequest struct {
	Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Id  string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFsNodeChildRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFsNodeChildRequest.ProtoReflect.Descriptor instead.

func (*RemoveFsNodeChildRequest) GetId 

func (x *RemoveFsNodeChildRequest) GetId() string

func (*RemoveFsNodeChildRequest) GetPid 

func (x *RemoveFsNodeChildRequest) GetPid() string

func (*RemoveFsNodeChildRequest) ProtoMessage 

func (*RemoveFsNodeChildRequest) ProtoMessage()

func (*RemoveFsNodeChildRequest) ProtoReflect 

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

func (*RemoveFsNodeChildRequest) Reset 

func (x *RemoveFsNodeChildRequest) Reset()

func (*RemoveFsNodeChildRequest) String 

func (x *RemoveFsNodeChildRequest) String() string

type RemoveFsNodeChildResponse 

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

func (*RemoveFsNodeChildResponse) Descriptor deprecated 

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

Deprecated: Use RemoveFsNodeChildResponse.ProtoReflect.Descriptor instead.

func (*RemoveFsNodeChildResponse) GetOk 

func (x *RemoveFsNodeChildResponse) GetOk() bool

func (*RemoveFsNodeChildResponse) ProtoMessage 

func (*RemoveFsNodeChildResponse) ProtoMessage()

func (*RemoveFsNodeChildResponse) ProtoReflect 

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

func (*RemoveFsNodeChildResponse) Reset 

func (x *RemoveFsNodeChildResponse) Reset()

func (*RemoveFsNodeChildResponse) String 

func (x *RemoveFsNodeChildResponse) String() string

type RemoveFsNodeRequest 

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

func (*RemoveFsNodeRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFsNodeRequest.ProtoReflect.Descriptor instead.

func (*RemoveFsNodeRequest) GetId 

func (x *RemoveFsNodeRequest) GetId() string

func (*RemoveFsNodeRequest) ProtoMessage 

func (*RemoveFsNodeRequest) ProtoMessage()

func (*RemoveFsNodeRequest) ProtoReflect 

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

func (*RemoveFsNodeRequest) Reset 

func (x *RemoveFsNodeRequest) Reset()

func (*RemoveFsNodeRequest) String 

func (x *RemoveFsNodeRequest) String() string

type RemoveFsNodeResponse 

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

func (*RemoveFsNodeResponse) Descriptor deprecated 

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

Deprecated: Use RemoveFsNodeResponse.ProtoReflect.Descriptor instead.

func (*RemoveFsNodeResponse) GetOk 

func (x *RemoveFsNodeResponse) GetOk() bool

func (*RemoveFsNodeResponse) ProtoMessage 

func (*RemoveFsNodeResponse) ProtoMessage()

func (*RemoveFsNodeResponse) ProtoReflect 

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

func (*RemoveFsNodeResponse) Reset 

func (x *RemoveFsNodeResponse) Reset()

func (*RemoveFsNodeResponse) String 

func (x *RemoveFsNodeResponse) String() string

type RemoveStoreFromContentLockRequest 

type RemoveStoreFromContentLockRequest struct {
	Locality   string `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	SourcePath string `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveStoreFromContentLockRequest) Descriptor deprecated 

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

Deprecated: Use RemoveStoreFromContentLockRequest.ProtoReflect.Descriptor instead.

func (*RemoveStoreFromContentLockRequest) GetLocality 

func (x *RemoveStoreFromContentLockRequest) GetLocality() string

func (*RemoveStoreFromContentLockRequest) GetSourcePath 

func (x *RemoveStoreFromContentLockRequest) GetSourcePath() string

func (*RemoveStoreFromContentLockRequest) ProtoMessage 

func (*RemoveStoreFromContentLockRequest) ProtoMessage()

func (*RemoveStoreFromContentLockRequest) ProtoReflect 

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

func (*RemoveStoreFromContentLockRequest) Reset 

func (x *RemoveStoreFromContentLockRequest) Reset()

func (*RemoveStoreFromContentLockRequest) String 

func (x *RemoveStoreFromContentLockRequest) String() string

type RemoveStoreFromContentLockResponse 

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

func (*RemoveStoreFromContentLockResponse) Descriptor deprecated 

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

Deprecated: Use RemoveStoreFromContentLockResponse.ProtoReflect.Descriptor instead.

func (*RemoveStoreFromContentLockResponse) GetOk 

func (x *RemoveStoreFromContentLockResponse) GetOk() bool

func (*RemoveStoreFromContentLockResponse) ProtoMessage 

func (*RemoveStoreFromContentLockResponse) ProtoMessage()

func (*RemoveStoreFromContentLockResponse) ProtoReflect 

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

func (*RemoveStoreFromContentLockResponse) Reset 

func (x *RemoveStoreFromContentLockResponse) Reset()

func (*RemoveStoreFromContentLockResponse) String 

func (x *RemoveStoreFromContentLockResponse) String() string

type SetClientLockRequest 

type SetClientLockRequest struct {
	Hash   string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	HostId string `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SetClientLockRequest) Descriptor deprecated 

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

Deprecated: Use SetClientLockRequest.ProtoReflect.Descriptor instead.

func (*SetClientLockRequest) GetHash 

func (x *SetClientLockRequest) GetHash() string

func (*SetClientLockRequest) GetHostId 

func (x *SetClientLockRequest) GetHostId() string

func (*SetClientLockRequest) ProtoMessage 

func (*SetClientLockRequest) ProtoMessage()

func (*SetClientLockRequest) ProtoReflect 

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

func (*SetClientLockRequest) Reset 

func (x *SetClientLockRequest) Reset()

func (*SetClientLockRequest) String 

func (x *SetClientLockRequest) String() string

type SetClientLockResponse 

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

func (*SetClientLockResponse) Descriptor deprecated 

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

Deprecated: Use SetClientLockResponse.ProtoReflect.Descriptor instead.

func (*SetClientLockResponse) GetOk 

func (x *SetClientLockResponse) GetOk() bool

func (*SetClientLockResponse) ProtoMessage 

func (*SetClientLockResponse) ProtoMessage()

func (*SetClientLockResponse) ProtoReflect 

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

func (*SetClientLockResponse) Reset 

func (x *SetClientLockResponse) Reset()

func (*SetClientLockResponse) String 

func (x *SetClientLockResponse) String() string

type SetFsNodeRequest 

type SetFsNodeRequest struct {
	Id       string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata *BlobFsMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*SetFsNodeRequest) Descriptor deprecated 

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

Deprecated: Use SetFsNodeRequest.ProtoReflect.Descriptor instead.

func (*SetFsNodeRequest) GetId 

func (x *SetFsNodeRequest) GetId() string

func (*SetFsNodeRequest) GetMetadata 

func (x *SetFsNodeRequest) GetMetadata() *BlobFsMetadata

func (*SetFsNodeRequest) ProtoMessage 

func (*SetFsNodeRequest) ProtoMessage()

func (*SetFsNodeRequest) ProtoReflect 

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

func (*SetFsNodeRequest) Reset 

func (x *SetFsNodeRequest) Reset()

func (*SetFsNodeRequest) String 

func (x *SetFsNodeRequest) String() string

type SetFsNodeResponse 

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

func (*SetFsNodeResponse) Descriptor deprecated 

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

Deprecated: Use SetFsNodeResponse.ProtoReflect.Descriptor instead.

func (*SetFsNodeResponse) GetOk 

func (x *SetFsNodeResponse) GetOk() bool

func (*SetFsNodeResponse) ProtoMessage 

func (*SetFsNodeResponse) ProtoMessage()

func (*SetFsNodeResponse) ProtoReflect 

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

func (*SetFsNodeResponse) Reset 

func (x *SetFsNodeResponse) Reset()

func (*SetFsNodeResponse) String 

func (x *SetFsNodeResponse) String() string

type SetHostKeepAliveRequest 

type SetHostKeepAliveRequest struct {
	Locality string         `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	Host     *BlobCacheHost `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*SetHostKeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use SetHostKeepAliveRequest.ProtoReflect.Descriptor instead.

func (*SetHostKeepAliveRequest) GetHost 

func (x *SetHostKeepAliveRequest) GetHost() *BlobCacheHost

func (*SetHostKeepAliveRequest) GetLocality 

func (x *SetHostKeepAliveRequest) GetLocality() string

func (*SetHostKeepAliveRequest) ProtoMessage 

func (*SetHostKeepAliveRequest) ProtoMessage()

func (*SetHostKeepAliveRequest) ProtoReflect 

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

func (*SetHostKeepAliveRequest) Reset 

func (x *SetHostKeepAliveRequest) Reset()

func (*SetHostKeepAliveRequest) String 

func (x *SetHostKeepAliveRequest) String() string

type SetHostKeepAliveResponse 

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

func (*SetHostKeepAliveResponse) Descriptor deprecated 

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

Deprecated: Use SetHostKeepAliveResponse.ProtoReflect.Descriptor instead.

func (*SetHostKeepAliveResponse) GetOk 

func (x *SetHostKeepAliveResponse) GetOk() bool

func (*SetHostKeepAliveResponse) ProtoMessage 

func (*SetHostKeepAliveResponse) ProtoMessage()

func (*SetHostKeepAliveResponse) ProtoReflect 

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

func (*SetHostKeepAliveResponse) Reset 

func (x *SetHostKeepAliveResponse) Reset()

func (*SetHostKeepAliveResponse) String 

func (x *SetHostKeepAliveResponse) String() string

type SetStoreFromContentLockRequest 

type SetStoreFromContentLockRequest struct {
	Locality   string `protobuf:"bytes,1,opt,name=locality,proto3" json:"locality,omitempty"`
	SourcePath string `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStoreFromContentLockRequest) Descriptor deprecated 

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

Deprecated: Use SetStoreFromContentLockRequest.ProtoReflect.Descriptor instead.

func (*SetStoreFromContentLockRequest) GetLocality 

func (x *SetStoreFromContentLockRequest) GetLocality() string

func (*SetStoreFromContentLockRequest) GetSourcePath 

func (x *SetStoreFromContentLockRequest) GetSourcePath() string

func (*SetStoreFromContentLockRequest) ProtoMessage 

func (*SetStoreFromContentLockRequest) ProtoMessage()

func (*SetStoreFromContentLockRequest) ProtoReflect 

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

func (*SetStoreFromContentLockRequest) Reset 

func (x *SetStoreFromContentLockRequest) Reset()

func (*SetStoreFromContentLockRequest) String 

func (x *SetStoreFromContentLockRequest) String() string

type SetStoreFromContentLockResponse 

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

func (*SetStoreFromContentLockResponse) Descriptor deprecated 

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

Deprecated: Use SetStoreFromContentLockResponse.ProtoReflect.Descriptor instead.

func (*SetStoreFromContentLockResponse) GetOk 

func (x *SetStoreFromContentLockResponse) GetOk() bool

func (*SetStoreFromContentLockResponse) ProtoMessage 

func (*SetStoreFromContentLockResponse) ProtoMessage()

func (*SetStoreFromContentLockResponse) ProtoReflect 

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

func (*SetStoreFromContentLockResponse) Reset 

func (x *SetStoreFromContentLockResponse) Reset()

func (*SetStoreFromContentLockResponse) String 

func (x *SetStoreFromContentLockResponse) String() string

type SourceConfig 

type SourceConfig struct {
	Mode           string            `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"`
	FilesystemName string            `protobuf:"bytes,2,opt,name=filesystem_name,json=filesystemName,proto3" json:"filesystem_name,omitempty"`
	FilesystemPath string            `protobuf:"bytes,3,opt,name=filesystem_path,json=filesystemPath,proto3" json:"filesystem_path,omitempty"`
	Juicefs        *JuiceFSConfig    `protobuf:"bytes,4,opt,name=juicefs,proto3" json:"juicefs,omitempty"`
	Mountpoint     *MountPointConfig `protobuf:"bytes,5,opt,name=mountpoint,proto3" json:"mountpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceConfig) Descriptor deprecated 

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

Deprecated: Use SourceConfig.ProtoReflect.Descriptor instead.

func (*SourceConfig) GetFilesystemName 

func (x *SourceConfig) GetFilesystemName() string

func (*SourceConfig) GetFilesystemPath 

func (x *SourceConfig) GetFilesystemPath() string

func (*SourceConfig) GetJuicefs 

func (x *SourceConfig) GetJuicefs() *JuiceFSConfig

func (*SourceConfig) GetMode 

func (x *SourceConfig) GetMode() string

func (*SourceConfig) GetMountpoint 

func (x *SourceConfig) GetMountpoint() *MountPointConfig

func (*SourceConfig) ProtoMessage 

func (*SourceConfig) ProtoMessage()

func (*SourceConfig) ProtoReflect 

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

func (*SourceConfig) Reset 

func (x *SourceConfig) Reset()

func (*SourceConfig) String 

func (x *SourceConfig) String() string

type StoreContentFromSourceRequest 

type StoreContentFromSourceRequest struct {
	Source *CacheSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreContentFromSourceRequest) Descriptor deprecated 

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

Deprecated: Use StoreContentFromSourceRequest.ProtoReflect.Descriptor instead.

func (*StoreContentFromSourceRequest) GetSource 

func (x *StoreContentFromSourceRequest) GetSource() *CacheSource

func (*StoreContentFromSourceRequest) ProtoMessage 

func (*StoreContentFromSourceRequest) ProtoMessage()

func (*StoreContentFromSourceRequest) ProtoReflect 

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

func (*StoreContentFromSourceRequest) Reset 

func (x *StoreContentFromSourceRequest) Reset()

func (*StoreContentFromSourceRequest) String 

func (x *StoreContentFromSourceRequest) String() string

type StoreContentFromSourceResponse 

type StoreContentFromSourceResponse struct {
	Ok       bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Hash     string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	ErrorMsg string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreContentFromSourceResponse) Descriptor deprecated 

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

Deprecated: Use StoreContentFromSourceResponse.ProtoReflect.Descriptor instead.

func (*StoreContentFromSourceResponse) GetErrorMsg 

func (x *StoreContentFromSourceResponse) GetErrorMsg() string

func (*StoreContentFromSourceResponse) GetHash 

func (x *StoreContentFromSourceResponse) GetHash() string

func (*StoreContentFromSourceResponse) GetOk 

func (x *StoreContentFromSourceResponse) GetOk() bool

func (*StoreContentFromSourceResponse) ProtoMessage 

func (*StoreContentFromSourceResponse) ProtoMessage()

func (*StoreContentFromSourceResponse) ProtoReflect 

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

func (*StoreContentFromSourceResponse) Reset 

func (x *StoreContentFromSourceResponse) Reset()

func (*StoreContentFromSourceResponse) String 

func (x *StoreContentFromSourceResponse) String() string

type StoreContentFromSourceWithLockResponse 

type StoreContentFromSourceWithLockResponse struct {
	Hash                string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // Hash of the stored content
	Ok                  bool   `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	FailedToAcquireLock bool   `protobuf:"varint,3,opt,name=failed_to_acquire_lock,json=failedToAcquireLock,proto3" json:"failed_to_acquire_lock,omitempty"`
	ErrorMsg            string `protobuf:"bytes,4,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreContentFromSourceWithLockResponse) Descriptor deprecated 

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

Deprecated: Use StoreContentFromSourceWithLockResponse.ProtoReflect.Descriptor instead.

func (*StoreContentFromSourceWithLockResponse) GetErrorMsg 

func (x *StoreContentFromSourceWithLockResponse) GetErrorMsg() string

func (*StoreContentFromSourceWithLockResponse) GetFailedToAcquireLock 

func (x *StoreContentFromSourceWithLockResponse) GetFailedToAcquireLock() bool

func (*StoreContentFromSourceWithLockResponse) GetHash 

func (x *StoreContentFromSourceWithLockResponse) GetHash() string

func (*StoreContentFromSourceWithLockResponse) GetOk 

func (x *StoreContentFromSourceWithLockResponse) GetOk() bool

func (*StoreContentFromSourceWithLockResponse) ProtoMessage 

func (*StoreContentFromSourceWithLockResponse) ProtoMessage()

func (*StoreContentFromSourceWithLockResponse) ProtoReflect 

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

func (*StoreContentFromSourceWithLockResponse) Reset 

func (x *StoreContentFromSourceWithLockResponse) Reset()

func (*StoreContentFromSourceWithLockResponse) String 

func (x *StoreContentFromSourceWithLockResponse) String() string

type StoreContentRequest 

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

func (*StoreContentRequest) Descriptor deprecated 

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

Deprecated: Use StoreContentRequest.ProtoReflect.Descriptor instead.

func (*StoreContentRequest) GetContent 

func (x *StoreContentRequest) GetContent() []byte

func (*StoreContentRequest) ProtoMessage 

func (*StoreContentRequest) ProtoMessage()

func (*StoreContentRequest) ProtoReflect 

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

func (*StoreContentRequest) Reset 

func (x *StoreContentRequest) Reset()

func (*StoreContentRequest) String 

func (x *StoreContentRequest) String() string

type StoreContentResponse 

type StoreContentResponse struct {
	Ok   bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` // Hash of the stored content
	// contains filtered or unexported fields
}

func (*StoreContentResponse) Descriptor deprecated 

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

Deprecated: Use StoreContentResponse.ProtoReflect.Descriptor instead.

func (*StoreContentResponse) GetHash 

func (x *StoreContentResponse) GetHash() string

func (*StoreContentResponse) GetOk 

func (x *StoreContentResponse) GetOk() bool

func (*StoreContentResponse) ProtoMessage 

func (*StoreContentResponse) ProtoMessage()

func (*StoreContentResponse) ProtoReflect 

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

func (*StoreContentResponse) Reset 

func (x *StoreContentResponse) Reset()

func (*StoreContentResponse) String 

func (x *StoreContentResponse) String() string

type UnimplementedBlobCacheServer 

type UnimplementedBlobCacheServer struct{}

UnimplementedBlobCacheServer 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 (UnimplementedBlobCacheServer) AddFsNodeChild 

func (UnimplementedBlobCacheServer) AddFsNodeChild(context.Context, *AddFsNodeChildRequest) (*AddFsNodeChildResponse, error)

func (UnimplementedBlobCacheServer) AddHostToIndex 

func (UnimplementedBlobCacheServer) AddHostToIndex(context.Context, *AddHostToIndexRequest) (*AddHostToIndexResponse, error)

func (UnimplementedBlobCacheServer) GetAvailableHosts 

func (UnimplementedBlobCacheServer) GetAvailableHosts(context.Context, *GetAvailableHostsRequest) (*GetAvailableHostsResponse, error)

func (UnimplementedBlobCacheServer) GetContent 

func (UnimplementedBlobCacheServer) GetContent(context.Context, *GetContentRequest) (*GetContentResponse, error)

func (UnimplementedBlobCacheServer) GetContentStream 

func (UnimplementedBlobCacheServer) GetContentStream(*GetContentRequest, grpc.ServerStreamingServer[GetContentResponse]) error

func (UnimplementedBlobCacheServer) GetFsNode 

func (UnimplementedBlobCacheServer) GetFsNode(context.Context, *GetFsNodeRequest) (*GetFsNodeResponse, error)

func (UnimplementedBlobCacheServer) GetFsNodeChildren 

func (UnimplementedBlobCacheServer) GetFsNodeChildren(context.Context, *GetFsNodeChildrenRequest) (*GetFsNodeChildrenResponse, error)

func (UnimplementedBlobCacheServer) GetRegionConfig 

func (UnimplementedBlobCacheServer) GetRegionConfig(context.Context, *GetRegionConfigRequest) (*GetRegionConfigResponse, error)

func (UnimplementedBlobCacheServer) GetState 

func (UnimplementedBlobCacheServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)

func (UnimplementedBlobCacheServer) HasContent 

func (UnimplementedBlobCacheServer) HasContent(context.Context, *HasContentRequest) (*HasContentResponse, error)

func (UnimplementedBlobCacheServer) RefreshStoreFromContentLock 

func (UnimplementedBlobCacheServer) RefreshStoreFromContentLock(context.Context, *RefreshStoreFromContentLockRequest) (*RefreshStoreFromContentLockResponse, error)

func (UnimplementedBlobCacheServer) RemoveClientLock 

func (UnimplementedBlobCacheServer) RemoveClientLock(context.Context, *RemoveClientLockRequest) (*RemoveClientLockResponse, error)

func (UnimplementedBlobCacheServer) RemoveFsNode 

func (UnimplementedBlobCacheServer) RemoveFsNode(context.Context, *RemoveFsNodeRequest) (*RemoveFsNodeResponse, error)

func (UnimplementedBlobCacheServer) RemoveFsNodeChild 

func (UnimplementedBlobCacheServer) RemoveFsNodeChild(context.Context, *RemoveFsNodeChildRequest) (*RemoveFsNodeChildResponse, error)

func (UnimplementedBlobCacheServer) RemoveStoreFromContentLock 

func (UnimplementedBlobCacheServer) RemoveStoreFromContentLock(context.Context, *RemoveStoreFromContentLockRequest) (*RemoveStoreFromContentLockResponse, error)

func (UnimplementedBlobCacheServer) SetClientLock 

func (UnimplementedBlobCacheServer) SetClientLock(context.Context, *SetClientLockRequest) (*SetClientLockResponse, error)

func (UnimplementedBlobCacheServer) SetFsNode 

func (UnimplementedBlobCacheServer) SetFsNode(context.Context, *SetFsNodeRequest) (*SetFsNodeResponse, error)

func (UnimplementedBlobCacheServer) SetHostKeepAlive 

func (UnimplementedBlobCacheServer) SetHostKeepAlive(context.Context, *SetHostKeepAliveRequest) (*SetHostKeepAliveResponse, error)

func (UnimplementedBlobCacheServer) SetStoreFromContentLock 

func (UnimplementedBlobCacheServer) SetStoreFromContentLock(context.Context, *SetStoreFromContentLockRequest) (*SetStoreFromContentLockResponse, error)

func (UnimplementedBlobCacheServer) StoreContent 

func (UnimplementedBlobCacheServer) StoreContent(grpc.ClientStreamingServer[StoreContentRequest, StoreContentResponse]) error

func (UnimplementedBlobCacheServer) StoreContentFromSource 

func (UnimplementedBlobCacheServer) StoreContentFromSource(context.Context, *StoreContentFromSourceRequest) (*StoreContentFromSourceResponse, error)

func (UnimplementedBlobCacheServer) StoreContentFromSourceWithLock 

func (UnimplementedBlobCacheServer) StoreContentFromSourceWithLock(context.Context, *StoreContentFromSourceRequest) (*StoreContentFromSourceWithLockResponse, error)

type UnsafeBlobCacheServer 

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

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

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.