tree

package
v0.44.0-rc.5 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2024 License: GPL-3.0 Imports: 67 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TreeService_Add_FullMethodName           = "/tree.TreeService/Add"
	TreeService_AddByPath_FullMethodName     = "/tree.TreeService/AddByPath"
	TreeService_Remove_FullMethodName        = "/tree.TreeService/Remove"
	TreeService_Move_FullMethodName          = "/tree.TreeService/Move"
	TreeService_GetNodeByPath_FullMethodName = "/tree.TreeService/GetNodeByPath"
	TreeService_GetSubTree_FullMethodName    = "/tree.TreeService/GetSubTree"
	TreeService_TreeList_FullMethodName      = "/tree.TreeService/TreeList"
	TreeService_Apply_FullMethodName         = "/tree.TreeService/Apply"
	TreeService_GetOpLog_FullMethodName      = "/tree.TreeService/GetOpLog"
	TreeService_Healthcheck_FullMethodName   = "/tree.TreeService/Healthcheck"
)

Variables

View Source 
var (
	GetSubTreeRequest_Body_Order_Direction_name = map[int32]string{
		0: "None",
		1: "Asc",
	}
	GetSubTreeRequest_Body_Order_Direction_value = map[string]int32{
		"None": 0,
		"Asc":  1,
	}
)
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 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 {
	Body      *AddByPathRequest_Body `json:"body"`
	Signature *Signature             `json:"signature"`
}

func (*AddByPathRequest) EmitProtobuf added in v0.43.0 

func (x *AddByPathRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*AddByPathRequest) GetBody 

func (x *AddByPathRequest) GetBody() *AddByPathRequest_Body

func (*AddByPathRequest) GetSignature 

func (x *AddByPathRequest) GetSignature() *Signature

func (*AddByPathRequest) MarshalEasyJSON added in v0.43.0 

func (x *AddByPathRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*AddByPathRequest) MarshalJSON added in v0.43.0 

func (x *AddByPathRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddByPathRequest) MarshalProtobuf added in v0.43.0 

func (x *AddByPathRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *AddByPathRequest) SetBody(v *AddByPathRequest_Body)

func (*AddByPathRequest) SetSignature 

func (x *AddByPathRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddByPathRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddByPathRequest) UnmarshalJSON added in v0.43.0 

func (x *AddByPathRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddByPathRequest) UnmarshalProtobuf added in v0.43.0 

