tree

package
v0.0.0-...-79ba347 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2023 License: GPL-3.0 Imports: 44 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

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

ErrAlreadySyncing is returned when a service synchronization has already been started.

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

ErrNotInContainer is returned when operation could not be performed because the node is not included in the container.

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

ErrShuttingDown is returned when the service is shitting down and could not accept any calls.

View Source 
var File_pkg_services_tree_service_proto protoreflect.FileDescriptor
View Source 
var File_pkg_services_tree_types_proto protoreflect.FileDescriptor
View Source 
var TreeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.TreeService",
	HandlerType: (*TreeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Add",
			Handler:    _TreeService_Add_Handler,
		},
		{
			MethodName: "AddByPath",
			Handler:    _TreeService_AddByPath_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _TreeService_Remove_Handler,
		},
		{
			MethodName: "Move",
			Handler:    _TreeService_Move_Handler,
		},
		{
			MethodName: "GetNodeByPath",
			Handler:    _TreeService_GetNodeByPath_Handler,
		},
		{
			MethodName: "TreeList",
			Handler:    _TreeService_TreeList_Handler,
		},
		{
			MethodName: "Apply",
			Handler:    _TreeService_Apply_Handler,
		},
		{
			MethodName: "Healthcheck",
			Handler:    _TreeService_Healthcheck_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSubTree",
			Handler:       _TreeService_GetSubTree_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetOpLog",
			Handler:       _TreeService_GetOpLog_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/services/tree/service.proto",
}

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

Functions ¶

func RegisterTreeServiceServer ¶ 

func RegisterTreeServiceServer(s grpc.ServiceRegistrar, srv TreeServiceServer)

func SignMessage ¶ 

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

SignMessage uses the provided key and signs any protobuf message that was generated for the TreeService by the protoc-gen-go-frostfs generator. Returns any errors directly.

Types ¶

type AddByPathRequest ¶ 

type AddByPathRequest struct {

	// Request body.
	Body *AddByPathRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AddByPathRequest) Descriptor deprecated 

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

Deprecated: Use AddByPathRequest.ProtoReflect.Descriptor instead.

func (*AddByPathRequest) GetBody ¶ 

func (x *AddByPathRequest) GetBody() *AddByPathRequest_Body

func (*AddByPathRequest) GetSignature ¶ 

func (x *AddByPathRequest) GetSignature() *Signature

func (*AddByPathRequest) ProtoMessage ¶ 

func (*AddByPathRequest) ProtoMessage()

func (*AddByPathRequest) ProtoReflect ¶ 

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

func (*AddByPathRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*AddByPathRequest) Reset ¶ 

func (x *AddByPathRequest) Reset()

func (*AddByPathRequest) SetSignature ¶ 

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

func (*AddByPathRequest) SignedDataSize ¶ 

func (x *AddByPathRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*AddByPathRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddByPathRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddByPathRequest) String ¶ 

func (x *AddByPathRequest) String() string

type AddByPathRequest_Body ¶ 

type AddByPathRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// Attribute to build path with. Default: "FileName".
	PathAttribute string `protobuf:"bytes,3,opt,name=path_attribute,json=pathAttribute,proto3" json:"path_attribute,omitempty"`
	// List of path components.
	Path []string `protobuf:"bytes,4,rep,name=path,proto3" json:"path,omitempty"`
	// Node meta-information.
	Meta []*KeyValue `protobuf:"bytes,5,rep,name=meta,proto3" json:"meta,omitempty"`
	// Bearer token in V2 format.
	BearerToken []byte `protobuf:"bytes,6,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	// contains filtered or unexported fields
}

func (*AddByPathRequest_Body) Descriptor deprecated 

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

Deprecated: Use AddByPathRequest_Body.ProtoReflect.Descriptor instead.

func (*AddByPathRequest_Body) GetBearerToken ¶ 

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

func (*AddByPathRequest_Body) GetContainerId ¶ 

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

func (*AddByPathRequest_Body) GetMeta ¶ 

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

func (*AddByPathRequest_Body) GetPath ¶ 

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

func (*AddByPathRequest_Body) GetPathAttribute ¶ 

func (x *AddByPathRequest_Body) GetPathAttribute() string

func (*AddByPathRequest_Body) GetTreeId ¶ 

func (x *AddByPathRequest_Body) GetTreeId() string

func (*AddByPathRequest_Body) ProtoMessage ¶ 

func (*AddByPathRequest_Body) ProtoMessage()

func (*AddByPathRequest_Body) ProtoReflect ¶ 

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

func (*AddByPathRequest_Body) Reset ¶ 

func (x *AddByPathRequest_Body) Reset()

func (*AddByPathRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddByPathRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddByPathRequest_Body) String ¶ 

func (x *AddByPathRequest_Body) String() string

type AddByPathResponse ¶ 

type AddByPathResponse struct {

	// Response body.
	Body *AddByPathResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AddByPathResponse) Descriptor deprecated 

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

Deprecated: Use AddByPathResponse.ProtoReflect.Descriptor instead.

func (*AddByPathResponse) GetBody ¶ 

func (x *AddByPathResponse) GetBody() *AddByPathResponse_Body

func (*AddByPathResponse) GetSignature ¶ 

func (x *AddByPathResponse) GetSignature() *Signature

func (*AddByPathResponse) ProtoMessage ¶ 

func (*AddByPathResponse) ProtoMessage()

func (*AddByPathResponse) ProtoReflect ¶ 

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

func (*AddByPathResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*AddByPathResponse) Reset ¶ 

func (x *AddByPathResponse) Reset()

func (*AddByPathResponse) SetSignature ¶ 

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

func (*AddByPathResponse) SignedDataSize ¶ 

func (x *AddByPathResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*AddByPathResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddByPathResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddByPathResponse) String ¶ 

func (x *AddByPathResponse) String() string

type AddByPathResponse_Body ¶ 

type AddByPathResponse_Body struct {

	// List of all created nodes. The first one is the leaf.
	Nodes []uint64 `protobuf:"varint,1,rep,packed,name=nodes,proto3" json:"nodes,omitempty"`
	// ID of the parent node where new nodes were attached.
	ParentId uint64 `protobuf:"varint,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddByPathResponse_Body) Descriptor deprecated 

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

Deprecated: Use AddByPathResponse_Body.ProtoReflect.Descriptor instead.

func (*AddByPathResponse_Body) GetNodes ¶ 

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

func (*AddByPathResponse_Body) GetParentId ¶ 

func (x *AddByPathResponse_Body) GetParentId() uint64

func (*AddByPathResponse_Body) ProtoMessage ¶ 

func (*AddByPathResponse_Body) ProtoMessage()

func (*AddByPathResponse_Body) ProtoReflect ¶ 

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

func (*AddByPathResponse_Body) Reset ¶ 

func (x *AddByPathResponse_Body) Reset()

func (*AddByPathResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddByPathResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddByPathResponse_Body) String ¶ 

func (x *AddByPathResponse_Body) String() string

type AddRequest ¶ 

type AddRequest struct {

	// Request body.
	Body *AddRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRequest) Descriptor deprecated 

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

Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.

