tree

package

Go to main page

Versions in this module

v0

v0.38.6

May 2, 2024

v0.38.5

Apr 12, 2024

Changes in this version

type Option

+ func WithAPERouter(router policyengine.ChainRouter) Option

v0.38.4

Apr 10, 2024

v0.38.3

Apr 4, 2024

v0.38.2

Apr 2, 2024

v0.38.1

Mar 19, 2024

v0.38.0

Mar 15, 2024

Changes in this version

type Service

+ func (s *Service) ReplicateTreeOp(ctx context.Context, n netmapSDK.NodeInfo, req *ApplyRequest) error

v0.38.0-rc.2

Mar 5, 2024

v0.38.0-rc.1

Feb 21, 2024

v0.37.0

Dec 7, 2023

Changes in this version

+ const TreeService_AddByPath_FullMethodName

+ const TreeService_Add_FullMethodName

+ const TreeService_Apply_FullMethodName

+ const TreeService_GetNodeByPath_FullMethodName

+ const TreeService_GetOpLog_FullMethodName

+ const TreeService_GetSubTree_FullMethodName

+ const TreeService_Healthcheck_FullMethodName

+ const TreeService_Move_FullMethodName

+ const TreeService_Remove_FullMethodName

+ const TreeService_TreeList_FullMethodName

+ var GetSubTreeRequest_Body_Order_Direction_name = map[int32]string

+ var GetSubTreeRequest_Body_Order_Direction_value = map[string]int32

type ContainerSource

+ DeletionInfo func(cid.ID) (*container.DelInfo, error)

type GetSubTreeRequest_Body

+ OrderBy *GetSubTreeRequest_Body_Order

+ func (x *GetSubTreeRequest_Body) GetOrderBy() *GetSubTreeRequest_Body_Order

+ type GetSubTreeRequest_Body_Order struct

+ Direction GetSubTreeRequest_Body_Order_Direction

+ func (*GetSubTreeRequest_Body_Order) Descriptor() ([]byte, []int)

+ func (*GetSubTreeRequest_Body_Order) ProtoMessage()

+ func (x *GetSubTreeRequest_Body_Order) GetDirection() GetSubTreeRequest_Body_Order_Direction

+ func (x *GetSubTreeRequest_Body_Order) ProtoReflect() protoreflect.Message

+ func (x *GetSubTreeRequest_Body_Order) Reset()

+ func (x *GetSubTreeRequest_Body_Order) StableMarshal(buf []byte) []byte

+ func (x *GetSubTreeRequest_Body_Order) StableSize() (size int)

+ func (x *GetSubTreeRequest_Body_Order) String() string

+ type GetSubTreeRequest_Body_Order_Direction int32

+ const GetSubTreeRequest_Body_Order_Asc

+ const GetSubTreeRequest_Body_Order_None

+ func (GetSubTreeRequest_Body_Order_Direction) Descriptor() protoreflect.EnumDescriptor

+ func (GetSubTreeRequest_Body_Order_Direction) EnumDescriptor() ([]byte, []int)

+ func (GetSubTreeRequest_Body_Order_Direction) Type() protoreflect.EnumType

+ func (x GetSubTreeRequest_Body_Order_Direction) Enum() *GetSubTreeRequest_Body_Order_Direction

+ func (x GetSubTreeRequest_Body_Order_Direction) Number() protoreflect.EnumNumber

+ func (x GetSubTreeRequest_Body_Order_Direction) String() string

+ type MetricsRegister interface

+ AddReplicateTaskDuration func(time.Duration, bool)

+ AddReplicateWaitDuration func(time.Duration, bool)

+ AddSyncDuration func(time.Duration, bool)

type Option

+ func WithAuthorizedKeys(keys keys.PublicKeys) Option

+ func WithMetrics(v MetricsRegister) Option

v0.37.0-rc.1

Sep 14, 2023

v0.36.0

Jul 12, 2023

Changes in this version

+ var ErrAlreadySyncing = errors.New("service is being synchronized")

+ var ErrNotInContainer = errors.New("node is not in container")

+ var ErrShuttingDown = errors.New("service is shutting down")

+ var File_pkg_services_tree_service_proto protoreflect.FileDescriptor

+ var File_pkg_services_tree_types_proto protoreflect.FileDescriptor

+ var TreeService_ServiceDesc = grpc.ServiceDesc

+ func RegisterTreeServiceServer(s grpc.ServiceRegistrar, srv TreeServiceServer)

+ func SignMessage(m message, key *ecdsa.PrivateKey) error

+ type AddByPathRequest struct

+ Body *AddByPathRequest_Body

+ Signature *Signature

+ func (*AddByPathRequest) Descriptor() ([]byte, []int)

+ func (*AddByPathRequest) ProtoMessage()

+ func (x *AddByPathRequest) GetBody() *AddByPathRequest_Body

+ func (x *AddByPathRequest) GetSignature() *Signature

+ func (x *AddByPathRequest) ProtoReflect() protoreflect.Message

+ func (x *AddByPathRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *AddByPathRequest) Reset()

+ func (x *AddByPathRequest) SetSignature(sig *Signature)

+ func (x *AddByPathRequest) SignedDataSize() int

+ func (x *AddByPathRequest) StableMarshal(buf []byte) []byte

+ func (x *AddByPathRequest) StableSize() (size int)

+ func (x *AddByPathRequest) String() string

