tree

package
v0.30.2 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2022 License: GPL-3.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const MaxGetSubTreeDepth = 10

MaxGetSubTreeDepth represents maximum allowed traversal depth in GetSubTree RPC.

Variables

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: "Apply",
			Handler:    _TreeService_Apply_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)

Types

type AddByPathRequest 

type AddByPathRequest struct {
	Body      *AddByPathRequest_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 (*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 {
	ContainerId   []byte      `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId        string      `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	PathAttribute string      `protobuf:"bytes,3,opt,name=path_attribute,json=pathAttribute,proto3" json:"path_attribute,omitempty"`
	Path          []string    `protobuf:"bytes,4,rep,name=path,proto3" json:"path,omitempty"`
	Meta          []*KeyValue `protobuf:"bytes,5,rep,name=meta,proto3" json:"meta,omitempty"`
	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 {
	Body      *AddByPathResponse_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 (*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 {
	Nodes    []uint64 `protobuf:"varint,1,rep,packed,name=nodes,proto3" json:"nodes,omitempty"`
	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 {
	Body      *AddRequest_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 (*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 {
	ContainerId []byte      `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId      string      `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	ParentId    uint64      `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Meta        []*KeyValue `protobuf:"bytes,4,rep,name=meta,proto3" json:"meta,omitempty"`
	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 {
	Body      *AddResponse_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 (*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 {
	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 {
	Body      *ApplyRequest_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 (*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 {
	ContainerId []byte   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId      string   `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	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 {
	Body      *ApplyResponse_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 (*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 GetNodeByPathRequest 

type GetNodeByPathRequest struct {
	Body      *GetNodeByPathRequest_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 (*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 {
	ContainerId   []byte   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId        string   `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	PathAttribute string   `protobuf:"bytes,3,opt,name=path_attribute,json=pathAttribute,proto3" json:"path_attribute,omitempty"`
	Path          []string `protobuf:"bytes,4,rep,name=path,proto3" json:"path,omitempty"`
	Attributes    []string `protobuf:"bytes,5,rep,name=attributes,proto3" json:"attributes,omitempty"`
	LatestOnly    bool     `protobuf:"varint,6,opt,name=latest_only,json=latestOnly,proto3" json:"latest_only,omitempty"`
	AllAttributes bool     `protobuf:"varint,7,opt,name=all_attributes,json=allAttributes,proto3" json:"all_attributes,omitempty"`
	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 {
	Body      *GetNodeByPathResponse_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 (*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 {
	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 {
	NodeId    uint64      `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Timestamp uint64      `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Meta      []*KeyValue `protobuf:"bytes,3,rep,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

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) 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 {
	Body      *GetOpLogRequest_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 (*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 {
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId      string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	Height      uint64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	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 {
	Body      *GetOpLogResponse_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 (*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 *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 {
	Body      *GetSubTreeRequest_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 (*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 {
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId      string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	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"`
	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 {
	Body      *GetSubTreeResponse_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 (*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 {
	NodeId    uint64      `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ParentId  uint64      `protobuf:"varint,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Timestamp uint64      `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	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 KeyValue 

type KeyValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	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 {
	Body      *MoveRequest_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 (*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.
	ContainerId []byte      `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId      string      `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	ParentId    uint64      `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	NodeId      uint64      `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Meta        []*KeyValue `protobuf:"bytes,5,rep,name=meta,proto3" json:"meta,omitempty"`
	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 {
	Body      *MoveResponse_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 (*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 container.Source) Option

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

func WithLogger 

func WithLogger(log *zap.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 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 {
	Body      *RemoveRequest_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 (*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 {
	ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	TreeId      string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
	NodeId      uint64 `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	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 {
	Body      *RemoveResponse_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 (*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) 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) 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) Synchronize 

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

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

type Signature 

type Signature struct {
	Key  []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	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 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)
	// 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(ctx context.Context, in *GetOpLogRequest, opts ...grpc.CallOption) (TreeService_GetOpLogClient, error)
}

TreeServiceClient is the client API for TreeService service.

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

func 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
	// 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(*GetOpLogRequest, TreeService_GetOpLogServer) 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) Move 

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

func (UnimplementedTreeServiceServer) Remove 

func (UnimplementedTreeServiceServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, 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.