func (x *AddByPathRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddByPathRequest_Body 

type AddByPathRequest_Body struct {
	ContainerId   []byte     `json:"containerId"`
	TreeId        string     `json:"treeId"`
	PathAttribute string     `json:"pathAttribute"`
	Path          []string   `json:"path"`
	Meta          []KeyValue `json:"meta"`
	BearerToken   []byte     `json:"bearerToken"`
}

func (*AddByPathRequest_Body) EmitProtobuf added in v0.43.0 

func (x *AddByPathRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *AddByPathRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*AddByPathRequest_Body) MarshalJSON added in v0.43.0 

func (x *AddByPathRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddByPathRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *AddByPathRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddByPathRequest_Body) SetBearerToken added in v0.43.0 

func (x *AddByPathRequest_Body) SetBearerToken(v []byte)

func (*AddByPathRequest_Body) SetContainerId added in v0.43.0 

func (x *AddByPathRequest_Body) SetContainerId(v []byte)

func (*AddByPathRequest_Body) SetMeta added in v0.43.0 

func (x *AddByPathRequest_Body) SetMeta(v []KeyValue)

func (*AddByPathRequest_Body) SetPath added in v0.43.0 

func (x *AddByPathRequest_Body) SetPath(v []string)

func (*AddByPathRequest_Body) SetPathAttribute added in v0.43.0 

func (x *AddByPathRequest_Body) SetPathAttribute(v string)

func (*AddByPathRequest_Body) SetTreeId added in v0.43.0 

func (x *AddByPathRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddByPathRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddByPathRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *AddByPathRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddByPathRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *AddByPathRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddByPathResponse 

type AddByPathResponse struct {
	Body      *AddByPathResponse_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func (*AddByPathResponse) EmitProtobuf added in v0.43.0 

func (x *AddByPathResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*AddByPathResponse) GetBody 

func (x *AddByPathResponse) GetBody() *AddByPathResponse_Body

func (*AddByPathResponse) GetSignature 

func (x *AddByPathResponse) GetSignature() *Signature

func (*AddByPathResponse) MarshalEasyJSON added in v0.43.0 

func (x *AddByPathResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*AddByPathResponse) MarshalJSON added in v0.43.0 

func (x *AddByPathResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddByPathResponse) MarshalProtobuf added in v0.43.0 

func (x *AddByPathResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *AddByPathResponse) SetBody(v *AddByPathResponse_Body)

func (*AddByPathResponse) SetSignature 

func (x *AddByPathResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddByPathResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddByPathResponse) UnmarshalJSON added in v0.43.0 

func (x *AddByPathResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddByPathResponse) UnmarshalProtobuf added in v0.43.0 

func (x *AddByPathResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddByPathResponse_Body 

type AddByPathResponse_Body struct {
	Nodes    []uint64 `json:"nodes"`
	ParentId uint64   `json:"parentId"`
}

func (*AddByPathResponse_Body) EmitProtobuf added in v0.43.0 

func (x *AddByPathResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*AddByPathResponse_Body) GetNodes 

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

func (*AddByPathResponse_Body) GetParentId 

func (x *AddByPathResponse_Body) GetParentId() uint64

func (*AddByPathResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *AddByPathResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*AddByPathResponse_Body) MarshalJSON added in v0.43.0 

func (x *AddByPathResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddByPathResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *AddByPathResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddByPathResponse_Body) SetNodes added in v0.43.0 

func (x *AddByPathResponse_Body) SetNodes(v []uint64)

func (*AddByPathResponse_Body) SetParentId added in v0.43.0 

func (x *AddByPathResponse_Body) SetParentId(v uint64)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddByPathResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddByPathResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *AddByPathResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddByPathResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *AddByPathResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddRequest 

type AddRequest struct {
	Body      *AddRequest_Body `json:"body"`
	Signature *Signature       `json:"signature"`
}

func (*AddRequest) EmitProtobuf added in v0.43.0 

func (x *AddRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*AddRequest) GetBody 

func (x *AddRequest) GetBody() *AddRequest_Body

func (*AddRequest) GetSignature 

func (x *AddRequest) GetSignature() *Signature

func (*AddRequest) MarshalEasyJSON added in v0.43.0 

func (x *AddRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*AddRequest) MarshalJSON added in v0.43.0 

func (x *AddRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddRequest) MarshalProtobuf added in v0.43.0 

func (x *AddRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *AddRequest) SetBody(v *AddRequest_Body)

func (*AddRequest) SetSignature 

func (x *AddRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddRequest) UnmarshalJSON added in v0.43.0 

func (x *AddRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddRequest) UnmarshalProtobuf added in v0.43.0 

func (x *AddRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddRequest_Body 

type AddRequest_Body struct {
	ContainerId []byte     `json:"containerId"`
	TreeId      string     `json:"treeId"`
	ParentId    uint64     `json:"parentId"`
	Meta        []KeyValue `json:"meta"`
	BearerToken []byte     `json:"bearerToken"`
}

func (*AddRequest_Body) EmitProtobuf added in v0.43.0 

func (x *AddRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *AddRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*AddRequest_Body) MarshalJSON added in v0.43.0 

func (x *AddRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *AddRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddRequest_Body) SetBearerToken added in v0.43.0 

func (x *AddRequest_Body) SetBearerToken(v []byte)

func (*AddRequest_Body) SetContainerId added in v0.43.0 

func (x *AddRequest_Body) SetContainerId(v []byte)

func (*AddRequest_Body) SetMeta added in v0.43.0 

func (x *AddRequest_Body) SetMeta(v []KeyValue)

func (*AddRequest_Body) SetParentId added in v0.43.0 

func (x *AddRequest_Body) SetParentId(v uint64)

func (*AddRequest_Body) SetTreeId added in v0.43.0 

func (x *AddRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *AddRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *AddRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddResponse 

type AddResponse struct {
	Body      *AddResponse_Body `json:"body"`
	Signature *Signature        `json:"signature"`
}

func (*AddResponse) EmitProtobuf added in v0.43.0 

func (x *AddResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*AddResponse) GetBody 

func (x *AddResponse) GetBody() *AddResponse_Body

func (*AddResponse) GetSignature 

func (x *AddResponse) GetSignature() *Signature

func (*AddResponse) MarshalEasyJSON added in v0.43.0 

func (x *AddResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*AddResponse) MarshalJSON added in v0.43.0 

func (x *AddResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddResponse) MarshalProtobuf added in v0.43.0 

func (x *AddResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *AddResponse) SetBody(v *AddResponse_Body)

func (*AddResponse) SetSignature 

func (x *AddResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddResponse) UnmarshalJSON added in v0.43.0 

func (x *AddResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddResponse) UnmarshalProtobuf added in v0.43.0 

func (x *AddResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddResponse_Body 

type AddResponse_Body struct {
	NodeId uint64 `json:"nodeId"`
}

func (*AddResponse_Body) EmitProtobuf added in v0.43.0 

func (x *AddResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*AddResponse_Body) GetNodeId 

func (x *AddResponse_Body) GetNodeId() uint64

func (*AddResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *AddResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*AddResponse_Body) MarshalJSON added in v0.43.0 

func (x *AddResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*AddResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *AddResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddResponse_Body) SetNodeId added in v0.43.0 

func (x *AddResponse_Body) SetNodeId(v uint64)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *AddResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*AddResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *AddResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *AddResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ApplyRequest 

type ApplyRequest struct {
	Body      *ApplyRequest_Body `json:"body"`
	Signature *Signature         `json:"signature"`
}

func (*ApplyRequest) EmitProtobuf added in v0.43.0 

func (x *ApplyRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*ApplyRequest) GetBody 

func (x *ApplyRequest) GetBody() *ApplyRequest_Body

func (*ApplyRequest) GetSignature 

func (x *ApplyRequest) GetSignature() *Signature

func (*ApplyRequest) MarshalEasyJSON added in v0.43.0 

func (x *ApplyRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*ApplyRequest) MarshalJSON added in v0.43.0 

func (x *ApplyRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*ApplyRequest) MarshalProtobuf added in v0.43.0 

func (x *ApplyRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *ApplyRequest) SetBody(v *ApplyRequest_Body)

func (*ApplyRequest) SetSignature 

func (x *ApplyRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *ApplyRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*ApplyRequest) UnmarshalJSON added in v0.43.0 

func (x *ApplyRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ApplyRequest) UnmarshalProtobuf added in v0.43.0 

func (x *ApplyRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ApplyRequest_Body 

type ApplyRequest_Body struct {
	ContainerId []byte   `json:"containerId"`
	TreeId      string   `json:"treeId"`
	Operation   *LogMove `json:"operation"`
}

func (*ApplyRequest_Body) EmitProtobuf added in v0.43.0 

func (x *ApplyRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *ApplyRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*ApplyRequest_Body) MarshalJSON added in v0.43.0 

func (x *ApplyRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*ApplyRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *ApplyRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ApplyRequest_Body) SetContainerId added in v0.43.0 

func (x *ApplyRequest_Body) SetContainerId(v []byte)

func (*ApplyRequest_Body) SetOperation added in v0.43.0 

func (x *ApplyRequest_Body) SetOperation(v *LogMove)

func (*ApplyRequest_Body) SetTreeId added in v0.43.0 

func (x *ApplyRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *ApplyRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*ApplyRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *ApplyRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ApplyRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *ApplyRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ApplyResponse 

type ApplyResponse struct {
	Body      *ApplyResponse_Body `json:"body"`
	Signature *Signature          `json:"signature"`
}

func (*ApplyResponse) EmitProtobuf added in v0.43.0 

func (x *ApplyResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*ApplyResponse) GetBody 

func (x *ApplyResponse) GetBody() *ApplyResponse_Body

func (*ApplyResponse) GetSignature 

func (x *ApplyResponse) GetSignature() *Signature

func (*ApplyResponse) MarshalEasyJSON added in v0.43.0 

func (x *ApplyResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*ApplyResponse) MarshalJSON added in v0.43.0 

func (x *ApplyResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*ApplyResponse) MarshalProtobuf added in v0.43.0 

func (x *ApplyResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *ApplyResponse) SetBody(v *ApplyResponse_Body)

func (*ApplyResponse) SetSignature 

func (x *ApplyResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *ApplyResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*ApplyResponse) UnmarshalJSON added in v0.43.0 

func (x *ApplyResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ApplyResponse) UnmarshalProtobuf added in v0.43.0 

func (x *ApplyResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ApplyResponse_Body 

type ApplyResponse_Body struct {
}

func (*ApplyResponse_Body) EmitProtobuf added in v0.43.0 

func (x *ApplyResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*ApplyResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *ApplyResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*ApplyResponse_Body) MarshalJSON added in v0.43.0 

func (x *ApplyResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*ApplyResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *ApplyResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) UnmarshalEasyJSON added in v0.43.0 

func (x *ApplyResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*ApplyResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *ApplyResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ApplyResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *ApplyResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ContainerSource 

type ContainerSource interface {
	container.Source

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

	// 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 {
	Body      *GetNodeByPathRequest_Body `json:"body"`
	Signature *Signature                 `json:"signature"`
}

func (*GetNodeByPathRequest) EmitProtobuf added in v0.43.0 

func (x *GetNodeByPathRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetNodeByPathRequest) GetBody 

func (x *GetNodeByPathRequest) GetBody() *GetNodeByPathRequest_Body

func (*GetNodeByPathRequest) GetSignature 

func (x *GetNodeByPathRequest) GetSignature() *Signature

func (*GetNodeByPathRequest) MarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*GetNodeByPathRequest) MarshalJSON added in v0.43.0 

func (x *GetNodeByPathRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetNodeByPathRequest) MarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *GetNodeByPathRequest) SetBody(v *GetNodeByPathRequest_Body)

func (*GetNodeByPathRequest) SetSignature 

func (x *GetNodeByPathRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetNodeByPathRequest) UnmarshalJSON added in v0.43.0 

func (x *GetNodeByPathRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetNodeByPathRequest) UnmarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetNodeByPathRequest_Body 

type GetNodeByPathRequest_Body struct {
	ContainerId   []byte   `json:"containerId"`
	TreeId        string   `json:"treeId"`
	PathAttribute string   `json:"pathAttribute"`
	Path          []string `json:"path"`
	Attributes    []string `json:"attributes"`
	LatestOnly    bool     `json:"latestOnly"`
	AllAttributes bool     `json:"allAttributes"`
	BearerToken   []byte   `json:"bearerToken"`
}

func (*GetNodeByPathRequest_Body) EmitProtobuf added in v0.43.0 

func (x *GetNodeByPathRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*GetNodeByPathRequest_Body) MarshalJSON added in v0.43.0 

func (x *GetNodeByPathRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetNodeByPathRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetNodeByPathRequest_Body) SetAllAttributes added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetAllAttributes(v bool)

func (*GetNodeByPathRequest_Body) SetAttributes added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetAttributes(v []string)

func (*GetNodeByPathRequest_Body) SetBearerToken added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetBearerToken(v []byte)

func (*GetNodeByPathRequest_Body) SetContainerId added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetContainerId(v []byte)

func (*GetNodeByPathRequest_Body) SetLatestOnly added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetLatestOnly(v bool)

func (*GetNodeByPathRequest_Body) SetPath added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetPath(v []string)

func (*GetNodeByPathRequest_Body) SetPathAttribute added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetPathAttribute(v string)

func (*GetNodeByPathRequest_Body) SetTreeId added in v0.43.0 

func (x *GetNodeByPathRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetNodeByPathRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *GetNodeByPathRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetNodeByPathRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetNodeByPathResponse 

type GetNodeByPathResponse struct {
	Body      *GetNodeByPathResponse_Body `json:"body"`
	Signature *Signature                  `json:"signature"`
}

func (*GetNodeByPathResponse) EmitProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetNodeByPathResponse) GetBody 

func (x *GetNodeByPathResponse) GetBody() *GetNodeByPathResponse_Body

func (*GetNodeByPathResponse) GetSignature 

func (x *GetNodeByPathResponse) GetSignature() *Signature

func (*GetNodeByPathResponse) MarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*GetNodeByPathResponse) MarshalJSON added in v0.43.0 

func (x *GetNodeByPathResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetNodeByPathResponse) MarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *GetNodeByPathResponse) SetBody(v *GetNodeByPathResponse_Body)

func (*GetNodeByPathResponse) SetSignature 

func (x *GetNodeByPathResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetNodeByPathResponse) UnmarshalJSON added in v0.43.0 

func (x *GetNodeByPathResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetNodeByPathResponse) UnmarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetNodeByPathResponse_Body 

type GetNodeByPathResponse_Body struct {
	Nodes []GetNodeByPathResponse_Info `json:"nodes"`
}

func (*GetNodeByPathResponse_Body) EmitProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetNodeByPathResponse_Body) GetNodes 

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

func (*GetNodeByPathResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*GetNodeByPathResponse_Body) MarshalJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetNodeByPathResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetNodeByPathResponse_Body) SetNodes added in v0.43.0 

func (x *GetNodeByPathResponse_Body) SetNodes(v []GetNodeByPathResponse_Info)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetNodeByPathResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetNodeByPathResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetNodeByPathResponse_Info 

type GetNodeByPathResponse_Info struct {
	NodeId    uint64     `json:"nodeId"`
	Timestamp uint64     `json:"timestamp"`
	Meta      []KeyValue `json:"meta"`
	ParentId  uint64     `json:"parentId"`
}

func (*GetNodeByPathResponse_Info) EmitProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse_Info) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Info) MarshalEasyJSON(out *jwriter.Writer)

func (*GetNodeByPathResponse_Info) MarshalJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Info) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetNodeByPathResponse_Info) MarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse_Info) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetNodeByPathResponse_Info) SetMeta added in v0.43.0 