+ type AddByPathRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Meta []*KeyValue

+ Path []string

+ PathAttribute string

+ TreeId string

+ func (*AddByPathRequest_Body) Descriptor() ([]byte, []int)

+ func (*AddByPathRequest_Body) ProtoMessage()

+ func (x *AddByPathRequest_Body) GetBearerToken() []byte

+ func (x *AddByPathRequest_Body) GetContainerId() []byte

+ func (x *AddByPathRequest_Body) GetMeta() []*KeyValue

+ func (x *AddByPathRequest_Body) GetPath() []string

+ func (x *AddByPathRequest_Body) GetPathAttribute() string

+ func (x *AddByPathRequest_Body) GetTreeId() string

+ func (x *AddByPathRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *AddByPathRequest_Body) Reset()

+ func (x *AddByPathRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *AddByPathRequest_Body) StableSize() (size int)

+ func (x *AddByPathRequest_Body) String() string

+ type AddByPathResponse struct

+ Body *AddByPathResponse_Body

+ Signature *Signature

+ func (*AddByPathResponse) Descriptor() ([]byte, []int)

+ func (*AddByPathResponse) ProtoMessage()

+ func (x *AddByPathResponse) GetBody() *AddByPathResponse_Body

+ func (x *AddByPathResponse) GetSignature() *Signature

+ func (x *AddByPathResponse) ProtoReflect() protoreflect.Message

+ func (x *AddByPathResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *AddByPathResponse) Reset()

+ func (x *AddByPathResponse) SetSignature(sig *Signature)

+ func (x *AddByPathResponse) SignedDataSize() int

+ func (x *AddByPathResponse) StableMarshal(buf []byte) []byte

+ func (x *AddByPathResponse) StableSize() (size int)

+ func (x *AddByPathResponse) String() string

+ type AddByPathResponse_Body struct

+ Nodes []uint64

+ ParentId uint64

+ func (*AddByPathResponse_Body) Descriptor() ([]byte, []int)

+ func (*AddByPathResponse_Body) ProtoMessage()

+ func (x *AddByPathResponse_Body) GetNodes() []uint64

+ func (x *AddByPathResponse_Body) GetParentId() uint64

+ func (x *AddByPathResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *AddByPathResponse_Body) Reset()

+ func (x *AddByPathResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *AddByPathResponse_Body) StableSize() (size int)

+ func (x *AddByPathResponse_Body) String() string

+ type AddRequest struct

+ Body *AddRequest_Body

+ Signature *Signature

+ func (*AddRequest) Descriptor() ([]byte, []int)

+ func (*AddRequest) ProtoMessage()

+ func (x *AddRequest) GetBody() *AddRequest_Body

+ func (x *AddRequest) GetSignature() *Signature

+ func (x *AddRequest) ProtoReflect() protoreflect.Message

+ func (x *AddRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *AddRequest) Reset()

+ func (x *AddRequest) SetSignature(sig *Signature)

+ func (x *AddRequest) SignedDataSize() int

+ func (x *AddRequest) StableMarshal(buf []byte) []byte

+ func (x *AddRequest) StableSize() (size int)

+ func (x *AddRequest) String() string

+ type AddRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Meta []*KeyValue

+ ParentId uint64

+ TreeId string

+ func (*AddRequest_Body) Descriptor() ([]byte, []int)

+ func (*AddRequest_Body) ProtoMessage()

+ func (x *AddRequest_Body) GetBearerToken() []byte

+ func (x *AddRequest_Body) GetContainerId() []byte

+ func (x *AddRequest_Body) GetMeta() []*KeyValue

+ func (x *AddRequest_Body) GetParentId() uint64

+ func (x *AddRequest_Body) GetTreeId() string

+ func (x *AddRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *AddRequest_Body) Reset()

+ func (x *AddRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *AddRequest_Body) StableSize() (size int)

+ func (x *AddRequest_Body) String() string

+ type AddResponse struct

+ Body *AddResponse_Body

+ Signature *Signature

+ func (*AddResponse) Descriptor() ([]byte, []int)

+ func (*AddResponse) ProtoMessage()

+ func (x *AddResponse) GetBody() *AddResponse_Body

+ func (x *AddResponse) GetSignature() *Signature

+ func (x *AddResponse) ProtoReflect() protoreflect.Message

+ func (x *AddResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *AddResponse) Reset()

+ func (x *AddResponse) SetSignature(sig *Signature)

+ func (x *AddResponse) SignedDataSize() int

+ func (x *AddResponse) StableMarshal(buf []byte) []byte

+ func (x *AddResponse) StableSize() (size int)

+ func (x *AddResponse) String() string

+ type AddResponse_Body struct

+ NodeId uint64

+ func (*AddResponse_Body) Descriptor() ([]byte, []int)

+ func (*AddResponse_Body) ProtoMessage()

+ func (x *AddResponse_Body) GetNodeId() uint64

+ func (x *AddResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *AddResponse_Body) Reset()

+ func (x *AddResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *AddResponse_Body) StableSize() (size int)

+ func (x *AddResponse_Body) String() string

+ type ApplyRequest struct

+ Body *ApplyRequest_Body

+ Signature *Signature

+ func (*ApplyRequest) Descriptor() ([]byte, []int)

+ func (*ApplyRequest) ProtoMessage()

