Documentation ¶
Index ¶
- Variables
- func NewClient(c BlobcacheClient) blobcache.Service
- func RegisterBlobcacheServer(s grpc.ServiceRegistrar, srv BlobcacheServer)
- type AddReq
- type BlobcacheClient
- type BlobcacheServer
- type Blobcache_ListEntriesClient
- type Blobcache_ListEntriesServer
- type CreateDirReq
- func (*CreateDirReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDirReq) GetHandle() string
- func (x *CreateDirReq) GetName() string
- func (*CreateDirReq) ProtoMessage()
- func (x *CreateDirReq) ProtoReflect() protoreflect.Message
- func (x *CreateDirReq) Reset()
- func (x *CreateDirReq) String() string
- type CreatePinSetReq
- func (*CreatePinSetReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreatePinSetReq) GetHandle() string
- func (x *CreatePinSetReq) GetName() string
- func (x *CreatePinSetReq) GetReplicas() uint32
- func (*CreatePinSetReq) ProtoMessage()
- func (x *CreatePinSetReq) ProtoReflect() protoreflect.Message
- func (x *CreatePinSetReq) Reset()
- func (x *CreatePinSetReq) String() string
- type DeleteEntryReq
- func (*DeleteEntryReq) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteEntryReq) GetHandle() string
- func (x *DeleteEntryReq) GetName() string
- func (*DeleteEntryReq) ProtoMessage()
- func (x *DeleteEntryReq) ProtoReflect() protoreflect.Message
- func (x *DeleteEntryReq) Reset()
- func (x *DeleteEntryReq) String() string
- type DeleteReq
- type Entry
- type GetPinSetReq
- type GetReq
- type HandleRes
- type ListEntriesReq
- type ListReq
- func (*ListReq) Descriptor() ([]byte, []int)deprecated
- func (x *ListReq) GetFirst() []byte
- func (x *ListReq) GetHandle() string
- func (x *ListReq) GetLimit() uint32
- func (*ListReq) ProtoMessage()
- func (x *ListReq) ProtoReflect() protoreflect.Message
- func (x *ListReq) Reset()
- func (x *ListReq) String() string
- type ListRes
- type OpenReq
- type PinSet
- type PostReq
- type UnimplementedBlobcacheServer
- func (UnimplementedBlobcacheServer) Add(context.Context, *AddReq) (*emptypb.Empty, error)
- func (UnimplementedBlobcacheServer) CreateDir(context.Context, *CreateDirReq) (*HandleRes, error)
- func (UnimplementedBlobcacheServer) CreatePinSet(context.Context, *CreatePinSetReq) (*HandleRes, error)
- func (UnimplementedBlobcacheServer) Delete(context.Context, *DeleteReq) (*emptypb.Empty, error)
- func (UnimplementedBlobcacheServer) DeleteEntry(context.Context, *DeleteEntryReq) (*emptypb.Empty, error)
- func (UnimplementedBlobcacheServer) Get(context.Context, *GetReq) (*wrapperspb.BytesValue, error)
- func (UnimplementedBlobcacheServer) GetPinSet(context.Context, *GetPinSetReq) (*PinSet, error)
- func (UnimplementedBlobcacheServer) List(context.Context, *ListReq) (*ListRes, error)
- func (UnimplementedBlobcacheServer) ListEntries(*ListEntriesReq, Blobcache_ListEntriesServer) error
- func (UnimplementedBlobcacheServer) Open(context.Context, *OpenReq) (*HandleRes, error)
- func (UnimplementedBlobcacheServer) Post(context.Context, *PostReq) (*wrapperspb.BytesValue, error)
- func (UnimplementedBlobcacheServer) WaitOK(context.Context, *WaitReq) (*emptypb.Empty, error)
- type UnsafeBlobcacheServer
- type WaitReq
Constants ¶
This section is empty.
Variables ¶
var Blobcache_ServiceDesc = grpc.ServiceDesc{ ServiceName: "blobcache.Blobcache", HandlerType: (*BlobcacheServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateDir", Handler: _Blobcache_CreateDir_Handler, }, { MethodName: "Open", Handler: _Blobcache_Open_Handler, }, { MethodName: "DeleteEntry", Handler: _Blobcache_DeleteEntry_Handler, }, { MethodName: "CreatePinSet", Handler: _Blobcache_CreatePinSet_Handler, }, { MethodName: "GetPinSet", Handler: _Blobcache_GetPinSet_Handler, }, { MethodName: "Post", Handler: _Blobcache_Post_Handler, }, { MethodName: "Get", Handler: _Blobcache_Get_Handler, }, { MethodName: "Add", Handler: _Blobcache_Add_Handler, }, { MethodName: "Delete", Handler: _Blobcache_Delete_Handler, }, { MethodName: "List", Handler: _Blobcache_List_Handler, }, { MethodName: "WaitOK", Handler: _Blobcache_WaitOK_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ListEntries", Handler: _Blobcache_ListEntries_Handler, ServerStreams: 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)
var File_blobcache_proto protoreflect.FileDescriptor
Functions ¶
func NewClient ¶
func NewClient(c BlobcacheClient) blobcache.Service
func RegisterBlobcacheServer ¶
func RegisterBlobcacheServer(s grpc.ServiceRegistrar, srv BlobcacheServer)
Types ¶
type AddReq ¶
type AddReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Id []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*AddReq) Descriptor
deprecated
func (*AddReq) ProtoMessage ¶
func (*AddReq) ProtoMessage()
func (*AddReq) ProtoReflect ¶
func (x *AddReq) ProtoReflect() protoreflect.Message
type BlobcacheClient ¶
type BlobcacheClient interface { // CreateDir creates a directory at name under the parent. CreateDir(ctx context.Context, in *CreateDirReq, opts ...grpc.CallOption) (*HandleRes, error) // Open resolves a path relative to a handle Open(ctx context.Context, in *OpenReq, opts ...grpc.CallOption) (*HandleRes, error) // DeleteEntry removes the entry with name from its parent. DeleteEntry(ctx context.Context, in *DeleteEntryReq, opts ...grpc.CallOption) (*emptypb.Empty, error) // ListEntries lists the entries under a parent. ListEntries(ctx context.Context, in *ListEntriesReq, opts ...grpc.CallOption) (Blobcache_ListEntriesClient, error) // CreatePinSet creates a PinSet at name under the parent. CreatePinSet(ctx context.Context, in *CreatePinSetReq, opts ...grpc.CallOption) (*HandleRes, error) // GetPinSet returns information about a PinSet GetPinSet(ctx context.Context, in *GetPinSetReq, opts ...grpc.CallOption) (*PinSet, error) // Post uploads data and adds it to a PinSet. Post(ctx context.Context, in *PostReq, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error) // Get retrieves data from a PinSet and returns. Get(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*wrapperspb.BytesValue, error) // Add adds data by ID to a PinSet. Add(ctx context.Context, in *AddReq, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete removes data from a PinSet Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*emptypb.Empty, error) // List lists blobs by ID in a PinSet List(ctx context.Context, in *ListReq, opts ...grpc.CallOption) (*ListRes, error) // WaitOK WaitOK(ctx context.Context, in *WaitReq, opts ...grpc.CallOption) (*emptypb.Empty, 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 BlobcacheServer ¶
type BlobcacheServer interface { // CreateDir creates a directory at name under the parent. CreateDir(context.Context, *CreateDirReq) (*HandleRes, error) // Open resolves a path relative to a handle Open(context.Context, *OpenReq) (*HandleRes, error) // DeleteEntry removes the entry with name from its parent. DeleteEntry(context.Context, *DeleteEntryReq) (*emptypb.Empty, error) // ListEntries lists the entries under a parent. ListEntries(*ListEntriesReq, Blobcache_ListEntriesServer) error // CreatePinSet creates a PinSet at name under the parent. CreatePinSet(context.Context, *CreatePinSetReq) (*HandleRes, error) // GetPinSet returns information about a PinSet GetPinSet(context.Context, *GetPinSetReq) (*PinSet, error) // Post uploads data and adds it to a PinSet. Post(context.Context, *PostReq) (*wrapperspb.BytesValue, error) // Get retrieves data from a PinSet and returns. Get(context.Context, *GetReq) (*wrapperspb.BytesValue, error) // Add adds data by ID to a PinSet. Add(context.Context, *AddReq) (*emptypb.Empty, error) // Delete removes data from a PinSet Delete(context.Context, *DeleteReq) (*emptypb.Empty, error) // List lists blobs by ID in a PinSet List(context.Context, *ListReq) (*ListRes, error) // WaitOK WaitOK(context.Context, *WaitReq) (*emptypb.Empty, error) // contains filtered or unexported methods }
BlobcacheServer is the server API for Blobcache service. All implementations must embed UnimplementedBlobcacheServer for forward compatibility
func NewServer ¶
func NewServer(s blobcache.Service) BlobcacheServer
type Blobcache_ListEntriesClient ¶
type Blobcache_ListEntriesClient interface { Recv() (*Entry, error) grpc.ClientStream }
type Blobcache_ListEntriesServer ¶
type Blobcache_ListEntriesServer interface { Send(*Entry) error grpc.ServerStream }
type CreateDirReq ¶
type CreateDirReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*CreateDirReq) Descriptor
deprecated
func (*CreateDirReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateDirReq.ProtoReflect.Descriptor instead.
func (*CreateDirReq) GetHandle ¶
func (x *CreateDirReq) GetHandle() string
func (*CreateDirReq) GetName ¶
func (x *CreateDirReq) GetName() string
func (*CreateDirReq) ProtoMessage ¶
func (*CreateDirReq) ProtoMessage()
func (*CreateDirReq) ProtoReflect ¶
func (x *CreateDirReq) ProtoReflect() protoreflect.Message
func (*CreateDirReq) Reset ¶
func (x *CreateDirReq) Reset()
func (*CreateDirReq) String ¶
func (x *CreateDirReq) String() string
type CreatePinSetReq ¶
type CreatePinSetReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Replicas uint32 `protobuf:"varint,3,opt,name=replicas,proto3" json:"replicas,omitempty"` // contains filtered or unexported fields }
func (*CreatePinSetReq) Descriptor
deprecated
func (*CreatePinSetReq) Descriptor() ([]byte, []int)
Deprecated: Use CreatePinSetReq.ProtoReflect.Descriptor instead.
func (*CreatePinSetReq) GetHandle ¶
func (x *CreatePinSetReq) GetHandle() string
func (*CreatePinSetReq) GetName ¶
func (x *CreatePinSetReq) GetName() string
func (*CreatePinSetReq) GetReplicas ¶
func (x *CreatePinSetReq) GetReplicas() uint32
func (*CreatePinSetReq) ProtoMessage ¶
func (*CreatePinSetReq) ProtoMessage()
func (*CreatePinSetReq) ProtoReflect ¶
func (x *CreatePinSetReq) ProtoReflect() protoreflect.Message
func (*CreatePinSetReq) Reset ¶
func (x *CreatePinSetReq) Reset()
func (*CreatePinSetReq) String ¶
func (x *CreatePinSetReq) String() string
type DeleteEntryReq ¶
type DeleteEntryReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteEntryReq) Descriptor
deprecated
func (*DeleteEntryReq) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEntryReq.ProtoReflect.Descriptor instead.
func (*DeleteEntryReq) GetHandle ¶
func (x *DeleteEntryReq) GetHandle() string
func (*DeleteEntryReq) GetName ¶
func (x *DeleteEntryReq) GetName() string
func (*DeleteEntryReq) ProtoMessage ¶
func (*DeleteEntryReq) ProtoMessage()
func (*DeleteEntryReq) ProtoReflect ¶
func (x *DeleteEntryReq) ProtoReflect() protoreflect.Message
func (*DeleteEntryReq) Reset ¶
func (x *DeleteEntryReq) Reset()
func (*DeleteEntryReq) String ¶
func (x *DeleteEntryReq) String() string
type DeleteReq ¶
type DeleteReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Id []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DeleteReq) Descriptor
deprecated
func (*DeleteReq) ProtoMessage ¶
func (*DeleteReq) ProtoMessage()
func (*DeleteReq) ProtoReflect ¶
func (x *DeleteReq) ProtoReflect() protoreflect.Message
type Entry ¶
type Entry struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Oid uint64 `protobuf:"varint,2,opt,name=oid,proto3" json:"oid,omitempty"` // contains filtered or unexported fields }
func (*Entry) Descriptor
deprecated
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) ProtoReflect ¶
func (x *Entry) ProtoReflect() protoreflect.Message
type GetPinSetReq ¶
type GetPinSetReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` // contains filtered or unexported fields }
func (*GetPinSetReq) Descriptor
deprecated
func (*GetPinSetReq) Descriptor() ([]byte, []int)
Deprecated: Use GetPinSetReq.ProtoReflect.Descriptor instead.
func (*GetPinSetReq) GetHandle ¶
func (x *GetPinSetReq) GetHandle() string
func (*GetPinSetReq) ProtoMessage ¶
func (*GetPinSetReq) ProtoMessage()
func (*GetPinSetReq) ProtoReflect ¶
func (x *GetPinSetReq) ProtoReflect() protoreflect.Message
func (*GetPinSetReq) Reset ¶
func (x *GetPinSetReq) Reset()
func (*GetPinSetReq) String ¶
func (x *GetPinSetReq) String() string
type GetReq ¶
type GetReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Id []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetReq) Descriptor
deprecated
func (*GetReq) ProtoMessage ¶
func (*GetReq) ProtoMessage()
func (*GetReq) ProtoReflect ¶
func (x *GetReq) ProtoReflect() protoreflect.Message
type HandleRes ¶
type HandleRes struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` // contains filtered or unexported fields }
func (*HandleRes) Descriptor
deprecated
func (*HandleRes) ProtoMessage ¶
func (*HandleRes) ProtoMessage()
func (*HandleRes) ProtoReflect ¶
func (x *HandleRes) ProtoReflect() protoreflect.Message
type ListEntriesReq ¶
type ListEntriesReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` // contains filtered or unexported fields }
func (*ListEntriesReq) Descriptor
deprecated
func (*ListEntriesReq) Descriptor() ([]byte, []int)
Deprecated: Use ListEntriesReq.ProtoReflect.Descriptor instead.
func (*ListEntriesReq) GetHandle ¶
func (x *ListEntriesReq) GetHandle() string
func (*ListEntriesReq) ProtoMessage ¶
func (*ListEntriesReq) ProtoMessage()
func (*ListEntriesReq) ProtoReflect ¶
func (x *ListEntriesReq) ProtoReflect() protoreflect.Message
func (*ListEntriesReq) Reset ¶
func (x *ListEntriesReq) Reset()
func (*ListEntriesReq) String ¶
func (x *ListEntriesReq) String() string
type ListReq ¶
type ListReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` First []byte `protobuf:"bytes,2,opt,name=first,proto3" json:"first,omitempty"` Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*ListReq) Descriptor
deprecated
func (*ListReq) ProtoMessage ¶
func (*ListReq) ProtoMessage()
func (*ListReq) ProtoReflect ¶
func (x *ListReq) ProtoReflect() protoreflect.Message
type ListRes ¶
type ListRes struct { Ids [][]byte `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*ListRes) Descriptor
deprecated
func (*ListRes) ProtoMessage ¶
func (*ListRes) ProtoMessage()
func (*ListRes) ProtoReflect ¶
func (x *ListRes) ProtoReflect() protoreflect.Message
type OpenReq ¶
type OpenReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Path []string `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*OpenReq) Descriptor
deprecated
func (*OpenReq) ProtoMessage ¶
func (*OpenReq) ProtoMessage()
func (*OpenReq) ProtoReflect ¶
func (x *OpenReq) ProtoReflect() protoreflect.Message
type PinSet ¶
type PinSet struct {
// contains filtered or unexported fields
}
func (*PinSet) Descriptor
deprecated
func (*PinSet) ProtoMessage ¶
func (*PinSet) ProtoMessage()
func (*PinSet) ProtoReflect ¶
func (x *PinSet) ProtoReflect() protoreflect.Message
type PostReq ¶
type PostReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*PostReq) Descriptor
deprecated
func (*PostReq) ProtoMessage ¶
func (*PostReq) ProtoMessage()
func (*PostReq) ProtoReflect ¶
func (x *PostReq) ProtoReflect() protoreflect.Message
type UnimplementedBlobcacheServer ¶
type UnimplementedBlobcacheServer struct { }
UnimplementedBlobcacheServer must be embedded to have forward compatible implementations.
func (UnimplementedBlobcacheServer) CreateDir ¶
func (UnimplementedBlobcacheServer) CreateDir(context.Context, *CreateDirReq) (*HandleRes, error)
func (UnimplementedBlobcacheServer) CreatePinSet ¶
func (UnimplementedBlobcacheServer) CreatePinSet(context.Context, *CreatePinSetReq) (*HandleRes, error)
func (UnimplementedBlobcacheServer) DeleteEntry ¶
func (UnimplementedBlobcacheServer) DeleteEntry(context.Context, *DeleteEntryReq) (*emptypb.Empty, error)
func (UnimplementedBlobcacheServer) Get ¶
func (UnimplementedBlobcacheServer) Get(context.Context, *GetReq) (*wrapperspb.BytesValue, error)
func (UnimplementedBlobcacheServer) GetPinSet ¶
func (UnimplementedBlobcacheServer) GetPinSet(context.Context, *GetPinSetReq) (*PinSet, error)
func (UnimplementedBlobcacheServer) ListEntries ¶
func (UnimplementedBlobcacheServer) ListEntries(*ListEntriesReq, Blobcache_ListEntriesServer) error
func (UnimplementedBlobcacheServer) Post ¶
func (UnimplementedBlobcacheServer) Post(context.Context, *PostReq) (*wrapperspb.BytesValue, 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.
type WaitReq ¶
type WaitReq struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` // contains filtered or unexported fields }
func (*WaitReq) Descriptor
deprecated
func (*WaitReq) ProtoMessage ¶
func (*WaitReq) ProtoMessage()
func (*WaitReq) ProtoReflect ¶
func (x *WaitReq) ProtoReflect() protoreflect.Message