func (x *GetNodeByPathResponse_Info) SetMeta(v []KeyValue)

func (*GetNodeByPathResponse_Info) SetNodeId added in v0.43.0 

func (x *GetNodeByPathResponse_Info) SetNodeId(v uint64)

func (*GetNodeByPathResponse_Info) SetParentId added in v0.43.0 

func (x *GetNodeByPathResponse_Info) SetParentId(v uint64)

func (*GetNodeByPathResponse_Info) SetTimestamp added in v0.43.0 

func (x *GetNodeByPathResponse_Info) SetTimestamp(v uint64)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Info) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetNodeByPathResponse_Info) UnmarshalJSON added in v0.43.0 

func (x *GetNodeByPathResponse_Info) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetNodeByPathResponse_Info) UnmarshalProtobuf added in v0.43.0 

func (x *GetNodeByPathResponse_Info) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetOpLogRequest 

type GetOpLogRequest struct {
	Body      *GetOpLogRequest_Body `json:"body"`
	Signature *Signature            `json:"signature"`
}

func (*GetOpLogRequest) EmitProtobuf added in v0.43.0 

func (x *GetOpLogRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetOpLogRequest) GetBody 

func (x *GetOpLogRequest) GetBody() *GetOpLogRequest_Body

func (*GetOpLogRequest) GetSignature 