+ func (x *ApplyRequest) GetBody() *ApplyRequest_Body

+ func (x *ApplyRequest) GetSignature() *Signature

+ func (x *ApplyRequest) ProtoReflect() protoreflect.Message

+ func (x *ApplyRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *ApplyRequest) Reset()

+ func (x *ApplyRequest) SetSignature(sig *Signature)

+ func (x *ApplyRequest) SignedDataSize() int

+ func (x *ApplyRequest) StableMarshal(buf []byte) []byte

+ func (x *ApplyRequest) StableSize() (size int)

+ func (x *ApplyRequest) String() string

+ type ApplyRequest_Body struct

+ ContainerId []byte

+ Operation *LogMove

+ TreeId string

+ func (*ApplyRequest_Body) Descriptor() ([]byte, []int)

+ func (*ApplyRequest_Body) ProtoMessage()

+ func (x *ApplyRequest_Body) GetContainerId() []byte

+ func (x *ApplyRequest_Body) GetOperation() *LogMove

+ func (x *ApplyRequest_Body) GetTreeId() string

+ func (x *ApplyRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *ApplyRequest_Body) Reset()

+ func (x *ApplyRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *ApplyRequest_Body) StableSize() (size int)

+ func (x *ApplyRequest_Body) String() string

+ type ApplyResponse struct

+ Body *ApplyResponse_Body

+ Signature *Signature

+ func (*ApplyResponse) Descriptor() ([]byte, []int)

+ func (*ApplyResponse) ProtoMessage()

+ func (x *ApplyResponse) GetBody() *ApplyResponse_Body

+ func (x *ApplyResponse) GetSignature() *Signature

+ func (x *ApplyResponse) ProtoReflect() protoreflect.Message

+ func (x *ApplyResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *ApplyResponse) Reset()

+ func (x *ApplyResponse) SetSignature(sig *Signature)

+ func (x *ApplyResponse) SignedDataSize() int

+ func (x *ApplyResponse) StableMarshal(buf []byte) []byte

+ func (x *ApplyResponse) StableSize() (size int)

+ func (x *ApplyResponse) String() string

+ type ApplyResponse_Body struct

+ func (*ApplyResponse_Body) Descriptor() ([]byte, []int)

+ func (*ApplyResponse_Body) ProtoMessage()

+ func (x *ApplyResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *ApplyResponse_Body) Reset()

+ func (x *ApplyResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *ApplyResponse_Body) StableSize() (size int)

+ func (x *ApplyResponse_Body) String() string

+ type ContainerSource interface

+ List func() ([]cid.ID, error)

+ type GetNodeByPathRequest struct

+ Body *GetNodeByPathRequest_Body

+ Signature *Signature

+ func (*GetNodeByPathRequest) Descriptor() ([]byte, []int)

+ func (*GetNodeByPathRequest) ProtoMessage()

+ func (x *GetNodeByPathRequest) GetBody() *GetNodeByPathRequest_Body

+ func (x *GetNodeByPathRequest) GetSignature() *Signature

+ func (x *GetNodeByPathRequest) ProtoReflect() protoreflect.Message

+ func (x *GetNodeByPathRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *GetNodeByPathRequest) Reset()

+ func (x *GetNodeByPathRequest) SetSignature(sig *Signature)

+ func (x *GetNodeByPathRequest) SignedDataSize() int

+ func (x *GetNodeByPathRequest) StableMarshal(buf []byte) []byte

+ func (x *GetNodeByPathRequest) StableSize() (size int)

+ func (x *GetNodeByPathRequest) String() string

+ type GetNodeByPathRequest_Body struct

+ AllAttributes bool

+ Attributes []string

+ BearerToken []byte

+ ContainerId []byte

+ LatestOnly bool

+ Path []string

+ PathAttribute string

+ TreeId string

+ func (*GetNodeByPathRequest_Body) Descriptor() ([]byte, []int)

+ func (*GetNodeByPathRequest_Body) ProtoMessage()

+ func (x *GetNodeByPathRequest_Body) GetAllAttributes() bool

+ func (x *GetNodeByPathRequest_Body) GetAttributes() []string

+ func (x *GetNodeByPathRequest_Body) GetBearerToken() []byte

+ func (x *GetNodeByPathRequest_Body) GetContainerId() []byte

+ func (x *GetNodeByPathRequest_Body) GetLatestOnly() bool

+ func (x *GetNodeByPathRequest_Body) GetPath() []string

+ func (x *GetNodeByPathRequest_Body) GetPathAttribute() string

+ func (x *GetNodeByPathRequest_Body) GetTreeId() string

+ func (x *GetNodeByPathRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *GetNodeByPathRequest_Body) Reset()

+ func (x *GetNodeByPathRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *GetNodeByPathRequest_Body) StableSize() (size int)

+ func (x *GetNodeByPathRequest_Body) String() string

+ type GetNodeByPathResponse struct

+ Body *GetNodeByPathResponse_Body

+ Signature *Signature

+ func (*GetNodeByPathResponse) Descriptor() ([]byte, []int)

+ func (*GetNodeByPathResponse) ProtoMessage()

+ func (x *GetNodeByPathResponse) GetBody() *GetNodeByPathResponse_Body

+ func (x *GetNodeByPathResponse) GetSignature() *Signature

+ func (x *GetNodeByPathResponse) ProtoReflect() protoreflect.Message

