Versions in this module Expand all Collapse all v0 v0.4.2 Mar 16, 2020 v0.4.1 Mar 2, 2020 v0.4.0 Feb 18, 2020 v0.3.2 Feb 10, 2020 v0.3.1 Feb 7, 2020 v0.3.0 Feb 5, 2020 v0.2.14 Feb 4, 2020 v0.2.13 Feb 3, 2020 Changes in this version + const AccessModeReadWrite + const ErrNotFound + var ErrIntOverflowService = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group") + func RegisterServiceServer(s *grpc.Server, srv ServiceServer) + type AccessControlList struct + List []AccessGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AccessControlList) Descriptor() ([]byte, []int) + func (*AccessControlList) ProtoMessage() + func (m *AccessControlList) GetList() []AccessGroup + func (m *AccessControlList) Marshal() (dAtA []byte, err error) + func (m *AccessControlList) MarshalTo(dAtA []byte) (int, error) + func (m *AccessControlList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AccessControlList) Reset() + func (m *AccessControlList) Size() (n int) + func (m *AccessControlList) String() string + func (m *AccessControlList) Unmarshal(dAtA []byte) error + func (m *AccessControlList) XXX_DiscardUnknown() + func (m *AccessControlList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AccessControlList) XXX_Merge(src proto.Message) + func (m *AccessControlList) XXX_Size() int + func (m *AccessControlList) XXX_Unmarshal(b []byte) error + type AccessGroup struct + AccessMode uint32 + UserGroup []OwnerID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AccessGroup) Descriptor() ([]byte, []int) + func (*AccessGroup) ProtoMessage() + func (m *AccessGroup) GetAccessMode() uint32 + func (m *AccessGroup) Marshal() (dAtA []byte, err error) + func (m *AccessGroup) MarshalTo(dAtA []byte) (int, error) + func (m *AccessGroup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AccessGroup) Reset() + func (m *AccessGroup) Size() (n int) + func (m *AccessGroup) String() string + func (m *AccessGroup) Unmarshal(dAtA []byte) error + func (m *AccessGroup) XXX_DiscardUnknown() + func (m *AccessGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AccessGroup) XXX_Merge(src proto.Message) + func (m *AccessGroup) XXX_Size() int + func (m *AccessGroup) XXX_Unmarshal(b []byte) error + type AccessMode uint32 + const AccessModeRead + const AccessModeWrite + type CID = refs.CID + type Container struct + Capacity uint64 + List AccessControlList + OwnerID OwnerID + Rules netmap.PlacementRule + Salt UUID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func New(cap uint64, owner OwnerID, rules netmap.PlacementRule) (*Container, error) + func NewTestContainer() (*Container, error) + func (*Container) Descriptor() ([]byte, []int) + func (*Container) ProtoMessage() + func (m *Container) Bytes() []byte + func (m *Container) Empty() bool + func (m *Container) GetCapacity() uint64 + func (m *Container) GetList() AccessControlList + func (m *Container) GetRules() netmap.PlacementRule + func (m *Container) ID() (CID, error) + func (m *Container) Marshal() (dAtA []byte, err error) + func (m *Container) MarshalTo(dAtA []byte) (int, error) + func (m *Container) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Container) Reset() + func (m *Container) Size() (n int) + func (m *Container) String() string + func (m *Container) Unmarshal(dAtA []byte) error + func (m *Container) XXX_DiscardUnknown() + func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Container) XXX_Merge(src proto.Message) + func (m *Container) XXX_Size() int + func (m *Container) XXX_Unmarshal(b []byte) error + type DeleteRequest struct + CID CID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteRequest) PrepareData() ([]byte, error) + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) Size() (n int) + func (m *DeleteRequest) String() string + func (m *DeleteRequest) Unmarshal(dAtA []byte) error + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type DeleteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) String() string + func (m *DeleteResponse) Unmarshal(dAtA []byte) error + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + type GetRequest struct + CID CID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) String() string + func (m *GetRequest) Unmarshal(dAtA []byte) error + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Container *Container + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetContainer() *Container + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) String() string + func (m *GetResponse) Unmarshal(dAtA []byte) error + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type ListRequest struct + OwnerID OwnerID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) Marshal() (dAtA []byte, err error) + func (m *ListRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListRequest) Reset() + func (m *ListRequest) Size() (n int) + func (m *ListRequest) String() string + func (m *ListRequest) Unmarshal(dAtA []byte) error + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type ListResponse struct + CID []CID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (m *ListResponse) Marshal() (dAtA []byte, err error) + func (m *ListResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListResponse) Reset() + func (m *ListResponse) Size() (n int) + func (m *ListResponse) String() string + func (m *ListResponse) Unmarshal(dAtA []byte) error + func (m *ListResponse) XXX_DiscardUnknown() + func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResponse) XXX_Merge(src proto.Message) + func (m *ListResponse) XXX_Size() int + func (m *ListResponse) XXX_Unmarshal(b []byte) error + type MessageID = refs.MessageID + type OwnerID = refs.OwnerID + type PutRequest struct + Capacity uint64 + Group AccessGroup + MessageID MessageID + OwnerID OwnerID + Rules netmap.PlacementRule + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) GetCapacity() uint64 + func (m *PutRequest) GetGroup() AccessGroup + func (m *PutRequest) GetRules() netmap.PlacementRule + func (m *PutRequest) Marshal() (dAtA []byte, err error) + func (m *PutRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutRequest) PrepareData() ([]byte, error) + func (m *PutRequest) Reset() + func (m *PutRequest) Size() (n int) + func (m *PutRequest) String() string + func (m *PutRequest) Unmarshal(dAtA []byte) error + func (m *PutRequest) XXX_DiscardUnknown() + func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutRequest) XXX_Merge(src proto.Message) + func (m *PutRequest) XXX_Size() int + func (m *PutRequest) XXX_Unmarshal(b []byte) error + type PutResponse struct + CID CID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) Marshal() (dAtA []byte, err error) + func (m *PutResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutResponse) Reset() + func (m *PutResponse) Size() (n int) + func (m *PutResponse) String() string + func (m *PutResponse) Unmarshal(dAtA []byte) error + func (m *PutResponse) XXX_DiscardUnknown() + func (m *PutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutResponse) XXX_Merge(src proto.Message) + func (m *PutResponse) XXX_Size() int + func (m *PutResponse) XXX_Unmarshal(b []byte) error + type ServiceClient interface + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) + func NewServiceClient(cc *grpc.ClientConn) ServiceClient + type ServiceServer interface + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + List func(context.Context, *ListRequest) (*ListResponse, error) + Put func(context.Context, *PutRequest) (*PutResponse, error) + type UUID = refs.UUID + type UnimplementedServiceServer struct + func (*UnimplementedServiceServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error) + func (*UnimplementedServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedServiceServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error) + func (*UnimplementedServiceServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)