func (*AddRequest) GetBody ¶ 

func (x *AddRequest) GetBody() *AddRequest_Body

func (*AddRequest) GetSignature ¶ 

func (x *AddRequest) GetSignature() *Signature

func (*AddRequest) ProtoMessage ¶ 

func (*AddRequest) ProtoMessage()

func (*AddRequest) ProtoReflect ¶ 

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

func (*AddRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*AddRequest) Reset ¶ 

func (x *AddRequest) Reset()

func (*AddRequest) SetSignature ¶ 

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

func (*AddRequest) SignedDataSize ¶ 

func (x *AddRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*AddRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddRequest) String ¶ 

func (x *AddRequest) String() string

type AddRequest_Body ¶ 

type AddRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// ID of the parent to attach node to.
	ParentId uint64 `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// Key-Value pairs with meta information.
	Meta []*KeyValue `protobuf:"bytes,4,rep,name=meta,proto3" json:"meta,omitempty"`
	// Bearer token in V2 format.
	BearerToken []byte `protobuf:"bytes,5,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRequest_Body) Descriptor deprecated 

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

Deprecated: Use AddRequest_Body.ProtoReflect.Descriptor instead.

func (*AddRequest_Body) GetBearerToken ¶ 

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

func (*AddRequest_Body) GetContainerId ¶ 

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

func (*AddRequest_Body) GetMeta ¶ 

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

func (*AddRequest_Body) GetParentId ¶ 

func (x *AddRequest_Body) GetParentId() uint64

func (*AddRequest_Body) GetTreeId ¶ 

func (x *AddRequest_Body) GetTreeId() string

func (*AddRequest_Body) ProtoMessage ¶ 

func (*AddRequest_Body) ProtoMessage()

func (*AddRequest_Body) ProtoReflect ¶ 

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

func (*AddRequest_Body) Reset ¶ 

func (x *AddRequest_Body) Reset()

func (*AddRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddRequest_Body) String ¶ 

func (x *AddRequest_Body) String() string

type AddResponse ¶ 

type AddResponse struct {

	// Response body.
	Body *AddResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AddResponse) Descriptor deprecated 

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

Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.

func (*AddResponse) GetBody ¶ 

func (x *AddResponse) GetBody() *AddResponse_Body

func (*AddResponse) GetSignature ¶ 

func (x *AddResponse) GetSignature() *Signature

func (*AddResponse) ProtoMessage ¶ 

func (*AddResponse) ProtoMessage()

func (*AddResponse) ProtoReflect ¶ 

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

func (*AddResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*AddResponse) Reset ¶ 

func (x *AddResponse) Reset()

func (*AddResponse) SetSignature ¶ 

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

func (*AddResponse) SignedDataSize ¶ 

func (x *AddResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*AddResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddResponse) String ¶ 

func (x *AddResponse) String() string

type AddResponse_Body ¶ 

type AddResponse_Body struct {

	// ID of the created node.
	NodeId uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddResponse_Body) Descriptor deprecated 

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

Deprecated: Use AddResponse_Body.ProtoReflect.Descriptor instead.

func (*AddResponse_Body) GetNodeId ¶ 

func (x *AddResponse_Body) GetNodeId() uint64

func (*AddResponse_Body) ProtoMessage ¶ 

func (*AddResponse_Body) ProtoMessage()

func (*AddResponse_Body) ProtoReflect ¶ 

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

func (*AddResponse_Body) Reset ¶ 

func (x *AddResponse_Body) Reset()

func (*AddResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*AddResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*AddResponse_Body) String ¶ 

func (x *AddResponse_Body) String() string

type ApplyRequest ¶ 

type ApplyRequest struct {

	// Request body.
	Body *ApplyRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRequest) Descriptor deprecated 

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

Deprecated: Use ApplyRequest.ProtoReflect.Descriptor instead.

func (*ApplyRequest) GetBody ¶ 

func (x *ApplyRequest) GetBody() *ApplyRequest_Body

func (*ApplyRequest) GetSignature ¶ 

func (x *ApplyRequest) GetSignature() *Signature

func (*ApplyRequest) ProtoMessage ¶ 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) ProtoReflect ¶ 

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

func (*ApplyRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*ApplyRequest) Reset ¶ 

func (x *ApplyRequest) Reset()

func (*ApplyRequest) SetSignature ¶ 

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

func (*ApplyRequest) SignedDataSize ¶ 

func (x *ApplyRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*ApplyRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*ApplyRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*ApplyRequest) String ¶ 

func (x *ApplyRequest) String() string

type ApplyRequest_Body ¶ 

type ApplyRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// Operation to be applied.
	Operation *LogMove `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRequest_Body) Descriptor deprecated 

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

Deprecated: Use ApplyRequest_Body.ProtoReflect.Descriptor instead.

func (*ApplyRequest_Body) GetContainerId ¶ 

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

func (*ApplyRequest_Body) GetOperation ¶ 

func (x *ApplyRequest_Body) GetOperation() *LogMove

func (*ApplyRequest_Body) GetTreeId ¶ 

func (x *ApplyRequest_Body) GetTreeId() string

func (*ApplyRequest_Body) ProtoMessage ¶ 

func (*ApplyRequest_Body) ProtoMessage()

func (*ApplyRequest_Body) ProtoReflect ¶ 

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

func (*ApplyRequest_Body) Reset ¶ 

func (x *ApplyRequest_Body) Reset()

func (*ApplyRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*ApplyRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*ApplyRequest_Body) String ¶ 

func (x *ApplyRequest_Body) String() string

type ApplyResponse ¶ 

type ApplyResponse struct {

	// Response body.
	Body *ApplyResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResponse) Descriptor deprecated 

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

Deprecated: Use ApplyResponse.ProtoReflect.Descriptor instead.

func (*ApplyResponse) GetBody ¶ 

func (x *ApplyResponse) GetBody() *ApplyResponse_Body

func (*ApplyResponse) GetSignature ¶ 

func (x *ApplyResponse) GetSignature() *Signature

func (*ApplyResponse) ProtoMessage ¶ 

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) ProtoReflect ¶ 

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

func (*ApplyResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*ApplyResponse) Reset ¶ 

func (x *ApplyResponse) Reset()

func (*ApplyResponse) SetSignature ¶ 

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

func (*ApplyResponse) SignedDataSize ¶ 

func (x *ApplyResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*ApplyResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*ApplyResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*ApplyResponse) String ¶ 

func (x *ApplyResponse) String() string

type ApplyResponse_Body ¶ 

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

func (*ApplyResponse_Body) Descriptor deprecated 

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

Deprecated: Use ApplyResponse_Body.ProtoReflect.Descriptor instead.

func (*ApplyResponse_Body) ProtoMessage ¶ 

func (*ApplyResponse_Body) ProtoMessage()

func (*ApplyResponse_Body) ProtoReflect ¶ 

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

func (*ApplyResponse_Body) Reset ¶ 

func (x *ApplyResponse_Body) Reset()

func (*ApplyResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*ApplyResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*ApplyResponse_Body) String ¶ 

func (x *ApplyResponse_Body) String() string

type ContainerSource ¶ 

type ContainerSource interface {
	container.Source
	// List must return list of all the containers in the FrostFS network
	// at the moment of a call and any error that does not allow fetching
	// container information.
	List() ([]cid.ID, error)
}

type GetNodeByPathRequest ¶ 

type GetNodeByPathRequest struct {

	// Request body.
	Body *GetNodeByPathRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeByPathRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeByPathRequest.ProtoReflect.Descriptor instead.

func (*GetNodeByPathRequest) GetBody ¶ 

func (x *GetNodeByPathRequest) GetBody() *GetNodeByPathRequest_Body

func (*GetNodeByPathRequest) GetSignature ¶ 

func (x *GetNodeByPathRequest) GetSignature() *Signature

func (*GetNodeByPathRequest) ProtoMessage ¶ 

func (*GetNodeByPathRequest) ProtoMessage()

func (*GetNodeByPathRequest) ProtoReflect ¶ 

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

func (*GetNodeByPathRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*GetNodeByPathRequest) Reset ¶ 

func (x *GetNodeByPathRequest) Reset()

func (*GetNodeByPathRequest) SetSignature ¶ 

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

func (*GetNodeByPathRequest) SignedDataSize ¶ 

func (x *GetNodeByPathRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*GetNodeByPathRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetNodeByPathRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetNodeByPathRequest) String ¶ 

func (x *GetNodeByPathRequest) String() string

type GetNodeByPathRequest_Body ¶ 

type GetNodeByPathRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// Attribute to build path with. Default: "FileName".
	PathAttribute string `protobuf:"bytes,3,opt,name=path_attribute,json=pathAttribute,proto3" json:"path_attribute,omitempty"`
	// List of path components.
	Path []string `protobuf:"bytes,4,rep,name=path,proto3" json:"path,omitempty"`
	// List of attributes to include in response.
	Attributes []string `protobuf:"bytes,5,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// Flag to return only the latest version of node.
	LatestOnly bool `protobuf:"varint,6,opt,name=latest_only,json=latestOnly,proto3" json:"latest_only,omitempty"`
	// Flag to return all stored attributes.
	AllAttributes bool `protobuf:"varint,7,opt,name=all_attributes,json=allAttributes,proto3" json:"all_attributes,omitempty"`
	// Bearer token in V2 format.
	BearerToken []byte `protobuf:"bytes,8,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeByPathRequest_Body) Descriptor deprecated 

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

Deprecated: Use GetNodeByPathRequest_Body.ProtoReflect.Descriptor instead.

func (*GetNodeByPathRequest_Body) GetAllAttributes ¶ 

func (x *GetNodeByPathRequest_Body) GetAllAttributes() bool

func (*GetNodeByPathRequest_Body) GetAttributes ¶ 

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

func (*GetNodeByPathRequest_Body) GetBearerToken ¶ 

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

func (*GetNodeByPathRequest_Body) GetContainerId ¶ 

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

func (*GetNodeByPathRequest_Body) GetLatestOnly ¶ 

func (x *GetNodeByPathRequest_Body) GetLatestOnly() bool

func (*GetNodeByPathRequest_Body) GetPath ¶ 

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

func (*GetNodeByPathRequest_Body) GetPathAttribute ¶ 

func (x *GetNodeByPathRequest_Body) GetPathAttribute() string

func (*GetNodeByPathRequest_Body) GetTreeId ¶ 

func (x *GetNodeByPathRequest_Body) GetTreeId() string

func (*GetNodeByPathRequest_Body) ProtoMessage ¶ 

func (*GetNodeByPathRequest_Body) ProtoMessage()

func (*GetNodeByPathRequest_Body) ProtoReflect ¶ 

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

func (*GetNodeByPathRequest_Body) Reset ¶ 

func (x *GetNodeByPathRequest_Body) Reset()

func (*GetNodeByPathRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetNodeByPathRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetNodeByPathRequest_Body) String ¶ 

func (x *GetNodeByPathRequest_Body) String() string

type GetNodeByPathResponse ¶ 

type GetNodeByPathResponse struct {

	// Response body.
	Body *GetNodeByPathResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeByPathResponse) Descriptor deprecated 

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

Deprecated: Use GetNodeByPathResponse.ProtoReflect.Descriptor instead.

func (*GetNodeByPathResponse) GetBody ¶ 

func (x *GetNodeByPathResponse) GetBody() *GetNodeByPathResponse_Body

func (*GetNodeByPathResponse) GetSignature ¶ 

func (x *GetNodeByPathResponse) GetSignature() *Signature

func (*GetNodeByPathResponse) ProtoMessage ¶ 

func (*GetNodeByPathResponse) ProtoMessage()

func (*GetNodeByPathResponse) ProtoReflect ¶ 

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

func (*GetNodeByPathResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*GetNodeByPathResponse) Reset ¶ 

func (x *GetNodeByPathResponse) Reset()

func (*GetNodeByPathResponse) SetSignature ¶ 

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

func (*GetNodeByPathResponse) SignedDataSize ¶ 

func (x *GetNodeByPathResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*GetNodeByPathResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetNodeByPathResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetNodeByPathResponse) String ¶ 

func (x *GetNodeByPathResponse) String() string

type GetNodeByPathResponse_Body ¶ 

type GetNodeByPathResponse_Body struct {

	// List of nodes stored by path.
	Nodes []*GetNodeByPathResponse_Info `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeByPathResponse_Body) Descriptor deprecated 

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

Deprecated: Use GetNodeByPathResponse_Body.ProtoReflect.Descriptor instead.

func (*GetNodeByPathResponse_Body) GetNodes ¶ 

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

func (*GetNodeByPathResponse_Body) ProtoMessage ¶ 

func (*GetNodeByPathResponse_Body) ProtoMessage()

func (*GetNodeByPathResponse_Body) ProtoReflect ¶ 

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

func (*GetNodeByPathResponse_Body) Reset ¶ 

func (x *GetNodeByPathResponse_Body) Reset()

func (*GetNodeByPathResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetNodeByPathResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetNodeByPathResponse_Body) String ¶ 

func (x *GetNodeByPathResponse_Body) String() string

type GetNodeByPathResponse_Info ¶ 