+ func (x *GetNodeByPathResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *GetNodeByPathResponse) Reset()

+ func (x *GetNodeByPathResponse) SetSignature(sig *Signature)

+ func (x *GetNodeByPathResponse) SignedDataSize() int

+ func (x *GetNodeByPathResponse) StableMarshal(buf []byte) []byte

+ func (x *GetNodeByPathResponse) StableSize() (size int)

+ func (x *GetNodeByPathResponse) String() string

+ type GetNodeByPathResponse_Body struct

+ Nodes []*GetNodeByPathResponse_Info

+ func (*GetNodeByPathResponse_Body) Descriptor() ([]byte, []int)

+ func (*GetNodeByPathResponse_Body) ProtoMessage()

+ func (x *GetNodeByPathResponse_Body) GetNodes() []*GetNodeByPathResponse_Info

+ func (x *GetNodeByPathResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *GetNodeByPathResponse_Body) Reset()

+ func (x *GetNodeByPathResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *GetNodeByPathResponse_Body) StableSize() (size int)

+ func (x *GetNodeByPathResponse_Body) String() string

+ type GetNodeByPathResponse_Info struct

+ Meta []*KeyValue

+ NodeId uint64

+ ParentId uint64

+ Timestamp uint64

+ func (*GetNodeByPathResponse_Info) Descriptor() ([]byte, []int)

+ func (*GetNodeByPathResponse_Info) ProtoMessage()

+ func (x *GetNodeByPathResponse_Info) GetMeta() []*KeyValue

+ func (x *GetNodeByPathResponse_Info) GetNodeId() uint64

+ func (x *GetNodeByPathResponse_Info) GetParentId() uint64

+ func (x *GetNodeByPathResponse_Info) GetTimestamp() uint64

+ func (x *GetNodeByPathResponse_Info) ProtoReflect() protoreflect.Message

+ func (x *GetNodeByPathResponse_Info) Reset()

+ func (x *GetNodeByPathResponse_Info) StableMarshal(buf []byte) []byte

+ func (x *GetNodeByPathResponse_Info) StableSize() (size int)

+ func (x *GetNodeByPathResponse_Info) String() string

+ type GetOpLogRequest struct

+ Body *GetOpLogRequest_Body

+ Signature *Signature

+ func (*GetOpLogRequest) Descriptor() ([]byte, []int)

+ func (*GetOpLogRequest) ProtoMessage()

+ func (x *GetOpLogRequest) GetBody() *GetOpLogRequest_Body

+ func (x *GetOpLogRequest) GetSignature() *Signature

+ func (x *GetOpLogRequest) ProtoReflect() protoreflect.Message

+ func (x *GetOpLogRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *GetOpLogRequest) Reset()

+ func (x *GetOpLogRequest) SetSignature(sig *Signature)

+ func (x *GetOpLogRequest) SignedDataSize() int

+ func (x *GetOpLogRequest) StableMarshal(buf []byte) []byte

+ func (x *GetOpLogRequest) StableSize() (size int)

+ func (x *GetOpLogRequest) String() string

+ type GetOpLogRequest_Body struct

+ ContainerId []byte

+ Count uint64

+ Height uint64

+ TreeId string

+ func (*GetOpLogRequest_Body) Descriptor() ([]byte, []int)

+ func (*GetOpLogRequest_Body) ProtoMessage()

+ func (x *GetOpLogRequest_Body) GetContainerId() []byte

+ func (x *GetOpLogRequest_Body) GetCount() uint64

+ func (x *GetOpLogRequest_Body) GetHeight() uint64

+ func (x *GetOpLogRequest_Body) GetTreeId() string

+ func (x *GetOpLogRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *GetOpLogRequest_Body) Reset()

+ func (x *GetOpLogRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *GetOpLogRequest_Body) StableSize() (size int)

+ func (x *GetOpLogRequest_Body) String() string

+ type GetOpLogResponse struct

+ Body *GetOpLogResponse_Body

+ Signature *Signature

+ func (*GetOpLogResponse) Descriptor() ([]byte, []int)

+ func (*GetOpLogResponse) ProtoMessage()

+ func (x *GetOpLogResponse) GetBody() *GetOpLogResponse_Body

+ func (x *GetOpLogResponse) GetSignature() *Signature

+ func (x *GetOpLogResponse) ProtoReflect() protoreflect.Message

+ func (x *GetOpLogResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *GetOpLogResponse) Reset()

+ func (x *GetOpLogResponse) SetSignature(sig *Signature)

+ func (x *GetOpLogResponse) SignedDataSize() int

+ func (x *GetOpLogResponse) StableMarshal(buf []byte) []byte

+ func (x *GetOpLogResponse) StableSize() (size int)

+ func (x *GetOpLogResponse) String() string

+ type GetOpLogResponse_Body struct

+ Operation *LogMove

+ func (*GetOpLogResponse_Body) Descriptor() ([]byte, []int)

+ func (*GetOpLogResponse_Body) ProtoMessage()

+ func (x *GetOpLogResponse_Body) GetOperation() *LogMove

+ func (x *GetOpLogResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *GetOpLogResponse_Body) Reset()

+ func (x *GetOpLogResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *GetOpLogResponse_Body) StableSize() (size int)

+ func (x *GetOpLogResponse_Body) String() string

+ type GetSubTreeRequest struct

+ Body *GetSubTreeRequest_Body