func (x *GetOpLogRequest) GetSignature() *Signature

func (*GetOpLogRequest) MarshalEasyJSON added in v0.43.0 

func (x *GetOpLogRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*GetOpLogRequest) MarshalJSON added in v0.43.0 

func (x *GetOpLogRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetOpLogRequest) MarshalProtobuf added in v0.43.0 

func (x *GetOpLogRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *GetOpLogRequest) SetBody(v *GetOpLogRequest_Body)

func (*GetOpLogRequest) SetSignature 

func (x *GetOpLogRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetOpLogRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetOpLogRequest) UnmarshalJSON added in v0.43.0 

func (x *GetOpLogRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetOpLogRequest) UnmarshalProtobuf added in v0.43.0 

func (x *GetOpLogRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetOpLogRequest_Body 

type GetOpLogRequest_Body struct {
	ContainerId []byte `json:"containerId"`
	TreeId      string `json:"treeId"`
	Height      uint64 `json:"height"`
	Count       uint64 `json:"count"`
}

func (*GetOpLogRequest_Body) EmitProtobuf added in v0.43.0 

func (x *GetOpLogRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *GetOpLogRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*GetOpLogRequest_Body) MarshalJSON added in v0.43.0 

func (x *GetOpLogRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetOpLogRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *GetOpLogRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetOpLogRequest_Body) SetContainerId added in v0.43.0 

func (x *GetOpLogRequest_Body) SetContainerId(v []byte)

func (*GetOpLogRequest_Body) SetCount added in v0.43.0 

func (x *GetOpLogRequest_Body) SetCount(v uint64)

func (*GetOpLogRequest_Body) SetHeight added in v0.43.0 

func (x *GetOpLogRequest_Body) SetHeight(v uint64)

func (*GetOpLogRequest_Body) SetTreeId added in v0.43.0 

func (x *GetOpLogRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetOpLogRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetOpLogRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *GetOpLogRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetOpLogRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *GetOpLogRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetOpLogResponse 

type GetOpLogResponse struct {
	Body      *GetOpLogResponse_Body `json:"body"`
	Signature *Signature             `json:"signature"`
}

func (*GetOpLogResponse) EmitProtobuf added in v0.43.0 

func (x *GetOpLogResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetOpLogResponse) GetBody 

func (x *GetOpLogResponse) GetBody() *GetOpLogResponse_Body

func (*GetOpLogResponse) GetSignature 

func (x *GetOpLogResponse) GetSignature() *Signature

func (*GetOpLogResponse) MarshalEasyJSON added in v0.43.0 

func (x *GetOpLogResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*GetOpLogResponse) MarshalJSON added in v0.43.0 

func (x *GetOpLogResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetOpLogResponse) MarshalProtobuf added in v0.43.0 

func (x *GetOpLogResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *GetOpLogResponse) SetBody(v *GetOpLogResponse_Body)

func (*GetOpLogResponse) SetSignature 

func (x *GetOpLogResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetOpLogResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetOpLogResponse) UnmarshalJSON added in v0.43.0 

func (x *GetOpLogResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetOpLogResponse) UnmarshalProtobuf added in v0.43.0 

func (x *GetOpLogResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetOpLogResponse_Body 

type GetOpLogResponse_Body struct {
	Operation *LogMove `json:"operation"`
}

func (*GetOpLogResponse_Body) EmitProtobuf added in v0.43.0 

func (x *GetOpLogResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetOpLogResponse_Body) GetOperation 

func (x *GetOpLogResponse_Body) GetOperation() *LogMove

func (*GetOpLogResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *GetOpLogResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*GetOpLogResponse_Body) MarshalJSON added in v0.43.0 

func (x *GetOpLogResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetOpLogResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *GetOpLogResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetOpLogResponse_Body) SetOperation added in v0.43.0 

func (x *GetOpLogResponse_Body) SetOperation(v *LogMove)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetOpLogResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetOpLogResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *GetOpLogResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetOpLogResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *GetOpLogResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetSubTreeRequest 

type GetSubTreeRequest struct {
	Body      *GetSubTreeRequest_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func (*GetSubTreeRequest) EmitProtobuf added in v0.43.0 

func (x *GetSubTreeRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetSubTreeRequest) GetBody 

func (x *GetSubTreeRequest) GetBody() *GetSubTreeRequest_Body

func (*GetSubTreeRequest) GetSignature 

func (x *GetSubTreeRequest) GetSignature() *Signature

func (*GetSubTreeRequest) MarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*GetSubTreeRequest) MarshalJSON added in v0.43.0 

func (x *GetSubTreeRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetSubTreeRequest) MarshalProtobuf added in v0.43.0 

func (x *GetSubTreeRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *GetSubTreeRequest) SetBody(v *GetSubTreeRequest_Body)

func (*GetSubTreeRequest) SetSignature 

func (x *GetSubTreeRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetSubTreeRequest) UnmarshalJSON added in v0.43.0 

func (x *GetSubTreeRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetSubTreeRequest) UnmarshalProtobuf added in v0.43.0 

func (x *GetSubTreeRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetSubTreeRequest_Body 

type GetSubTreeRequest_Body struct {
	ContainerId []byte                        `json:"containerId"`
	TreeId      string                        `json:"treeId"`
	RootId      []uint64                      `json:"rootId"`
	Depth       uint32                        `json:"depth"`
	BearerToken []byte                        `json:"bearerToken"`
	OrderBy     *GetSubTreeRequest_Body_Order `json:"orderBy"`
}

func (*GetSubTreeRequest_Body) EmitProtobuf added in v0.43.0 

func (x *GetSubTreeRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) GetOrderBy added in v0.37.0 

func (x *GetSubTreeRequest_Body) GetOrderBy() *GetSubTreeRequest_Body_Order

func (*GetSubTreeRequest_Body) GetRootId 

func (x *GetSubTreeRequest_Body) GetRootId() []uint64

func (*GetSubTreeRequest_Body) GetTreeId 

func (x *GetSubTreeRequest_Body) GetTreeId() string

func (*GetSubTreeRequest_Body) MarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*GetSubTreeRequest_Body) MarshalJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetSubTreeRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *GetSubTreeRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetSubTreeRequest_Body) SetBearerToken added in v0.43.0 

func (x *GetSubTreeRequest_Body) SetBearerToken(v []byte)

func (*GetSubTreeRequest_Body) SetContainerId added in v0.43.0 

func (x *GetSubTreeRequest_Body) SetContainerId(v []byte)

func (*GetSubTreeRequest_Body) SetDepth added in v0.43.0 

func (x *GetSubTreeRequest_Body) SetDepth(v uint32)

func (*GetSubTreeRequest_Body) SetOrderBy added in v0.43.0 

func (x *GetSubTreeRequest_Body) SetOrderBy(v *GetSubTreeRequest_Body_Order)

func (*GetSubTreeRequest_Body) SetRootId added in v0.43.0 

func (x *GetSubTreeRequest_Body) SetRootId(v []uint64)

func (*GetSubTreeRequest_Body) SetTreeId added in v0.43.0 

func (x *GetSubTreeRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetSubTreeRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetSubTreeRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *GetSubTreeRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetSubTreeRequest_Body_Order added in v0.37.0 

type GetSubTreeRequest_Body_Order struct {
	Direction GetSubTreeRequest_Body_Order_Direction `json:"direction"`
}

func (*GetSubTreeRequest_Body_Order) EmitProtobuf added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetSubTreeRequest_Body_Order) GetDirection added in v0.37.0 

func (x *GetSubTreeRequest_Body_Order) GetDirection() GetSubTreeRequest_Body_Order_Direction

func (*GetSubTreeRequest_Body_Order) MarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) MarshalEasyJSON(out *jwriter.Writer)

func (*GetSubTreeRequest_Body_Order) MarshalJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetSubTreeRequest_Body_Order) MarshalProtobuf added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetSubTreeRequest_Body_Order) SetDirection added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) SetDirection(v GetSubTreeRequest_Body_Order_Direction)