type GetNodeByPathResponse_Info struct {

	// Node ID.
	NodeId uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Timestamp of the last operation with the node.
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Node meta-information.
	Meta []*KeyValue `protobuf:"bytes,3,rep,name=meta,proto3" json:"meta,omitempty"`
	// Parent ID.
	ParentId uint64 `protobuf:"varint,4,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// contains filtered or unexported fields
}

Information about a single tree node.

func (*GetNodeByPathResponse_Info) Descriptor deprecated 

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

Deprecated: Use GetNodeByPathResponse_Info.ProtoReflect.Descriptor instead.

func (*GetNodeByPathResponse_Info) GetMeta ¶ 

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

func (*GetNodeByPathResponse_Info) GetNodeId ¶ 

func (x *GetNodeByPathResponse_Info) GetNodeId() uint64

func (*GetNodeByPathResponse_Info) GetParentId ¶ 

func (x *GetNodeByPathResponse_Info) GetParentId() uint64

func (*GetNodeByPathResponse_Info) GetTimestamp ¶ 

func (x *GetNodeByPathResponse_Info) GetTimestamp() uint64

func (*GetNodeByPathResponse_Info) ProtoMessage ¶ 

func (*GetNodeByPathResponse_Info) ProtoMessage()

func (*GetNodeByPathResponse_Info) ProtoReflect ¶ 

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

func (*GetNodeByPathResponse_Info) Reset ¶ 

func (x *GetNodeByPathResponse_Info) Reset()

func (*GetNodeByPathResponse_Info) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetNodeByPathResponse_Info) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetNodeByPathResponse_Info) String ¶ 

func (x *GetNodeByPathResponse_Info) String() string

type GetOpLogRequest ¶ 

type GetOpLogRequest struct {

	// Request body.
	Body *GetOpLogRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOpLogRequest) Descriptor deprecated 

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

Deprecated: Use GetOpLogRequest.ProtoReflect.Descriptor instead.

func (*GetOpLogRequest) GetBody ¶ 

func (x *GetOpLogRequest) GetBody() *GetOpLogRequest_Body

func (*GetOpLogRequest) GetSignature ¶ 

func (x *GetOpLogRequest) GetSignature() *Signature

func (*GetOpLogRequest) ProtoMessage ¶ 

func (*GetOpLogRequest) ProtoMessage()

func (*GetOpLogRequest) ProtoReflect ¶ 

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

func (*GetOpLogRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*GetOpLogRequest) Reset ¶ 

func (x *GetOpLogRequest) Reset()

func (*GetOpLogRequest) SetSignature ¶ 

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

func (*GetOpLogRequest) SignedDataSize ¶ 

func (x *GetOpLogRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*GetOpLogRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetOpLogRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetOpLogRequest) String ¶ 

func (x *GetOpLogRequest) String() string

type GetOpLogRequest_Body ¶ 

type GetOpLogRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// Starting height to return logs from.
	Height uint64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	// Amount of operations to return.
	Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOpLogRequest_Body) Descriptor deprecated 

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

Deprecated: Use GetOpLogRequest_Body.ProtoReflect.Descriptor instead.

func (*GetOpLogRequest_Body) GetContainerId ¶ 

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

func (*GetOpLogRequest_Body) GetCount ¶ 

func (x *GetOpLogRequest_Body) GetCount() uint64

func (*GetOpLogRequest_Body) GetHeight ¶ 

func (x *GetOpLogRequest_Body) GetHeight() uint64

func (*GetOpLogRequest_Body) GetTreeId ¶ 

func (x *GetOpLogRequest_Body) GetTreeId() string

func (*GetOpLogRequest_Body) ProtoMessage ¶ 

func (*GetOpLogRequest_Body) ProtoMessage()

func (*GetOpLogRequest_Body) ProtoReflect ¶ 

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

func (*GetOpLogRequest_Body) Reset ¶ 

func (x *GetOpLogRequest_Body) Reset()

func (*GetOpLogRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetOpLogRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetOpLogRequest_Body) String ¶ 

func (x *GetOpLogRequest_Body) String() string

type GetOpLogResponse ¶ 

type GetOpLogResponse struct {

	// Response body.
	Body *GetOpLogResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOpLogResponse) Descriptor deprecated 

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

Deprecated: Use GetOpLogResponse.ProtoReflect.Descriptor instead.

func (*GetOpLogResponse) GetBody ¶ 

func (x *GetOpLogResponse) GetBody() *GetOpLogResponse_Body

func (*GetOpLogResponse) GetSignature ¶ 

func (x *GetOpLogResponse) GetSignature() *Signature

func (*GetOpLogResponse) ProtoMessage ¶ 

func (*GetOpLogResponse) ProtoMessage()

func (*GetOpLogResponse) ProtoReflect ¶ 

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

func (*GetOpLogResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*GetOpLogResponse) Reset ¶ 

func (x *GetOpLogResponse) Reset()

func (*GetOpLogResponse) SetSignature ¶ 

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

func (*GetOpLogResponse) SignedDataSize ¶ 

func (x *GetOpLogResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*GetOpLogResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetOpLogResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetOpLogResponse) String ¶ 

func (x *GetOpLogResponse) String() string

type GetOpLogResponse_Body ¶ 

type GetOpLogResponse_Body struct {

	// Operation on a tree.
	Operation *LogMove `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOpLogResponse_Body) Descriptor deprecated 

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

Deprecated: Use GetOpLogResponse_Body.ProtoReflect.Descriptor instead.

func (*GetOpLogResponse_Body) GetOperation ¶ 

func (x *GetOpLogResponse_Body) GetOperation() *LogMove

func (*GetOpLogResponse_Body) ProtoMessage ¶ 

func (*GetOpLogResponse_Body) ProtoMessage()

func (*GetOpLogResponse_Body) ProtoReflect ¶ 

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

func (*GetOpLogResponse_Body) Reset ¶ 

func (x *GetOpLogResponse_Body) Reset()

func (*GetOpLogResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetOpLogResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetOpLogResponse_Body) String ¶ 

func (x *GetOpLogResponse_Body) String() string

type GetSubTreeRequest ¶ 

type GetSubTreeRequest struct {

	// Request body.
	Body *GetSubTreeRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubTreeRequest) Descriptor deprecated 

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

Deprecated: Use GetSubTreeRequest.ProtoReflect.Descriptor instead.

func (*GetSubTreeRequest) GetBody ¶ 

func (x *GetSubTreeRequest) GetBody() *GetSubTreeRequest_Body

func (*GetSubTreeRequest) GetSignature ¶ 

func (x *GetSubTreeRequest) GetSignature() *Signature

func (*GetSubTreeRequest) ProtoMessage ¶ 

func (*GetSubTreeRequest) ProtoMessage()

func (*GetSubTreeRequest) ProtoReflect ¶ 

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

func (*GetSubTreeRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*GetSubTreeRequest) Reset ¶ 

func (x *GetSubTreeRequest) Reset()

func (*GetSubTreeRequest) SetSignature ¶ 

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

func (*GetSubTreeRequest) SignedDataSize ¶ 

func (x *GetSubTreeRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*GetSubTreeRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetSubTreeRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetSubTreeRequest) String ¶ 

func (x *GetSubTreeRequest) String() string

type GetSubTreeRequest_Body ¶ 

type GetSubTreeRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// ID of the root node of a subtree.
	RootId uint64 `protobuf:"varint,3,opt,name=root_id,json=rootId,proto3" json:"root_id,omitempty"`
	// Optional depth of the traversal. Zero means return only root.
	// Maximum depth is 10.
	Depth uint32 `protobuf:"varint,4,opt,name=depth,proto3" json:"depth,omitempty"`
	// Bearer token in V2 format.
	BearerToken []byte `protobuf:"bytes,5,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubTreeRequest_Body) Descriptor deprecated 

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

Deprecated: Use GetSubTreeRequest_Body.ProtoReflect.Descriptor instead.

func (*GetSubTreeRequest_Body) GetBearerToken ¶ 

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

func (*GetSubTreeRequest_Body) GetContainerId ¶ 

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

func (*GetSubTreeRequest_Body) GetDepth ¶ 

func (x *GetSubTreeRequest_Body) GetDepth() uint32

func (*GetSubTreeRequest_Body) GetRootId ¶ 

func (x *GetSubTreeRequest_Body) GetRootId() uint64

func (*GetSubTreeRequest_Body) GetTreeId ¶ 

func (x *GetSubTreeRequest_Body) GetTreeId() string

func (*GetSubTreeRequest_Body) ProtoMessage ¶ 

func (*GetSubTreeRequest_Body) ProtoMessage()

func (*GetSubTreeRequest_Body) ProtoReflect ¶ 

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

func (*GetSubTreeRequest_Body) Reset ¶ 

func (x *GetSubTreeRequest_Body) Reset()

func (*GetSubTreeRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetSubTreeRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetSubTreeRequest_Body) String ¶ 

func (x *GetSubTreeRequest_Body) String() string

type GetSubTreeResponse ¶ 

type GetSubTreeResponse struct {

	// Response body.
	Body *GetSubTreeResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubTreeResponse) Descriptor deprecated 

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

Deprecated: Use GetSubTreeResponse.ProtoReflect.Descriptor instead.

func (*GetSubTreeResponse) GetBody ¶ 

func (x *GetSubTreeResponse) GetBody() *GetSubTreeResponse_Body

func (*GetSubTreeResponse) GetSignature ¶ 

func (x *GetSubTreeResponse) GetSignature() *Signature

func (*GetSubTreeResponse) ProtoMessage ¶ 

func (*GetSubTreeResponse) ProtoMessage()

func (*GetSubTreeResponse) ProtoReflect ¶ 

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

func (*GetSubTreeResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*GetSubTreeResponse) Reset ¶ 

func (x *GetSubTreeResponse) Reset()

func (*GetSubTreeResponse) SetSignature ¶ 

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

func (*GetSubTreeResponse) SignedDataSize ¶ 

func (x *GetSubTreeResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*GetSubTreeResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetSubTreeResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetSubTreeResponse) String ¶ 

func (x *GetSubTreeResponse) String() string

type GetSubTreeResponse_Body ¶ 

type GetSubTreeResponse_Body struct {

	// ID of the node.
	NodeId uint64 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// ID of the parent.
	ParentId uint64 `protobuf:"varint,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// Time node was first added to a tree.
	Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Node meta-information.
	Meta []*KeyValue `protobuf:"bytes,4,rep,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubTreeResponse_Body) Descriptor deprecated 

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

Deprecated: Use GetSubTreeResponse_Body.ProtoReflect.Descriptor instead.

func (*GetSubTreeResponse_Body) GetMeta ¶ 

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

func (*GetSubTreeResponse_Body) GetNodeId ¶ 

func (x *GetSubTreeResponse_Body) GetNodeId() uint64

func (*GetSubTreeResponse_Body) GetParentId ¶ 

func (x *GetSubTreeResponse_Body) GetParentId() uint64

func (*GetSubTreeResponse_Body) GetTimestamp ¶ 

func (x *GetSubTreeResponse_Body) GetTimestamp() uint64

func (*GetSubTreeResponse_Body) ProtoMessage ¶ 

func (*GetSubTreeResponse_Body) ProtoMessage()

func (*GetSubTreeResponse_Body) ProtoReflect ¶ 

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

func (*GetSubTreeResponse_Body) Reset ¶ 

func (x *GetSubTreeResponse_Body) Reset()

func (*GetSubTreeResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*GetSubTreeResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*GetSubTreeResponse_Body) String ¶ 

func (x *GetSubTreeResponse_Body) String() string

type HealthcheckRequest ¶ 

type HealthcheckRequest struct {

	// Request body.
	Body *HealthcheckRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthcheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthcheckRequest.ProtoReflect.Descriptor instead.

func (*HealthcheckRequest) GetBody ¶ 

func (x *HealthcheckRequest) GetBody() *HealthcheckRequest_Body

func (*HealthcheckRequest) GetSignature ¶ 

func (x *HealthcheckRequest) GetSignature() *Signature

func (*HealthcheckRequest) ProtoMessage ¶ 

func (*HealthcheckRequest) ProtoMessage()

func (*HealthcheckRequest) ProtoReflect ¶ 

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

func (*HealthcheckRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*HealthcheckRequest) Reset ¶ 

func (x *HealthcheckRequest) Reset()

func (*HealthcheckRequest) SetSignature ¶ 

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

func (*HealthcheckRequest) SignedDataSize ¶ 

func (x *HealthcheckRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*HealthcheckRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*HealthcheckRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthcheckRequest) String ¶ 

func (x *HealthcheckRequest) String() string

type HealthcheckRequest_Body ¶ 

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

func (*HealthcheckRequest_Body) Descriptor deprecated 

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

Deprecated: Use HealthcheckRequest_Body.ProtoReflect.Descriptor instead.

func (*HealthcheckRequest_Body) ProtoMessage ¶ 

func (*HealthcheckRequest_Body) ProtoMessage()

func (*HealthcheckRequest_Body) ProtoReflect ¶ 

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

func (*HealthcheckRequest_Body) Reset ¶ 

func (x *HealthcheckRequest_Body) Reset()

func (*HealthcheckRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*HealthcheckRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthcheckRequest_Body) String ¶ 

func (x *HealthcheckRequest_Body) String() string

type HealthcheckResponse ¶ 

type HealthcheckResponse struct {

	// Response body.
	Body *HealthcheckResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthcheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthcheckResponse.ProtoReflect.Descriptor instead.

func (*HealthcheckResponse) GetBody ¶ 

func (x *HealthcheckResponse) GetBody() *HealthcheckResponse_Body

func (*HealthcheckResponse) GetSignature ¶ 

func (x *HealthcheckResponse) GetSignature() *Signature

func (*HealthcheckResponse) ProtoMessage ¶ 

func (*HealthcheckResponse) ProtoMessage()

func (*HealthcheckResponse) ProtoReflect ¶ 

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

func (*HealthcheckResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*HealthcheckResponse) Reset ¶ 

func (x *HealthcheckResponse) Reset()

func (*HealthcheckResponse) SetSignature ¶ 

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

func (*HealthcheckResponse) SignedDataSize ¶ 

func (x *HealthcheckResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*HealthcheckResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*HealthcheckResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthcheckResponse) String ¶ 

func (x *HealthcheckResponse) String() string

type HealthcheckResponse_Body ¶ 

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

func (*HealthcheckResponse_Body) Descriptor deprecated 

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

Deprecated: Use HealthcheckResponse_Body.ProtoReflect.Descriptor instead.

func (*HealthcheckResponse_Body) ProtoMessage ¶ 

func (*HealthcheckResponse_Body) ProtoMessage()

func (*HealthcheckResponse_Body) ProtoReflect ¶ 

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

func (*HealthcheckResponse_Body) Reset ¶ 

func (x *HealthcheckResponse_Body) Reset()

func (*HealthcheckResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*HealthcheckResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthcheckResponse_Body) String ¶ 

func (x *HealthcheckResponse_Body) String() string

type KeyValue ¶ 

type KeyValue struct {

	// Attribute name.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Attribute value.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

KeyValue represents key-value pair attached to an object.

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey ¶ 

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue ¶ 

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

func (*KeyValue) ProtoMessage ¶ 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect ¶ 

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

func (*KeyValue) Reset ¶ 

func (x *KeyValue) Reset()

func (*KeyValue) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*KeyValue) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*KeyValue) String ¶ 

func (x *KeyValue) String() string

type LogMove ¶ 

type LogMove struct {

	// ID of the parent node.
	ParentId uint64 `protobuf:"varint,1,opt,name=parent_id,json=parentID,proto3" json:"parent_id,omitempty"`
	// Node meta information, including operation timestamp.
	Meta []byte `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// ID of the node to move.
	ChildId uint64 `protobuf:"varint,3,opt,name=child_id,json=childID,proto3" json:"child_id,omitempty"`
	// contains filtered or unexported fields
}