+ Signature *Signature

+ func (*GetSubTreeRequest) Descriptor() ([]byte, []int)

+ func (*GetSubTreeRequest) ProtoMessage()

+ func (x *GetSubTreeRequest) GetBody() *GetSubTreeRequest_Body

+ func (x *GetSubTreeRequest) GetSignature() *Signature

+ func (x *GetSubTreeRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSubTreeRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *GetSubTreeRequest) Reset()

+ func (x *GetSubTreeRequest) SetSignature(sig *Signature)

+ func (x *GetSubTreeRequest) SignedDataSize() int

+ func (x *GetSubTreeRequest) StableMarshal(buf []byte) []byte

+ func (x *GetSubTreeRequest) StableSize() (size int)

+ func (x *GetSubTreeRequest) String() string

+ type GetSubTreeRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Depth uint32

+ RootId uint64

+ TreeId string

+ func (*GetSubTreeRequest_Body) Descriptor() ([]byte, []int)

+ func (*GetSubTreeRequest_Body) ProtoMessage()

+ func (x *GetSubTreeRequest_Body) GetBearerToken() []byte

+ func (x *GetSubTreeRequest_Body) GetContainerId() []byte

+ func (x *GetSubTreeRequest_Body) GetDepth() uint32

+ func (x *GetSubTreeRequest_Body) GetRootId() uint64

+ func (x *GetSubTreeRequest_Body) GetTreeId() string

+ func (x *GetSubTreeRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *GetSubTreeRequest_Body) Reset()

+ func (x *GetSubTreeRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *GetSubTreeRequest_Body) StableSize() (size int)

+ func (x *GetSubTreeRequest_Body) String() string

+ type GetSubTreeResponse struct

+ Body *GetSubTreeResponse_Body

+ Signature *Signature

+ func (*GetSubTreeResponse) Descriptor() ([]byte, []int)

+ func (*GetSubTreeResponse) ProtoMessage()

+ func (x *GetSubTreeResponse) GetBody() *GetSubTreeResponse_Body

+ func (x *GetSubTreeResponse) GetSignature() *Signature

+ func (x *GetSubTreeResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSubTreeResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *GetSubTreeResponse) Reset()

+ func (x *GetSubTreeResponse) SetSignature(sig *Signature)

+ func (x *GetSubTreeResponse) SignedDataSize() int

+ func (x *GetSubTreeResponse) StableMarshal(buf []byte) []byte

+ func (x *GetSubTreeResponse) StableSize() (size int)

+ func (x *GetSubTreeResponse) String() string

+ type GetSubTreeResponse_Body struct

+ Meta []*KeyValue

+ NodeId uint64

+ ParentId uint64

+ Timestamp uint64

+ func (*GetSubTreeResponse_Body) Descriptor() ([]byte, []int)

+ func (*GetSubTreeResponse_Body) ProtoMessage()

+ func (x *GetSubTreeResponse_Body) GetMeta() []*KeyValue

+ func (x *GetSubTreeResponse_Body) GetNodeId() uint64

+ func (x *GetSubTreeResponse_Body) GetParentId() uint64

+ func (x *GetSubTreeResponse_Body) GetTimestamp() uint64

+ func (x *GetSubTreeResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *GetSubTreeResponse_Body) Reset()

+ func (x *GetSubTreeResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *GetSubTreeResponse_Body) StableSize() (size int)

+ func (x *GetSubTreeResponse_Body) String() string

+ type HealthcheckRequest struct

+ Body *HealthcheckRequest_Body

+ Signature *Signature

+ func (*HealthcheckRequest) Descriptor() ([]byte, []int)

+ func (*HealthcheckRequest) ProtoMessage()

+ func (x *HealthcheckRequest) GetBody() *HealthcheckRequest_Body

+ func (x *HealthcheckRequest) GetSignature() *Signature

+ func (x *HealthcheckRequest) ProtoReflect() protoreflect.Message

+ func (x *HealthcheckRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *HealthcheckRequest) Reset()

+ func (x *HealthcheckRequest) SetSignature(sig *Signature)

+ func (x *HealthcheckRequest) SignedDataSize() int

+ func (x *HealthcheckRequest) StableMarshal(buf []byte) []byte

+ func (x *HealthcheckRequest) StableSize() (size int)

+ func (x *HealthcheckRequest) String() string

+ type HealthcheckRequest_Body struct

+ func (*HealthcheckRequest_Body) Descriptor() ([]byte, []int)

+ func (*HealthcheckRequest_Body) ProtoMessage()

+ func (x *HealthcheckRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *HealthcheckRequest_Body) Reset()

+ func (x *HealthcheckRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *HealthcheckRequest_Body) StableSize() (size int)

+ func (x *HealthcheckRequest_Body) String() string

+ type HealthcheckResponse struct

+ Body *HealthcheckResponse_Body

+ Signature *Signature

+ func (*HealthcheckResponse) Descriptor() ([]byte, []int)

+ func (*HealthcheckResponse) ProtoMessage()

+ func (x *HealthcheckResponse) GetBody() *HealthcheckResponse_Body

+ func (x *HealthcheckResponse) GetSignature() *Signature

+ func (x *HealthcheckResponse) ProtoReflect() protoreflect.Message

+ func (x *HealthcheckResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *HealthcheckResponse) Reset()