func (*GetSubTreeRequest_Body_Order) StableSize added in v0.37.0 

func (x *GetSubTreeRequest_Body_Order) 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_Order) UnmarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetSubTreeRequest_Body_Order) UnmarshalJSON added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetSubTreeRequest_Body_Order) UnmarshalProtobuf added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetSubTreeRequest_Body_Order_Direction added in v0.37.0 

type GetSubTreeRequest_Body_Order_Direction int32
const (
	GetSubTreeRequest_Body_Order_None GetSubTreeRequest_Body_Order_Direction = 0
	GetSubTreeRequest_Body_Order_Asc  GetSubTreeRequest_Body_Order_Direction = 1
)

func (*GetSubTreeRequest_Body_Order_Direction) FromString added in v0.43.0 

func (x *GetSubTreeRequest_Body_Order_Direction) FromString(s string) bool

func (GetSubTreeRequest_Body_Order_Direction) String added in v0.37.0 

func (x GetSubTreeRequest_Body_Order_Direction) String() string

type GetSubTreeResponse 

type GetSubTreeResponse struct {
	Body      *GetSubTreeResponse_Body `json:"body"`
	Signature *Signature               `json:"signature"`
}

func (*GetSubTreeResponse) EmitProtobuf added in v0.43.0 

func (x *GetSubTreeResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*GetSubTreeResponse) GetBody 

func (x *GetSubTreeResponse) GetBody() *GetSubTreeResponse_Body

func (*GetSubTreeResponse) GetSignature 

func (x *GetSubTreeResponse) GetSignature() *Signature

func (*GetSubTreeResponse) MarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*GetSubTreeResponse) MarshalJSON added in v0.43.0 

func (x *GetSubTreeResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetSubTreeResponse) MarshalProtobuf added in v0.43.0 

func (x *GetSubTreeResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *GetSubTreeResponse) SetBody(v *GetSubTreeResponse_Body)

func (*GetSubTreeResponse) SetSignature 

func (x *GetSubTreeResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetSubTreeResponse) UnmarshalJSON added in v0.43.0 

func (x *GetSubTreeResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetSubTreeResponse) UnmarshalProtobuf added in v0.43.0 