LogMove represents log-entry for a single move operation.

func (*LogMove) Descriptor deprecated 

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

Deprecated: Use LogMove.ProtoReflect.Descriptor instead.

func (*LogMove) GetChildId ¶ 

func (x *LogMove) GetChildId() uint64

func (*LogMove) GetMeta ¶ 

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

func (*LogMove) GetParentId ¶ 

func (x *LogMove) GetParentId() uint64

func (*LogMove) ProtoMessage ¶ 

func (*LogMove) ProtoMessage()

func (*LogMove) ProtoReflect ¶ 

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

func (*LogMove) Reset ¶ 

func (x *LogMove) Reset()

func (*LogMove) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*LogMove) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*LogMove) String ¶ 

func (x *LogMove) String() string

type MoveRequest ¶ 

type MoveRequest struct {

	// Request body.
	Body *MoveRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveRequest) Descriptor deprecated 

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

Deprecated: Use MoveRequest.ProtoReflect.Descriptor instead.

func (*MoveRequest) GetBody ¶ 

func (x *MoveRequest) GetBody() *MoveRequest_Body

func (*MoveRequest) GetSignature ¶ 

func (x *MoveRequest) GetSignature() *Signature

func (*MoveRequest) ProtoMessage ¶ 

func (*MoveRequest) ProtoMessage()

func (*MoveRequest) ProtoReflect ¶ 

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

func (*MoveRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*MoveRequest) Reset ¶ 

func (x *MoveRequest) Reset()

func (*MoveRequest) SetSignature ¶ 

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

func (*MoveRequest) SignedDataSize ¶ 

func (x *MoveRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*MoveRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*MoveRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*MoveRequest) String ¶ 

func (x *MoveRequest) String() string

type MoveRequest_Body ¶ 