+ func (x *HealthcheckResponse) SetSignature(sig *Signature)

+ func (x *HealthcheckResponse) SignedDataSize() int

+ func (x *HealthcheckResponse) StableMarshal(buf []byte) []byte

+ func (x *HealthcheckResponse) StableSize() (size int)

+ func (x *HealthcheckResponse) String() string

+ type HealthcheckResponse_Body struct

+ func (*HealthcheckResponse_Body) Descriptor() ([]byte, []int)

+ func (*HealthcheckResponse_Body) ProtoMessage()

+ func (x *HealthcheckResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *HealthcheckResponse_Body) Reset()

+ func (x *HealthcheckResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *HealthcheckResponse_Body) StableSize() (size int)

+ func (x *HealthcheckResponse_Body) String() string

+ type KeyValue struct

+ Key string

+ Value []byte

+ func (*KeyValue) Descriptor() ([]byte, []int)

+ func (*KeyValue) ProtoMessage()

+ func (x *KeyValue) GetKey() string

+ func (x *KeyValue) GetValue() []byte

+ func (x *KeyValue) ProtoReflect() protoreflect.Message

+ func (x *KeyValue) Reset()

+ func (x *KeyValue) StableMarshal(buf []byte) []byte

+ func (x *KeyValue) StableSize() (size int)

+ func (x *KeyValue) String() string

+ type LogMove struct

+ ChildId uint64

+ Meta []byte

+ ParentId uint64

+ func (*LogMove) Descriptor() ([]byte, []int)

+ func (*LogMove) ProtoMessage()

+ func (x *LogMove) GetChildId() uint64

+ func (x *LogMove) GetMeta() []byte

+ func (x *LogMove) GetParentId() uint64

+ func (x *LogMove) ProtoReflect() protoreflect.Message

+ func (x *LogMove) Reset()

+ func (x *LogMove) StableMarshal(buf []byte) []byte

+ func (x *LogMove) StableSize() (size int)

+ func (x *LogMove) String() string

+ type MoveRequest struct

+ Body *MoveRequest_Body

+ Signature *Signature

+ func (*MoveRequest) Descriptor() ([]byte, []int)

+ func (*MoveRequest) ProtoMessage()

+ func (x *MoveRequest) GetBody() *MoveRequest_Body

+ func (x *MoveRequest) GetSignature() *Signature

+ func (x *MoveRequest) ProtoReflect() protoreflect.Message

+ func (x *MoveRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *MoveRequest) Reset()

+ func (x *MoveRequest) SetSignature(sig *Signature)

+ func (x *MoveRequest) SignedDataSize() int

+ func (x *MoveRequest) StableMarshal(buf []byte) []byte

+ func (x *MoveRequest) StableSize() (size int)

+ func (x *MoveRequest) String() string

+ type MoveRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Meta []*KeyValue

+ NodeId uint64

+ ParentId uint64

+ TreeId string

+ func (*MoveRequest_Body) Descriptor() ([]byte, []int)

+ func (*MoveRequest_Body) ProtoMessage()

+ func (x *MoveRequest_Body) GetBearerToken() []byte

+ func (x *MoveRequest_Body) GetContainerId() []byte

+ func (x *MoveRequest_Body) GetMeta() []*KeyValue

+ func (x *MoveRequest_Body) GetNodeId() uint64

+ func (x *MoveRequest_Body) GetParentId() uint64

+ func (x *MoveRequest_Body) GetTreeId() string

+ func (x *MoveRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *MoveRequest_Body) Reset()

+ func (x *MoveRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *MoveRequest_Body) StableSize() (size int)

+ func (x *MoveRequest_Body) String() string

+ type MoveResponse struct

+ Body *MoveResponse_Body

+ Signature *Signature

+ func (*MoveResponse) Descriptor() ([]byte, []int)

+ func (*MoveResponse) ProtoMessage()

+ func (x *MoveResponse) GetBody() *MoveResponse_Body

+ func (x *MoveResponse) GetSignature() *Signature

+ func (x *MoveResponse) ProtoReflect() protoreflect.Message

+ func (x *MoveResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *MoveResponse) Reset()

+ func (x *MoveResponse) SetSignature(sig *Signature)

+ func (x *MoveResponse) SignedDataSize() int

+ func (x *MoveResponse) StableMarshal(buf []byte) []byte

+ func (x *MoveResponse) StableSize() (size int)

+ func (x *MoveResponse) String() string

+ type MoveResponse_Body struct

+ func (*MoveResponse_Body) Descriptor() ([]byte, []int)

+ func (*MoveResponse_Body) ProtoMessage()

+ func (x *MoveResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *MoveResponse_Body) Reset()

+ func (x *MoveResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *MoveResponse_Body) StableSize() (size int)

+ func (x *MoveResponse_Body) String() string

+ type Option func(*cfg)

+ func WithContainerCacheSize(n int) Option

+ func WithContainerSource(src ContainerSource) Option

+ func WithEACLSource(src container.EACLSource) Option

+ func WithLogger(log *logger.Logger) Option

+ func WithNetmapSource(src netmap.Source) Option

+ func WithPrivateKey(key *ecdsa.PrivateKey) Option

+ func WithReplicationChannelCapacity(n int) Option

+ func WithReplicationTimeout(t time.Duration) Option

+ func WithReplicationWorkerCount(n int) Option

+ func WithStorage(s pilorama.Forest) Option