func (x *GetSubTreeResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetSubTreeResponse_Body 

type GetSubTreeResponse_Body struct {
	NodeId    []uint64   `json:"nodeId"`
	ParentId  []uint64   `json:"parentId"`
	Timestamp []uint64   `json:"timestamp"`
	Meta      []KeyValue `json:"meta"`
}

func (*GetSubTreeResponse_Body) EmitProtobuf added in v0.43.0 

func (x *GetSubTreeResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*GetSubTreeResponse_Body) MarshalJSON added in v0.43.0 

func (x *GetSubTreeResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*GetSubTreeResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *GetSubTreeResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*GetSubTreeResponse_Body) SetMeta added in v0.43.0 

func (x *GetSubTreeResponse_Body) SetMeta(v []KeyValue)

func (*GetSubTreeResponse_Body) SetNodeId added in v0.43.0 

func (x *GetSubTreeResponse_Body) SetNodeId(v []uint64)

func (*GetSubTreeResponse_Body) SetParentId added in v0.43.0 

func (x *GetSubTreeResponse_Body) SetParentId(v []uint64)

func (*GetSubTreeResponse_Body) SetTimestamp added in v0.43.0 

func (x *GetSubTreeResponse_Body) SetTimestamp(v []uint64)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *GetSubTreeResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*GetSubTreeResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *GetSubTreeResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*GetSubTreeResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *GetSubTreeResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthcheckRequest 

type HealthcheckRequest struct {
	Body      *HealthcheckRequest_Body `json:"body"`
	Signature *Signature               `json:"signature"`
}

func (*HealthcheckRequest) EmitProtobuf added in v0.43.0 

func (x *HealthcheckRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthcheckRequest) GetBody 

func (x *HealthcheckRequest) GetBody() *HealthcheckRequest_Body

func (*HealthcheckRequest) GetSignature 

func (x *HealthcheckRequest) GetSignature() *Signature

func (*HealthcheckRequest) MarshalEasyJSON added in v0.43.0 

func (x *HealthcheckRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthcheckRequest) MarshalJSON added in v0.43.0 

func (x *HealthcheckRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthcheckRequest) MarshalProtobuf added in v0.43.0 

func (x *HealthcheckRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *HealthcheckRequest) SetBody(v *HealthcheckRequest_Body)

func (*HealthcheckRequest) SetSignature 

func (x *HealthcheckRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *HealthcheckRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthcheckRequest) UnmarshalJSON added in v0.43.0 

func (x *HealthcheckRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthcheckRequest) UnmarshalProtobuf added in v0.43.0 

func (x *HealthcheckRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthcheckRequest_Body 

type HealthcheckRequest_Body struct {
}

func (*HealthcheckRequest_Body) EmitProtobuf added in v0.43.0 

func (x *HealthcheckRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthcheckRequest_Body) MarshalEasyJSON added in v0.43.0 

func (x *HealthcheckRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthcheckRequest_Body) MarshalJSON added in v0.43.0 

func (x *HealthcheckRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthcheckRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *HealthcheckRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) UnmarshalEasyJSON added in v0.43.0 

func (x *HealthcheckRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthcheckRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *HealthcheckRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthcheckRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *HealthcheckRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthcheckResponse 

type HealthcheckResponse struct {
	Body      *HealthcheckResponse_Body `json:"body"`
	Signature *Signature                `json:"signature"`
}

func (*HealthcheckResponse) EmitProtobuf added in v0.43.0 

func (x *HealthcheckResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthcheckResponse) GetBody 

func (x *HealthcheckResponse) GetBody() *HealthcheckResponse_Body

func (*HealthcheckResponse) GetSignature 

func (x *HealthcheckResponse) GetSignature() *Signature

func (*HealthcheckResponse) MarshalEasyJSON added in v0.43.0 

func (x *HealthcheckResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthcheckResponse) MarshalJSON added in v0.43.0 

func (x *HealthcheckResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthcheckResponse) MarshalProtobuf added in v0.43.0 

func (x *HealthcheckResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *HealthcheckResponse) SetBody(v *HealthcheckResponse_Body)

func (*HealthcheckResponse) SetSignature 

func (x *HealthcheckResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *HealthcheckResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthcheckResponse) UnmarshalJSON added in v0.43.0 

func (x *HealthcheckResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthcheckResponse) UnmarshalProtobuf added in v0.43.0 

func (x *HealthcheckResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthcheckResponse_Body 

type HealthcheckResponse_Body struct {
}

func (*HealthcheckResponse_Body) EmitProtobuf added in v0.43.0 

func (x *HealthcheckResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthcheckResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *HealthcheckResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthcheckResponse_Body) MarshalJSON added in v0.43.0 

func (x *HealthcheckResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthcheckResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *HealthcheckResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) UnmarshalEasyJSON added in v0.43.0 

func (x *HealthcheckResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthcheckResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *HealthcheckResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthcheckResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *HealthcheckResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type KeyValue 

type KeyValue struct {
	Key   string `json:"key"`
	Value []byte `json:"value"`
}

func (*KeyValue) EmitProtobuf added in v0.43.0 

func (x *KeyValue) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue 

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

func (*KeyValue) MarshalEasyJSON added in v0.43.0 

func (x *KeyValue) MarshalEasyJSON(out *jwriter.Writer)

func (*KeyValue) MarshalJSON added in v0.43.0 

func (x *KeyValue) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*KeyValue) MarshalProtobuf added in v0.43.0 

func (x *KeyValue) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*KeyValue) SetKey added in v0.43.0 

func (x *KeyValue) SetKey(v string)

func (*KeyValue) SetValue added in v0.43.0 

func (x *KeyValue) SetValue(v []byte)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *KeyValue) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*KeyValue) UnmarshalJSON added in v0.43.0 

func (x *KeyValue) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*KeyValue) UnmarshalProtobuf added in v0.43.0 

func (x *KeyValue) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type LogMove 

type LogMove struct {
	ParentId uint64 `json:"parentID"`
	Meta     []byte `json:"meta"`
	ChildId  uint64 `json:"childID"`
}

func (*LogMove) EmitProtobuf added in v0.43.0 

func (x *LogMove) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *LogMove) MarshalEasyJSON(out *jwriter.Writer)

func (*LogMove) MarshalJSON added in v0.43.0 

func (x *LogMove) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*LogMove) MarshalProtobuf added in v0.43.0 

func (x *LogMove) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*LogMove) SetChildId added in v0.43.0 

func (x *LogMove) SetChildId(v uint64)

func (*LogMove) SetMeta added in v0.43.0 

func (x *LogMove) SetMeta(v []byte)

func (*LogMove) SetParentId added in v0.43.0 

func (x *LogMove) SetParentId(v uint64)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *LogMove) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*LogMove) UnmarshalJSON added in v0.43.0 

func (x *LogMove) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*LogMove) UnmarshalProtobuf added in v0.43.0 

func (x *LogMove) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type MetricsRegister added in v0.37.0 

type MetricsRegister interface {
	AddReplicateTaskDuration(time.Duration, bool)
	AddReplicateWaitDuration(time.Duration, bool)
	AddSyncDuration(time.Duration, bool)
}

type MoveRequest 

type MoveRequest struct {
	Body      *MoveRequest_Body `json:"body"`
	Signature *Signature        `json:"signature"`
}

func (*MoveRequest) EmitProtobuf added in v0.43.0 

func (x *MoveRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*MoveRequest) GetBody 

func (x *MoveRequest) GetBody() *MoveRequest_Body

func (*MoveRequest) GetSignature 

func (x *MoveRequest) GetSignature() *Signature

func (*MoveRequest) MarshalEasyJSON added in v0.43.0 

func (x *MoveRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*MoveRequest) MarshalJSON added in v0.43.0 

func (x *MoveRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*MoveRequest) MarshalProtobuf added in v0.43.0 

func (x *MoveRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *MoveRequest) SetBody(v *MoveRequest_Body)

func (*MoveRequest) SetSignature 

func (x *MoveRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *MoveRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*MoveRequest) UnmarshalJSON added in v0.43.0 

func (x *MoveRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*MoveRequest) UnmarshalProtobuf added in v0.43.0 