type MoveRequest_Body struct {

	// TODO import neo.fs.v2.refs.ContainerID directly.
	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// ID of the new parent.
	ParentId uint64 `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// ID of the node to move.
	NodeId uint64 `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Node meta-information.
	Meta []*KeyValue `protobuf:"bytes,5,rep,name=meta,proto3" json:"meta,omitempty"`
	// Bearer token in V2 format.
	BearerToken []byte `protobuf:"bytes,6,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveRequest_Body) Descriptor deprecated 

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

Deprecated: Use MoveRequest_Body.ProtoReflect.Descriptor instead.

func (*MoveRequest_Body) GetBearerToken ¶ 

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

func (*MoveRequest_Body) GetContainerId ¶ 

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

func (*MoveRequest_Body) GetMeta ¶ 

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

func (*MoveRequest_Body) GetNodeId ¶ 

func (x *MoveRequest_Body) GetNodeId() uint64

func (*MoveRequest_Body) GetParentId ¶ 

func (x *MoveRequest_Body) GetParentId() uint64

func (*MoveRequest_Body) GetTreeId ¶ 

func (x *MoveRequest_Body) GetTreeId() string

func (*MoveRequest_Body) ProtoMessage ¶ 

func (*MoveRequest_Body) ProtoMessage()

func (*MoveRequest_Body) ProtoReflect ¶ 

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

func (*MoveRequest_Body) Reset ¶ 

func (x *MoveRequest_Body) Reset()

func (*MoveRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*MoveRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*MoveRequest_Body) String ¶ 

func (x *MoveRequest_Body) String() string

type MoveResponse ¶ 

type MoveResponse struct {

	// Response body.
	Body *MoveResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveResponse) Descriptor deprecated 

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

Deprecated: Use MoveResponse.ProtoReflect.Descriptor instead.

func (*MoveResponse) GetBody ¶ 

func (x *MoveResponse) GetBody() *MoveResponse_Body

func (*MoveResponse) GetSignature ¶ 

func (x *MoveResponse) GetSignature() *Signature

func (*MoveResponse) ProtoMessage ¶ 

func (*MoveResponse) ProtoMessage()

func (*MoveResponse) ProtoReflect ¶ 

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

func (*MoveResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*MoveResponse) Reset ¶ 

func (x *MoveResponse) Reset()

func (*MoveResponse) SetSignature ¶ 

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

func (*MoveResponse) SignedDataSize ¶ 

func (x *MoveResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*MoveResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*MoveResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*MoveResponse) String ¶ 

func (x *MoveResponse) String() string

type MoveResponse_Body ¶ 

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

func (*MoveResponse_Body) Descriptor deprecated 

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

Deprecated: Use MoveResponse_Body.ProtoReflect.Descriptor instead.

func (*MoveResponse_Body) ProtoMessage ¶ 

func (*MoveResponse_Body) ProtoMessage()

func (*MoveResponse_Body) ProtoReflect ¶ 

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

func (*MoveResponse_Body) Reset ¶ 

func (x *MoveResponse_Body) Reset()

func (*MoveResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*MoveResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*MoveResponse_Body) String ¶ 

func (x *MoveResponse_Body) String() string

type Option ¶ 

type Option func(*cfg)

Option represents configuration option for a tree service.

func WithContainerCacheSize ¶ 

func WithContainerCacheSize(n int) Option

func WithContainerSource ¶ 

func WithContainerSource(src ContainerSource) Option

WithContainerSource sets a container source for a tree service. This option is required.

func WithEACLSource ¶ 

func WithEACLSource(src container.EACLSource) Option

WithEACLSource sets a eACL table source for a tree service. This option is required.

func WithLogger ¶ 

func WithLogger(log *logger.Logger) Option

WithLogger sets logger for a tree service.

func WithNetmapSource ¶ 

func WithNetmapSource(src netmap.Source) Option

WithNetmapSource sets a netmap source for a tree service. This option is required.

func WithPrivateKey ¶ 

func WithPrivateKey(key *ecdsa.PrivateKey) Option

WithPrivateKey sets a netmap source for a tree service. This option is required.

func WithReplicationChannelCapacity ¶ 

func WithReplicationChannelCapacity(n int) Option

func WithReplicationTimeout ¶ 

func WithReplicationTimeout(t time.Duration) Option

func WithReplicationWorkerCount ¶ 

func WithReplicationWorkerCount(n int) Option

func WithStorage ¶ 

func WithStorage(s pilorama.Forest) Option

WithStorage sets tree storage for a service.

type RemoveRequest ¶ 

type RemoveRequest struct {

	// Request body.
	Body *RemoveRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetBody ¶ 

func (x *RemoveRequest) GetBody() *RemoveRequest_Body

func (*RemoveRequest) GetSignature ¶ 

func (x *RemoveRequest) GetSignature() *Signature

func (*RemoveRequest) ProtoMessage ¶ 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect ¶ 

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

func (*RemoveRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*RemoveRequest) Reset ¶ 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) SetSignature ¶ 

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

func (*RemoveRequest) SignedDataSize ¶ 

func (x *RemoveRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*RemoveRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*RemoveRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveRequest) String ¶ 

func (x *RemoveRequest) String() string

type RemoveRequest_Body ¶ 

type RemoveRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// The name of the tree.
	TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	// ID of the node to remove.
	NodeId uint64 `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Bearer token in V2 format.
	BearerToken []byte `protobuf:"bytes,4,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest_Body) Descriptor deprecated 

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

Deprecated: Use RemoveRequest_Body.ProtoReflect.Descriptor instead.

func (*RemoveRequest_Body) GetBearerToken ¶ 

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

func (*RemoveRequest_Body) GetContainerId ¶ 

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

func (*RemoveRequest_Body) GetNodeId ¶ 

func (x *RemoveRequest_Body) GetNodeId() uint64

func (*RemoveRequest_Body) GetTreeId ¶ 

func (x *RemoveRequest_Body) GetTreeId() string

func (*RemoveRequest_Body) ProtoMessage ¶ 

func (*RemoveRequest_Body) ProtoMessage()

func (*RemoveRequest_Body) ProtoReflect ¶ 

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

func (*RemoveRequest_Body) Reset ¶ 

func (x *RemoveRequest_Body) Reset()

func (*RemoveRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*RemoveRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveRequest_Body) String ¶ 

func (x *RemoveRequest_Body) String() string

type RemoveResponse ¶ 

type RemoveResponse struct {

	// Response body.
	Body *RemoveResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Response signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveResponse) Descriptor deprecated 

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

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) GetBody ¶ 

func (x *RemoveResponse) GetBody() *RemoveResponse_Body

func (*RemoveResponse) GetSignature ¶ 

func (x *RemoveResponse) GetSignature() *Signature

func (*RemoveResponse) ProtoMessage ¶ 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect ¶ 

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

func (*RemoveResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*RemoveResponse) Reset ¶ 

func (x *RemoveResponse) Reset()

func (*RemoveResponse) SetSignature ¶ 

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

func (*RemoveResponse) SignedDataSize ¶ 

func (x *RemoveResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*RemoveResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*RemoveResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveResponse) String ¶ 

func (x *RemoveResponse) String() string

type RemoveResponse_Body ¶ 

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

func (*RemoveResponse_Body) Descriptor deprecated 

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

Deprecated: Use RemoveResponse_Body.ProtoReflect.Descriptor instead.

func (*RemoveResponse_Body) ProtoMessage ¶ 

func (*RemoveResponse_Body) ProtoMessage()

func (*RemoveResponse_Body) ProtoReflect ¶ 

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

func (*RemoveResponse_Body) Reset ¶ 

func (x *RemoveResponse_Body) Reset()

func (*RemoveResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*RemoveResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveResponse_Body) String ¶ 

func (x *RemoveResponse_Body) String() string

type Service ¶ 

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

Service represents tree-service capable of working with multiple instances of CRDT trees.

func New ¶ 

func New(opts ...Option) *Service

New creates new tree service instance.

func (*Service) Add ¶ 

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

func (*Service) AddByPath ¶ 

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

func (*Service) Apply ¶ 

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

Apply locally applies operation from the remote node to the tree.

func (*Service) DropTree ¶ 

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

DropTree drops a tree from the database. If treeID is empty, all the trees are dropped.

func (*Service) GetNodeByPath ¶ 

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

func (*Service) GetOpLog ¶ 

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

func (*Service) GetSubTree ¶ 

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

func (*Service) Healthcheck ¶ 

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

func (*Service) Move ¶ 

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

Move applies client operation to the specified tree and pushes in queue for replication on other nodes.

func (*Service) Remove ¶ 

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

func (*Service) Shutdown ¶ 

func (s *Service) Shutdown()

Shutdown shutdowns the service.

func (*Service) Start ¶ 

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

Start starts the service.

func (*Service) SynchronizeAll ¶ 

func (s *Service) SynchronizeAll() error

SynchronizeAll forces tree service to synchronize all the trees according to netmap information. Must not be called before Service.Start. Returns ErrAlreadySyncing if synchronization has been started and blocked by another routine. Note: non-blocking operation.

func (*Service) SynchronizeTree ¶ 

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

SynchronizeTree tries to synchronize log starting from the last stored height.

func (*Service) TreeList ¶ 

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

type Signature ¶ 

type Signature struct {

	// Serialized public key as defined in NeoFS API.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Signature of a message body.
	Sign []byte `protobuf:"bytes,2,opt,name=sign,json=signature,proto3" json:"sign,omitempty"`
	// contains filtered or unexported fields
}

Signature of a message.

func (*Signature) Descriptor deprecated 

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

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetKey ¶ 

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

func (*Signature) GetSign ¶ 

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

func (*Signature) ProtoMessage ¶ 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect ¶ 

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

func (*Signature) Reset ¶ 

func (x *Signature) Reset()

func (*Signature) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*Signature) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*Signature) String ¶ 

func (x *Signature) String() string

type TreeListRequest ¶ 

type TreeListRequest struct {

	// Request body.
	Body *TreeListRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// Request signature.
	Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeListRequest) Descriptor deprecated 

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

Deprecated: Use TreeListRequest.ProtoReflect.Descriptor instead.

func (*TreeListRequest) GetBody ¶ 

func (x *TreeListRequest) GetBody() *TreeListRequest_Body

func (*TreeListRequest) GetSignature ¶ 

func (x *TreeListRequest) GetSignature() *Signature

func (*TreeListRequest) ProtoMessage ¶ 

func (*TreeListRequest) ProtoMessage()

func (*TreeListRequest) ProtoReflect ¶ 

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

func (*TreeListRequest) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*TreeListRequest) Reset ¶ 

func (x *TreeListRequest) Reset()

func (*TreeListRequest) SetSignature ¶ 

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

func (*TreeListRequest) SignedDataSize ¶ 

func (x *TreeListRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*TreeListRequest) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*TreeListRequest) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TreeListRequest) String ¶ 

func (x *TreeListRequest) String() string

type TreeListRequest_Body ¶ 

type TreeListRequest_Body struct {

	// Container ID in V2 format.
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeListRequest_Body) Descriptor deprecated 

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

Deprecated: Use TreeListRequest_Body.ProtoReflect.Descriptor instead.

func (*TreeListRequest_Body) GetContainerId ¶ 

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

func (*TreeListRequest_Body) ProtoMessage ¶ 

func (*TreeListRequest_Body) ProtoMessage()

func (*TreeListRequest_Body) ProtoReflect ¶ 

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

func (*TreeListRequest_Body) Reset ¶ 

func (x *TreeListRequest_Body) Reset()

func (*TreeListRequest_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*TreeListRequest_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TreeListRequest_Body) String ¶ 

func (x *TreeListRequest_Body) String() string

type TreeListResponse ¶ 

type TreeListResponse struct {

	// Response body.
	Body      *TreeListResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Signature *Signature             `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeListResponse) Descriptor deprecated 

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