+ type RemoveRequest struct

+ Body *RemoveRequest_Body

+ Signature *Signature

+ func (*RemoveRequest) Descriptor() ([]byte, []int)

+ func (*RemoveRequest) ProtoMessage()

+ func (x *RemoveRequest) GetBody() *RemoveRequest_Body

+ func (x *RemoveRequest) GetSignature() *Signature

+ func (x *RemoveRequest) ProtoReflect() protoreflect.Message

+ func (x *RemoveRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *RemoveRequest) Reset()

+ func (x *RemoveRequest) SetSignature(sig *Signature)

+ func (x *RemoveRequest) SignedDataSize() int

+ func (x *RemoveRequest) StableMarshal(buf []byte) []byte

+ func (x *RemoveRequest) StableSize() (size int)

+ func (x *RemoveRequest) String() string

+ type RemoveRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ NodeId uint64

+ TreeId string

+ func (*RemoveRequest_Body) Descriptor() ([]byte, []int)

+ func (*RemoveRequest_Body) ProtoMessage()

+ func (x *RemoveRequest_Body) GetBearerToken() []byte

+ func (x *RemoveRequest_Body) GetContainerId() []byte

+ func (x *RemoveRequest_Body) GetNodeId() uint64

+ func (x *RemoveRequest_Body) GetTreeId() string

+ func (x *RemoveRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *RemoveRequest_Body) Reset()

+ func (x *RemoveRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *RemoveRequest_Body) StableSize() (size int)

+ func (x *RemoveRequest_Body) String() string

+ type RemoveResponse struct

+ Body *RemoveResponse_Body

+ Signature *Signature

+ func (*RemoveResponse) Descriptor() ([]byte, []int)

+ func (*RemoveResponse) ProtoMessage()

+ func (x *RemoveResponse) GetBody() *RemoveResponse_Body

+ func (x *RemoveResponse) GetSignature() *Signature

+ func (x *RemoveResponse) ProtoReflect() protoreflect.Message

+ func (x *RemoveResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *RemoveResponse) Reset()

+ func (x *RemoveResponse) SetSignature(sig *Signature)

+ func (x *RemoveResponse) SignedDataSize() int

+ func (x *RemoveResponse) StableMarshal(buf []byte) []byte

+ func (x *RemoveResponse) StableSize() (size int)

+ func (x *RemoveResponse) String() string

+ type RemoveResponse_Body struct

+ func (*RemoveResponse_Body) Descriptor() ([]byte, []int)

+ func (*RemoveResponse_Body) ProtoMessage()

+ func (x *RemoveResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *RemoveResponse_Body) Reset()

+ func (x *RemoveResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *RemoveResponse_Body) StableSize() (size int)

+ func (x *RemoveResponse_Body) String() string

+ type Service struct

+ func New(opts ...Option) *Service

+ func (s *Service) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)

+ func (s *Service) AddByPath(ctx context.Context, req *AddByPathRequest) (*AddByPathResponse, error)

+ func (s *Service) Apply(_ context.Context, req *ApplyRequest) (*ApplyResponse, error)

+ func (s *Service) DropTree(_ context.Context, cid cid.ID, treeID string) error

+ func (s *Service) GetNodeByPath(ctx context.Context, req *GetNodeByPathRequest) (*GetNodeByPathResponse, error)

+ func (s *Service) GetOpLog(req *GetOpLogRequest, srv TreeService_GetOpLogServer) error

+ func (s *Service) GetSubTree(req *GetSubTreeRequest, srv TreeService_GetSubTreeServer) error

+ func (s *Service) Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)

+ func (s *Service) Move(ctx context.Context, req *MoveRequest) (*MoveResponse, error)

+ func (s *Service) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)

+ func (s *Service) Shutdown()

+ func (s *Service) Start(ctx context.Context)

+ func (s *Service) SynchronizeAll() error

+ func (s *Service) SynchronizeTree(ctx context.Context, cid cid.ID, treeID string) error

+ func (s *Service) TreeList(ctx context.Context, req *TreeListRequest) (*TreeListResponse, error)

+ type Signature struct

+ Key []byte

+ Sign []byte

+ func (*Signature) Descriptor() ([]byte, []int)

+ func (*Signature) ProtoMessage()

+ func (x *Signature) GetKey() []byte

+ func (x *Signature) GetSign() []byte

+ func (x *Signature) ProtoReflect() protoreflect.Message

+ func (x *Signature) Reset()

+ func (x *Signature) StableMarshal(buf []byte) []byte

+ func (x *Signature) StableSize() (size int)

+ func (x *Signature) String() string

+ type TreeListRequest struct

+ Body *TreeListRequest_Body

+ Signature *Signature

+ func (*TreeListRequest) Descriptor() ([]byte, []int)

+ func (*TreeListRequest) ProtoMessage()

+ func (x *TreeListRequest) GetBody() *TreeListRequest_Body

+ func (x *TreeListRequest) GetSignature() *Signature

+ func (x *TreeListRequest) ProtoReflect() protoreflect.Message

+ func (x *TreeListRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *TreeListRequest) Reset()

+ func (x *TreeListRequest) SetSignature(sig *Signature)

+ func (x *TreeListRequest) SignedDataSize() int

+ func (x *TreeListRequest) StableMarshal(buf []byte) []byte

+ func (x *TreeListRequest) StableSize() (size int)