func (x *MoveRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type MoveRequest_Body 

type MoveRequest_Body struct {
	ContainerId []byte     `json:"containerId"`
	TreeId      string     `json:"treeId"`
	ParentId    uint64     `json:"parentId"`
	NodeId      uint64     `json:"nodeId"`
	Meta        []KeyValue `json:"meta"`
	BearerToken []byte     `json:"bearerToken"`
}

func (*MoveRequest_Body) EmitProtobuf added in v0.43.0 

func (x *MoveRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *MoveRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*MoveRequest_Body) MarshalJSON added in v0.43.0 

func (x *MoveRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*MoveRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *MoveRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*MoveRequest_Body) SetBearerToken added in v0.43.0 

func (x *MoveRequest_Body) SetBearerToken(v []byte)

func (*MoveRequest_Body) SetContainerId added in v0.43.0 

func (x *MoveRequest_Body) SetContainerId(v []byte)

func (*MoveRequest_Body) SetMeta added in v0.43.0 

func (x *MoveRequest_Body) SetMeta(v []KeyValue)

func (*MoveRequest_Body) SetNodeId added in v0.43.0 

func (x *MoveRequest_Body) SetNodeId(v uint64)

func (*MoveRequest_Body) SetParentId added in v0.43.0 

func (x *MoveRequest_Body) SetParentId(v uint64)

func (*MoveRequest_Body) SetTreeId added in v0.43.0 

func (x *MoveRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *MoveRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*MoveRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *MoveRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*MoveRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *MoveRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type MoveResponse 

type MoveResponse struct {
	Body      *MoveResponse_Body `json:"body"`
	Signature *Signature         `json:"signature"`
}

func (*MoveResponse) EmitProtobuf added in v0.43.0 

func (x *MoveResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*MoveResponse) GetBody 

func (x *MoveResponse) GetBody() *MoveResponse_Body

func (*MoveResponse) GetSignature 

func (x *MoveResponse) GetSignature() *Signature

func (*MoveResponse) MarshalEasyJSON added in v0.43.0 

func (x *MoveResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*MoveResponse) MarshalJSON added in v0.43.0 

func (x *MoveResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*MoveResponse) MarshalProtobuf added in v0.43.0 

func (x *MoveResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *MoveResponse) SetBody(v *MoveResponse_Body)

func (*MoveResponse) SetSignature 

func (x *MoveResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *MoveResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*MoveResponse) UnmarshalJSON added in v0.43.0 

func (x *MoveResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*MoveResponse) UnmarshalProtobuf added in v0.43.0 

func (x *MoveResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type MoveResponse_Body 

type MoveResponse_Body struct {
}

func (*MoveResponse_Body) EmitProtobuf added in v0.43.0 

func (x *MoveResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*MoveResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *MoveResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*MoveResponse_Body) MarshalJSON added in v0.43.0 

func (x *MoveResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*MoveResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *MoveResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) UnmarshalEasyJSON added in v0.43.0 

func (x *MoveResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*MoveResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *MoveResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*MoveResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *MoveResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type Option 

type Option func(*cfg)

Option represents configuration option for a tree service.

func WithAPELocalOverrideStorage added in v0.42.0 

func WithAPELocalOverrideStorage(localOverrideStorage policyengine.LocalOverrideStorage) Option

func WithAPEMorphRuleStorage added in v0.42.0 

func WithAPEMorphRuleStorage(morphRuleStorage policyengine.MorphRuleChainStorageReader) Option

func WithAuthorizedKeys added in v0.37.0 

func WithAuthorizedKeys(keys keys.PublicKeys) Option

WithAuthorizedKeys returns option to add list of public keys that have rights to use 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 WithFrostfsidSubjectProvider added in v0.39.0 

func WithFrostfsidSubjectProvider(provider frostfsidcore.SubjectProvider) Option

func WithLogger 

func WithLogger(log *logger.Logger) Option

WithLogger sets logger for a tree service.

func WithMetrics added in v0.37.0 

func WithMetrics(v MetricsRegister) Option

func WithNetmapSource 

func WithNetmapSource(src netmap.Source) Option

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

func WithNetmapState added in v0.41.0 

func WithNetmapState(state netmap.State) Option

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 {
	Body      *RemoveRequest_Body `json:"body"`
	Signature *Signature          `json:"signature"`
}

func (*RemoveRequest) EmitProtobuf added in v0.43.0 

func (x *RemoveRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveRequest) GetBody 

func (x *RemoveRequest) GetBody() *RemoveRequest_Body

func (*RemoveRequest) GetSignature 

func (x *RemoveRequest) GetSignature() *Signature

func (*RemoveRequest) MarshalEasyJSON added in v0.43.0 

func (x *RemoveRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveRequest) MarshalJSON added in v0.43.0 

func (x *RemoveRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveRequest) MarshalProtobuf added in v0.43.0 

func (x *RemoveRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *RemoveRequest) SetBody(v *RemoveRequest_Body)

func (*RemoveRequest) SetSignature 

func (x *RemoveRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *RemoveRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveRequest) UnmarshalJSON added in v0.43.0 

func (x *RemoveRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveRequest) UnmarshalProtobuf added in v0.43.0 

func (x *RemoveRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveRequest_Body 

type RemoveRequest_Body struct {
	ContainerId []byte `json:"containerId"`
	TreeId      string `json:"treeId"`
	NodeId      uint64 `json:"nodeId"`
	BearerToken []byte `json:"bearerToken"`
}

func (*RemoveRequest_Body) EmitProtobuf added in v0.43.0 

func (x *RemoveRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

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) MarshalEasyJSON added in v0.43.0 

func (x *RemoveRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveRequest_Body) MarshalJSON added in v0.43.0 

func (x *RemoveRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *RemoveRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveRequest_Body) SetBearerToken added in v0.43.0 

func (x *RemoveRequest_Body) SetBearerToken(v []byte)

func (*RemoveRequest_Body) SetContainerId added in v0.43.0 

func (x *RemoveRequest_Body) SetContainerId(v []byte)

func (*RemoveRequest_Body) SetNodeId added in v0.43.0 

func (x *RemoveRequest_Body) SetNodeId(v uint64)

func (*RemoveRequest_Body) SetTreeId added in v0.43.0 

func (x *RemoveRequest_Body) SetTreeId(v string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *RemoveRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *RemoveRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *RemoveRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveResponse 

type RemoveResponse struct {
	Body      *RemoveResponse_Body `json:"body"`
	Signature *Signature           `json:"signature"`
}

func (*RemoveResponse) EmitProtobuf added in v0.43.0 

func (x *RemoveResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveResponse) GetBody 

func (x *RemoveResponse) GetBody() *RemoveResponse_Body

func (*RemoveResponse) GetSignature 

func (x *RemoveResponse) GetSignature() *Signature

func (*RemoveResponse) MarshalEasyJSON added in v0.43.0 

func (x *RemoveResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveResponse) MarshalJSON added in v0.43.0 

func (x *RemoveResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveResponse) MarshalProtobuf added in v0.43.0 

func (x *RemoveResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *RemoveResponse) SetBody(v *RemoveResponse_Body)

func (*RemoveResponse) SetSignature 

func (x *RemoveResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *RemoveResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveResponse) UnmarshalJSON added in v0.43.0 

func (x *RemoveResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveResponse) UnmarshalProtobuf added in v0.43.0 

func (x *RemoveResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveResponse_Body 

type RemoveResponse_Body struct {
}

func (*RemoveResponse_Body) EmitProtobuf added in v0.43.0 

func (x *RemoveResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *RemoveResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveResponse_Body) MarshalJSON added in v0.43.0 

func (x *RemoveResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *RemoveResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) UnmarshalEasyJSON added in v0.43.0 

func (x *RemoveResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *RemoveResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *RemoveResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

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(ctx 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) ReplicateTreeOp added in v0.38.0 

func (s *Service) ReplicateTreeOp(ctx context.Context, n netmapSDK.NodeInfo, req *ApplyRequest) 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 {
	Key  []byte `json:"key"`
	Sign []byte `json:"signature"`
}

func (*Signature) EmitProtobuf added in v0.43.0 

func (x *Signature) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*Signature) GetKey 

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

func (*Signature) GetSign 

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

func (*Signature) MarshalEasyJSON added in v0.43.0 

func (x *Signature) MarshalEasyJSON(out *jwriter.Writer)

func (*Signature) MarshalJSON added in v0.43.0 

func (x *Signature) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*Signature) MarshalProtobuf added in v0.43.0 

func (x *Signature) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*Signature) SetKey added in v0.43.0 

func (x *Signature) SetKey(v []byte)

func (*Signature) SetSign added in v0.43.0 

func (x *Signature) SetSign(v []byte)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *Signature) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*Signature) UnmarshalJSON added in v0.43.0 

func (x *Signature) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*Signature) UnmarshalProtobuf added in v0.43.0 

func (x *Signature) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeListRequest 

type TreeListRequest struct {
	Body      *TreeListRequest_Body `json:"body"`
	Signature *Signature            `json:"signature"`
}

func (*TreeListRequest) EmitProtobuf added in v0.43.0 

func (x *TreeListRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TreeListRequest) GetBody 

func (x *TreeListRequest) GetBody() *TreeListRequest_Body

func (*TreeListRequest) GetSignature 

func (x *TreeListRequest) GetSignature() *Signature

func (*TreeListRequest) MarshalEasyJSON added in v0.43.0 

func (x *TreeListRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*TreeListRequest) MarshalJSON added in v0.43.0 

func (x *TreeListRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TreeListRequest) MarshalProtobuf added in v0.43.0 

func (x *TreeListRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *TreeListRequest) SetBody(v *TreeListRequest_Body)

func (*TreeListRequest) SetSignature 

func (x *TreeListRequest) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *TreeListRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TreeListRequest) UnmarshalJSON added in v0.43.0 

func (x *TreeListRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeListRequest) UnmarshalProtobuf added in v0.43.0 

func (x *TreeListRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeListRequest_Body 

type TreeListRequest_Body struct {
	ContainerId []byte `json:"containerId"`
}

func (*TreeListRequest_Body) EmitProtobuf added in v0.43.0 

func (x *TreeListRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TreeListRequest_Body) GetContainerId 

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

func (*TreeListRequest_Body) MarshalEasyJSON added in v0.43.0 

func (x *TreeListRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*TreeListRequest_Body) MarshalJSON added in v0.43.0 

func (x *TreeListRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TreeListRequest_Body) MarshalProtobuf added in v0.43.0 

func (x *TreeListRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TreeListRequest_Body) SetContainerId added in v0.43.0 

func (x *TreeListRequest_Body) SetContainerId(v []byte)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *TreeListRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TreeListRequest_Body) UnmarshalJSON added in v0.43.0 

func (x *TreeListRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeListRequest_Body) UnmarshalProtobuf added in v0.43.0 

func (x *TreeListRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeListResponse 

type TreeListResponse struct {
	Body      *TreeListResponse_Body `json:"body"`
	Signature *Signature             `json:"signature"`
}

func (*TreeListResponse) EmitProtobuf added in v0.43.0 

func (x *TreeListResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TreeListResponse) GetBody 

func (x *TreeListResponse) GetBody() *TreeListResponse_Body

func (*TreeListResponse) GetSignature 

func (x *TreeListResponse) GetSignature() *Signature

func (*TreeListResponse) MarshalEasyJSON added in v0.43.0 

func (x *TreeListResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*TreeListResponse) MarshalJSON added in v0.43.0 

func (x *TreeListResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TreeListResponse) MarshalProtobuf added in v0.43.0 

func (x *TreeListResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

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) SetBody added in v0.43.0 

func (x *TreeListResponse) SetBody(v *TreeListResponse_Body)

func (*TreeListResponse) SetSignature 

func (x *TreeListResponse) SetSignature(v *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) 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) UnmarshalEasyJSON added in v0.43.0 

func (x *TreeListResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TreeListResponse) UnmarshalJSON added in v0.43.0 

func (x *TreeListResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeListResponse) UnmarshalProtobuf added in v0.43.0 

func (x *TreeListResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeListResponse_Body 

type TreeListResponse_Body struct {
	Ids []string `json:"ids"`
}

func (*TreeListResponse_Body) EmitProtobuf added in v0.43.0 

func (x *TreeListResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TreeListResponse_Body) GetIds 

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

func (*TreeListResponse_Body) MarshalEasyJSON added in v0.43.0 

func (x *TreeListResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*TreeListResponse_Body) MarshalJSON added in v0.43.0 

func (x *TreeListResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TreeListResponse_Body) MarshalProtobuf added in v0.43.0 

func (x *TreeListResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TreeListResponse_Body) SetIds added in v0.43.0 

func (x *TreeListResponse_Body) SetIds(v []string)

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) UnmarshalEasyJSON added in v0.43.0 

func (x *TreeListResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TreeListResponse_Body) UnmarshalJSON added in v0.43.0 

func (x *TreeListResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeListResponse_Body) UnmarshalProtobuf added in v0.43.0 

func (x *TreeListResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

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.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
	// 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.