Deprecated: Use TreeListResponse.ProtoReflect.Descriptor instead.

func (*TreeListResponse) GetBody ¶ 

func (x *TreeListResponse) GetBody() *TreeListResponse_Body

func (*TreeListResponse) GetSignature ¶ 

func (x *TreeListResponse) GetSignature() *Signature

func (*TreeListResponse) ProtoMessage ¶ 

func (*TreeListResponse) ProtoMessage()

func (*TreeListResponse) ProtoReflect ¶ 

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

func (*TreeListResponse) ReadSignedData ¶ 

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

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*TreeListResponse) Reset ¶ 

func (x *TreeListResponse) Reset()

func (*TreeListResponse) SetSignature ¶ 

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

func (*TreeListResponse) SignedDataSize ¶ 

func (x *TreeListResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*TreeListResponse) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*TreeListResponse) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TreeListResponse) String ¶ 

func (x *TreeListResponse) String() string

type TreeListResponse_Body ¶ 

type TreeListResponse_Body struct {

	// Tree IDs.
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeListResponse_Body) Descriptor deprecated 

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

Deprecated: Use TreeListResponse_Body.ProtoReflect.Descriptor instead.

func (*TreeListResponse_Body) GetIds ¶ 

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

func (*TreeListResponse_Body) ProtoMessage ¶ 

func (*TreeListResponse_Body) ProtoMessage()

func (*TreeListResponse_Body) ProtoReflect ¶ 

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

func (*TreeListResponse_Body) Reset ¶ 

func (x *TreeListResponse_Body) Reset()

func (*TreeListResponse_Body) StableMarshal ¶ 

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

StableMarshal marshals x in protobuf binary format with stable field order.

If buffer length is less than x.StableSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same binary format.

func (*TreeListResponse_Body) StableSize ¶ 

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

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TreeListResponse_Body) String ¶ 

func (x *TreeListResponse_Body) String() string

type TreeServiceClient ¶ 

type TreeServiceClient interface {
	// Add adds new node to the tree. Invoked by a client.
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	// AddByPath adds new node to the tree by path. Invoked by a client.
	AddByPath(ctx context.Context, in *AddByPathRequest, opts ...grpc.CallOption) (*AddByPathResponse, error)
	// Remove removes node from the tree. Invoked by a client.
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	// Move moves node from one parent to another. Invoked by a client.
	Move(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*MoveResponse, error)
	// GetNodeByPath returns list of IDs corresponding to a specific filepath.
	GetNodeByPath(ctx context.Context, in *GetNodeByPathRequest, opts ...grpc.CallOption) (*GetNodeByPathResponse, error)
	// GetSubTree returns tree corresponding to a specific node.
	GetSubTree(ctx context.Context, in *GetSubTreeRequest, opts ...grpc.CallOption) (TreeService_GetSubTreeClient, error)
	// TreeList return list of the existing trees in the container.
	TreeList(ctx context.Context, in *TreeListRequest, opts ...grpc.CallOption) (*TreeListResponse, error)
	// Apply pushes log operation from another node to the current.
	// The request must be signed by a container node.
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	// GetOpLog returns a stream of logged operations starting from some height.
	GetOpLog(ctx context.Context, in *GetOpLogRequest, opts ...grpc.CallOption) (TreeService_GetOpLogClient, error)
	// Healthcheck is a dummy rpc to check service availability
	Healthcheck(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error)
}

TreeServiceClient is the client API for TreeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTreeServiceClient ¶ 

func NewTreeServiceClient(cc grpc.ClientConnInterface) TreeServiceClient

type TreeServiceServer ¶ 

type TreeServiceServer interface {
	// Add adds new node to the tree. Invoked by a client.
	Add(context.Context, *AddRequest) (*AddResponse, error)
	// AddByPath adds new node to the tree by path. Invoked by a client.
	AddByPath(context.Context, *AddByPathRequest) (*AddByPathResponse, error)
	// Remove removes node from the tree. Invoked by a client.
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	// Move moves node from one parent to another. Invoked by a client.
	Move(context.Context, *MoveRequest) (*MoveResponse, error)
	// GetNodeByPath returns list of IDs corresponding to a specific filepath.
	GetNodeByPath(context.Context, *GetNodeByPathRequest) (*GetNodeByPathResponse, error)
	// GetSubTree returns tree corresponding to a specific node.
	GetSubTree(*GetSubTreeRequest, TreeService_GetSubTreeServer) error
	// TreeList return list of the existing trees in the container.
	TreeList(context.Context, *TreeListRequest) (*TreeListResponse, error)
	// Apply pushes log operation from another node to the current.
	// The request must be signed by a container node.
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	// GetOpLog returns a stream of logged operations starting from some height.
	GetOpLog(*GetOpLogRequest, TreeService_GetOpLogServer) error
	// Healthcheck is a dummy rpc to check service availability
	Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)
}

TreeServiceServer is the server API for TreeService service. All implementations should embed UnimplementedTreeServiceServer for forward compatibility

type TreeService_GetOpLogClient ¶ 

type TreeService_GetOpLogClient interface {
	Recv() (*GetOpLogResponse, error)
	grpc.ClientStream
}

type TreeService_GetOpLogServer ¶ 

type TreeService_GetOpLogServer interface {
	Send(*GetOpLogResponse) error
	grpc.ServerStream
}

type TreeService_GetSubTreeClient ¶ 

type TreeService_GetSubTreeClient interface {
	Recv() (*GetSubTreeResponse, error)
	grpc.ClientStream
}

type TreeService_GetSubTreeServer ¶ 

type TreeService_GetSubTreeServer interface {
	Send(*GetSubTreeResponse) error
	grpc.ServerStream
}

type UnimplementedTreeServiceServer ¶ 

type UnimplementedTreeServiceServer struct {
}

UnimplementedTreeServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTreeServiceServer) Add ¶ 

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

func (UnimplementedTreeServiceServer) AddByPath ¶ 

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

func (UnimplementedTreeServiceServer) Apply ¶ 

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

func (UnimplementedTreeServiceServer) GetNodeByPath ¶ 

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

func (UnimplementedTreeServiceServer) GetOpLog ¶ 

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

func (UnimplementedTreeServiceServer) GetSubTree ¶ 

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

func (UnimplementedTreeServiceServer) Healthcheck ¶ 

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

func (UnimplementedTreeServiceServer) Move ¶ 

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

func (UnimplementedTreeServiceServer) Remove ¶ 

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

func (UnimplementedTreeServiceServer) TreeList ¶ 

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

type UnsafeTreeServiceServer ¶ 

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

UnsafeTreeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TreeServiceServer 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.