+ func (x *TreeListRequest) String() string

+ type TreeListRequest_Body struct

+ ContainerId []byte

+ func (*TreeListRequest_Body) Descriptor() ([]byte, []int)

+ func (*TreeListRequest_Body) ProtoMessage()

+ func (x *TreeListRequest_Body) GetContainerId() []byte

+ func (x *TreeListRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *TreeListRequest_Body) Reset()

+ func (x *TreeListRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *TreeListRequest_Body) StableSize() (size int)

+ func (x *TreeListRequest_Body) String() string

+ type TreeListResponse struct

+ Body *TreeListResponse_Body

+ Signature *Signature

+ func (*TreeListResponse) Descriptor() ([]byte, []int)

+ func (*TreeListResponse) ProtoMessage()

+ func (x *TreeListResponse) GetBody() *TreeListResponse_Body

+ func (x *TreeListResponse) GetSignature() *Signature

+ func (x *TreeListResponse) ProtoReflect() protoreflect.Message

+ func (x *TreeListResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *TreeListResponse) Reset()

+ func (x *TreeListResponse) SetSignature(sig *Signature)

+ func (x *TreeListResponse) SignedDataSize() int

+ func (x *TreeListResponse) StableMarshal(buf []byte) []byte

+ func (x *TreeListResponse) StableSize() (size int)

+ func (x *TreeListResponse) String() string

+ type TreeListResponse_Body struct

+ Ids []string

+ func (*TreeListResponse_Body) Descriptor() ([]byte, []int)

+ func (*TreeListResponse_Body) ProtoMessage()

+ func (x *TreeListResponse_Body) GetIds() []string

+ func (x *TreeListResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *TreeListResponse_Body) Reset()

+ func (x *TreeListResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *TreeListResponse_Body) StableSize() (size int)

+ func (x *TreeListResponse_Body) String() string

+ type TreeServiceClient interface

+ Add func(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)

+ AddByPath func(ctx context.Context, in *AddByPathRequest, opts ...grpc.CallOption) (*AddByPathResponse, error)

+ Apply func(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)

+ GetNodeByPath func(ctx context.Context, in *GetNodeByPathRequest, opts ...grpc.CallOption) (*GetNodeByPathResponse, error)

+ GetOpLog func(ctx context.Context, in *GetOpLogRequest, opts ...grpc.CallOption) (TreeService_GetOpLogClient, error)

+ GetSubTree func(ctx context.Context, in *GetSubTreeRequest, opts ...grpc.CallOption) (TreeService_GetSubTreeClient, error)

+ Healthcheck func(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error)

+ Move func(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*MoveResponse, error)

+ Remove func(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)

+ TreeList func(ctx context.Context, in *TreeListRequest, opts ...grpc.CallOption) (*TreeListResponse, error)

+ func NewTreeServiceClient(cc grpc.ClientConnInterface) TreeServiceClient

+ type TreeServiceServer interface

+ Add func(context.Context, *AddRequest) (*AddResponse, error)

+ AddByPath func(context.Context, *AddByPathRequest) (*AddByPathResponse, error)

+ Apply func(context.Context, *ApplyRequest) (*ApplyResponse, error)

+ GetNodeByPath func(context.Context, *GetNodeByPathRequest) (*GetNodeByPathResponse, error)

+ GetOpLog func(*GetOpLogRequest, TreeService_GetOpLogServer) error

+ GetSubTree func(*GetSubTreeRequest, TreeService_GetSubTreeServer) error

+ Healthcheck func(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)

+ Move func(context.Context, *MoveRequest) (*MoveResponse, error)

+ Remove func(context.Context, *RemoveRequest) (*RemoveResponse, error)

+ TreeList func(context.Context, *TreeListRequest) (*TreeListResponse, error)

+ type TreeService_GetOpLogClient interface

+ Recv func() (*GetOpLogResponse, error)

+ type TreeService_GetOpLogServer interface

+ Send func(*GetOpLogResponse) error

+ type TreeService_GetSubTreeClient interface

+ Recv func() (*GetSubTreeResponse, error)

+ type TreeService_GetSubTreeServer interface

+ Send func(*GetSubTreeResponse) error

+ type UnimplementedTreeServiceServer struct

+ func (UnimplementedTreeServiceServer) Add(context.Context, *AddRequest) (*AddResponse, error)

+ func (UnimplementedTreeServiceServer) AddByPath(context.Context, *AddByPathRequest) (*AddByPathResponse, error)

+ func (UnimplementedTreeServiceServer) Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)

+ func (UnimplementedTreeServiceServer) GetNodeByPath(context.Context, *GetNodeByPathRequest) (*GetNodeByPathResponse, error)

+ func (UnimplementedTreeServiceServer) GetOpLog(*GetOpLogRequest, TreeService_GetOpLogServer) error

+ func (UnimplementedTreeServiceServer) GetSubTree(*GetSubTreeRequest, TreeService_GetSubTreeServer) error

+ func (UnimplementedTreeServiceServer) Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)

+ func (UnimplementedTreeServiceServer) Move(context.Context, *MoveRequest) (*MoveResponse, error)

+ func (UnimplementedTreeServiceServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)

+ func (UnimplementedTreeServiceServer) TreeList(context.Context, *TreeListRequest) (*TreeListResponse, error)

+ type UnsafeTreeServiceServer interface

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