tree

package
v0.49.0 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2026 License: GPL-3.0 Imports: 84 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_TreeHeight_FullMethodName                = "/tree.TreeService/TreeHeight"
	TreeService_Apply_FullMethodName                     = "/tree.TreeService/Apply"
	TreeService_GetOpLog_FullMethodName                  = "/tree.TreeService/GetOpLog"
	TreeService_ScheduleSync_FullMethodName              = "/tree.TreeService/ScheduleSync"
	TreeService_SyncStatus_FullMethodName                = "/tree.TreeService/SyncStatus"
	TreeService_Healthcheck_FullMethodName               = "/tree.TreeService/Healthcheck"
	TreeService_SpaceUtilization_FullMethodName          = "/tree.TreeService/SpaceUtilization"
	TreeService_SubmitSynchronizationTask_FullMethodName = "/tree.TreeService/SubmitSynchronizationTask"
	TreeService_SubmitCompactionTask_FullMethodName      = "/tree.TreeService/SubmitCompactionTask"
	TreeService_TaskStatus_FullMethodName                = "/tree.TreeService/TaskStatus"
	TreeService_AbortTask_FullMethodName                 = "/tree.TreeService/AbortTask"
	TreeService_AddOpLogLock_FullMethodName              = "/tree.TreeService/AddOpLogLock"
	TreeService_RemoveOpLogLock_FullMethodName           = "/tree.TreeService/RemoveOpLogLock"
	TreeService_ListOpLogLocks_FullMethodName            = "/tree.TreeService/ListOpLogLocks"
	TreeService_OpLogHash_FullMethodName                 = "/tree.TreeService/OpLogHash"
	TreeService_Drop_FullMethodName                      = "/tree.TreeService/Drop"
)

Variables

View Source 
var (
	ErrForesterAlreadyRunning   = errors.New("tree service forester is already running")
	ErrForesterAlreadyScheduled = errors.New("tree service forester is already scheduled")
)
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 (
	SyncStatusResponse_Body_Status_name = map[int32]string{
		0: "Undefined",
		1: "Pending",
		2: "InProgress",
		3: "Completed",
	}
	SyncStatusResponse_Body_Status_value = map[string]int32{
		"Undefined":  0,
		"Pending":    1,
		"InProgress": 2,
		"Completed":  3,
	}
)
View Source 
var (
	TaskStatusResponse_Status_name = map[int32]string{
		0: "UNDEFINED",
		1: "QUEUED",
		2: "RUNNING",
		3: "DONE",
		4: "FAILED",
		5: "UNKNOWN",
	}
	TaskStatusResponse_Status_value = map[string]int32{
		"UNDEFINED": 0,
		"QUEUED":    1,
		"RUNNING":   2,
		"DONE":      3,
		"FAILED":    4,
		"UNKNOWN":   5,
	}
)
View Source 
var (
	OpLogLock_Type_name = map[int32]string{
		0: "UNDEFINED",
		1: "PREFIX",
		2: "SUFFIX",
	}
	OpLogLock_Type_value = map[string]int32{
		"UNDEFINED": 0,
		"PREFIX":    1,
		"SUFFIX":    2,
	}
)
View Source 
var ErrAlreadySyncing = errors.New("service is being synchronized")

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

View Source 
var ErrNotAllNodesSynced = errors.New("synchronization is not performed for all nodes")
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 (
	ErrResyncAlreadyScheduled = errors.New("tree service resync is already scheduled")
)
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 ErrTreeServiceIsNotAvailable = errors.New("tree service is not available on remote node")
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: "TreeHeight",
			Handler:    _TreeService_TreeHeight_Handler,
		},
		{
			MethodName: "Apply",
			Handler:    _TreeService_Apply_Handler,
		},
		{
			MethodName: "ScheduleSync",
			Handler:    _TreeService_ScheduleSync_Handler,
		},
		{
			MethodName: "SyncStatus",
			Handler:    _TreeService_SyncStatus_Handler,
		},
		{
			MethodName: "Healthcheck",
			Handler:    _TreeService_Healthcheck_Handler,
		},
		{
			MethodName: "SpaceUtilization",
			Handler:    _TreeService_SpaceUtilization_Handler,
		},
		{
			MethodName: "SubmitSynchronizationTask",
			Handler:    _TreeService_SubmitSynchronizationTask_Handler,
		},
		{
			MethodName: "SubmitCompactionTask",
			Handler:    _TreeService_SubmitCompactionTask_Handler,
		},
		{
			MethodName: "TaskStatus",
			Handler:    _TreeService_TaskStatus_Handler,
		},
		{
			MethodName: "AbortTask",
			Handler:    _TreeService_AbortTask_Handler,
		},
		{
			MethodName: "AddOpLogLock",
			Handler:    _TreeService_AddOpLogLock_Handler,
		},
		{
			MethodName: "RemoveOpLogLock",
			Handler:    _TreeService_RemoveOpLogLock_Handler,
		},
		{
			MethodName: "ListOpLogLocks",
			Handler:    _TreeService_ListOpLogLocks_Handler,
		},
		{
			MethodName: "OpLogHash",
			Handler:    _TreeService_OpLogHash_Handler,
		},
		{
			MethodName: "Drop",
			Handler:    _TreeService_Drop_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 AbortTaskRequest added in v0.49.0 

type AbortTaskRequest struct {
	Body      *AbortTaskRequest_Body `json:"body"`
	Signature *Signature             `json:"signature"`
}

func (*AbortTaskRequest) EmitProtobuf added in v0.49.0 

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

func (*AbortTaskRequest) GetBody added in v0.49.0 

func (x *AbortTaskRequest) GetBody() *AbortTaskRequest_Body

func (*AbortTaskRequest) GetSignature added in v0.49.0 

func (x *AbortTaskRequest) GetSignature() *Signature

func (*AbortTaskRequest) MarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AbortTaskRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AbortTaskRequest) ReadSignedData added in v0.49.0 

func (x *AbortTaskRequest) 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 (*AbortTaskRequest) SetBody added in v0.49.0 

func (x *AbortTaskRequest) SetBody(v *AbortTaskRequest_Body)

func (*AbortTaskRequest) SetSignature added in v0.49.0 

func (x *AbortTaskRequest) SetSignature(v *Signature)

func (*AbortTaskRequest) SignedDataSize added in v0.49.0 

func (x *AbortTaskRequest) 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 (*AbortTaskRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*AbortTaskRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AbortTaskRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AbortTaskRequest_Body added in v0.49.0 

type AbortTaskRequest_Body struct {
	TaskId string `json:"taskId"`
}

func (*AbortTaskRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*AbortTaskRequest_Body) GetTaskId added in v0.49.0 

func (x *AbortTaskRequest_Body) GetTaskId() string

func (*AbortTaskRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AbortTaskRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AbortTaskRequest_Body) SetTaskId added in v0.49.0 

func (x *AbortTaskRequest_Body) SetTaskId(v string)

func (*AbortTaskRequest_Body) StableSize added in v0.49.0 

func (x *AbortTaskRequest_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 (*AbortTaskRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AbortTaskRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AbortTaskResponse added in v0.49.0 

type AbortTaskResponse struct {
	Body      *AbortTaskResponse_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func (*AbortTaskResponse) EmitProtobuf added in v0.49.0 

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

func (*AbortTaskResponse) GetBody added in v0.49.0 

func (x *AbortTaskResponse) GetBody() *AbortTaskResponse_Body

func (*AbortTaskResponse) GetSignature added in v0.49.0 

func (x *AbortTaskResponse) GetSignature() *Signature

func (*AbortTaskResponse) MarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AbortTaskResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AbortTaskResponse) ReadSignedData added in v0.49.0 

func (x *AbortTaskResponse) 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 (*AbortTaskResponse) SetBody added in v0.49.0 

func (x *AbortTaskResponse) SetBody(v *AbortTaskResponse_Body)

func (*AbortTaskResponse) SetSignature added in v0.49.0 

func (x *AbortTaskResponse) SetSignature(v *Signature)

func (*AbortTaskResponse) SignedDataSize added in v0.49.0 

func (x *AbortTaskResponse) 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 (*AbortTaskResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*AbortTaskResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AbortTaskResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AbortTaskResponse_Body added in v0.49.0 

type AbortTaskResponse_Body struct {
}

func (*AbortTaskResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*AbortTaskResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AbortTaskResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AbortTaskResponse_Body) StableSize added in v0.49.0 

func (x *AbortTaskResponse_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 (*AbortTaskResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*AbortTaskResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AbortTaskResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddByPathRequest 

type AddByPathRequest struct {
	// Request body.
	Body *AddByPathRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// Attribute to build path with. Default: "FileName".
	PathAttribute string `json:"pathAttribute"`
	// List of path components.
	Path []string `json:"path"`
	// Node meta-information.
	Meta []KeyValue `json:"meta"`
	// Bearer token in V2 format.
	BearerToken []byte `json:"bearerToken"`
	// When set to true operation store locally and on all container nodes.
	// By default save locally and on one remote container node.
	Sync bool `json:"sync"`
	// `copies_number` is a placement vector [c1, c2, …, cN] where ci specifies
	// the number of object copies placed in the i-th policy selector, and cL specifies the
	// number of copies on the local node (L - the local selector).
	//
	// Constraints:
	//   - ci >= 0 for all i;
	//   - at least one ci must be positive -zero vector is invalid);
	//   - ci <= si, where si is the number of nodes in the i-th selector;
	//   - cL >= 1: a local copy is mandatory. If the request arrives at a
	//     non-container node or at a node belonging to a selector with ci = 0,
	//     the node MUST forward the request to any node of a selector where
	//     ci > 0.
	//
	// Partial failure is not fatal. If only the local copy is created the operation is still considered successful:
	//   - tree service provides eventual consistency and background;
	//   - synchronisation will deliver the operation log to the remaining nodes.
	CopiesNumber []uint32 `json:"copiesNumber"`
}

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) GetCopiesNumber added in v0.49.0 

func (x *AddByPathRequest_Body) GetCopiesNumber() []uint32

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) GetSync added in v0.46.0 

func (x *AddByPathRequest_Body) GetSync() bool

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) SetCopiesNumber added in v0.49.0 

func (x *AddByPathRequest_Body) SetCopiesNumber(v []uint32)

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) SetSync added in v0.46.0 

func (x *AddByPathRequest_Body) SetSync(v bool)

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 {
	// Response body.
	Body *AddByPathResponse_Body `json:"body"`
	// Response signature.
	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 {
	// List of all created nodes. The first one is the leaf.
	Nodes []uint64 `json:"nodes"`
	// ID of the parent node where new nodes were attached.
	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 AddOpLogLockRequest added in v0.49.0 

type AddOpLogLockRequest struct {
	Body      *AddOpLogLockRequest_Body `json:"body"`
	Signature *Signature                `json:"signature"`
}

func (*AddOpLogLockRequest) EmitProtobuf added in v0.49.0 

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

func (*AddOpLogLockRequest) GetBody added in v0.49.0 

func (x *AddOpLogLockRequest) GetBody() *AddOpLogLockRequest_Body

func (*AddOpLogLockRequest) GetSignature added in v0.49.0 

func (x *AddOpLogLockRequest) GetSignature() *Signature

func (*AddOpLogLockRequest) MarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AddOpLogLockRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddOpLogLockRequest) ReadSignedData added in v0.49.0 

func (x *AddOpLogLockRequest) 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 (*AddOpLogLockRequest) SetBody added in v0.49.0 

func (x *AddOpLogLockRequest) SetBody(v *AddOpLogLockRequest_Body)

func (*AddOpLogLockRequest) SetSignature added in v0.49.0 

func (x *AddOpLogLockRequest) SetSignature(v *Signature)

func (*AddOpLogLockRequest) SignedDataSize added in v0.49.0 

func (x *AddOpLogLockRequest) 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 (*AddOpLogLockRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*AddOpLogLockRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddOpLogLockRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddOpLogLockRequest_Body added in v0.49.0 

type AddOpLogLockRequest_Body struct {
	ContainerId []byte     `json:"containerId"`
	TreeId      string     `json:"treeId"`
	Lock        *OpLogLock `json:"lock"`
}

func (*AddOpLogLockRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*AddOpLogLockRequest_Body) GetContainerId added in v0.49.0 

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

func (*AddOpLogLockRequest_Body) GetLock added in v0.49.0 

func (x *AddOpLogLockRequest_Body) GetLock() *OpLogLock

func (*AddOpLogLockRequest_Body) GetTreeId added in v0.49.0 

func (x *AddOpLogLockRequest_Body) GetTreeId() string

func (*AddOpLogLockRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AddOpLogLockRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddOpLogLockRequest_Body) SetContainerId added in v0.49.0 

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

func (*AddOpLogLockRequest_Body) SetLock added in v0.49.0 

func (x *AddOpLogLockRequest_Body) SetLock(v *OpLogLock)

func (*AddOpLogLockRequest_Body) SetTreeId added in v0.49.0 

func (x *AddOpLogLockRequest_Body) SetTreeId(v string)

func (*AddOpLogLockRequest_Body) StableSize added in v0.49.0 

func (x *AddOpLogLockRequest_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 (*AddOpLogLockRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddOpLogLockRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddOpLogLockResponse added in v0.49.0 

type AddOpLogLockResponse struct {
	Body      *AddOpLogLockResponse_Body `json:"body"`
	Signature *Signature                 `json:"signature"`
}

func (*AddOpLogLockResponse) EmitProtobuf added in v0.49.0 

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

func (*AddOpLogLockResponse) GetBody added in v0.49.0 

func (x *AddOpLogLockResponse) GetBody() *AddOpLogLockResponse_Body

func (*AddOpLogLockResponse) GetSignature added in v0.49.0 

func (x *AddOpLogLockResponse) GetSignature() *Signature

func (*AddOpLogLockResponse) MarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AddOpLogLockResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddOpLogLockResponse) ReadSignedData added in v0.49.0 

func (x *AddOpLogLockResponse) 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 (*AddOpLogLockResponse) SetBody added in v0.49.0 

func (x *AddOpLogLockResponse) SetBody(v *AddOpLogLockResponse_Body)

func (*AddOpLogLockResponse) SetSignature added in v0.49.0 

func (x *AddOpLogLockResponse) SetSignature(v *Signature)

func (*AddOpLogLockResponse) SignedDataSize added in v0.49.0 

func (x *AddOpLogLockResponse) 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 (*AddOpLogLockResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*AddOpLogLockResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddOpLogLockResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddOpLogLockResponse_Body added in v0.49.0 

type AddOpLogLockResponse_Body struct {
}

func (*AddOpLogLockResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*AddOpLogLockResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*AddOpLogLockResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*AddOpLogLockResponse_Body) StableSize added in v0.49.0 

func (x *AddOpLogLockResponse_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 (*AddOpLogLockResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*AddOpLogLockResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*AddOpLogLockResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type AddRequest 

type AddRequest struct {
	// Request body.
	Body *AddRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// ID of the parent to attach node to.
	ParentId uint64 `json:"parentId"`
	// Key-Value pairs with meta information.
	Meta []KeyValue `json:"meta"`
	// Bearer token in V2 format.
	BearerToken []byte `json:"bearerToken"`
	// When set to true operation store locally and on all container nodes.
	// By default save locally and on one remote container node.
	Sync bool `json:"sync"`
	// `copies_number` is a placement vector [c1, c2, …, cN] where ci specifies
	// the number of object copies placed in the i-th policy selector, and cL specifies the
	// number of copies on the local node (L - the local selector).
	//
	// Constraints:
	//   - ci >= 0 for all i;
	//   - at least one ci must be positive -zero vector is invalid);
	//   - ci <= si, where si is the number of nodes in the i-th selector;
	//   - cL >= 1: a local copy is mandatory. If the request arrives at a
	//     non-container node or at a node belonging to a selector with ci = 0,
	//     the node MUST forward the request to any node of a selector where
	//     ci > 0.
	//
	// Partial failure is not fatal. If only the local copy is created the operation is still considered successful:
	//   - tree service provides eventual consistency and background;
	//   - synchronisation will deliver the operation log to the remaining nodes.
	CopiesNumber []uint32 `json:"copiesNumber"`
}

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) GetCopiesNumber added in v0.49.0 

func (x *AddRequest_Body) GetCopiesNumber() []uint32

func (*AddRequest_Body) GetMeta 

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

func (*AddRequest_Body) GetParentId 

func (x *AddRequest_Body) GetParentId() uint64

func (*AddRequest_Body) GetSync added in v0.46.0 

func (x *AddRequest_Body) GetSync() bool

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) SetCopiesNumber added in v0.49.0 

func (x *AddRequest_Body) SetCopiesNumber(v []uint32)

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) SetSync added in v0.46.0 

func (x *AddRequest_Body) SetSync(v bool)

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 {
	// Response body.
	Body *AddResponse_Body `json:"body"`
	// Response signature.
	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 {
	// ID of the created node.
	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 AdjustIOTag added in v0.45.0 

type AdjustIOTag interface {
	AdjustIncomingTag(ctx context.Context, requestSignPublicKey []byte) context.Context
}

type ApplyRequest 

type ApplyRequest struct {
	// Request body.
	Body *ApplyRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// Operation to be applied.
	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 {
	// Response body.
	Body *ApplyResponse_Body `json:"body"`
	// Response signature.
	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 ClientCacheConfig added in v0.47.5 

type ClientCacheConfig struct {
	Size                 int
	ClientDialTimeout    time.Duration
	MinReconnectInterval time.Duration
	MaxReconnectInterval time.Duration
	ReconnectIntervalInc time.Duration
	ClientWaitTimeout    time.Duration
	Metrics              ClientMetrics
}

type ClientMetrics added in v0.48.0 

type ClientMetrics interface {
	IncFailedHealthcheckCounter(service, address string)
}

type ContainerSource 

type ContainerSource interface {
	container.Source

	DeletionInfo(ctx context.Context, cid 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(ctx context.Context) ([]cid.ID, error)
}

type DropRequest added in v0.49.0 

type DropRequest struct {
	Body      *DropRequest_Body `json:"body"`
	Signature *Signature        `json:"signature"`
}

func (*DropRequest) EmitProtobuf added in v0.49.0 

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

func (*DropRequest) GetBody added in v0.49.0 

func (x *DropRequest) GetBody() *DropRequest_Body

func (*DropRequest) GetSignature added in v0.49.0 

func (x *DropRequest) GetSignature() *Signature

func (*DropRequest) MarshalEasyJSON added in v0.49.0 

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

func (*DropRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*DropRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*DropRequest) ReadSignedData added in v0.49.0 

func (x *DropRequest) 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 (*DropRequest) SetBody added in v0.49.0 

func (x *DropRequest) SetBody(v *DropRequest_Body)

func (*DropRequest) SetSignature added in v0.49.0 

func (x *DropRequest) SetSignature(v *Signature)

func (*DropRequest) SignedDataSize added in v0.49.0 

func (x *DropRequest) 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 (*DropRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*DropRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*DropRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*DropRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type DropRequest_Body added in v0.49.0 

type DropRequest_Body struct {
	ContainerId []byte `json:"containerId"`
	TreeId      string `json:"treeId"`
}

func (*DropRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*DropRequest_Body) GetContainerId added in v0.49.0 

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

func (*DropRequest_Body) GetTreeId added in v0.49.0 

func (x *DropRequest_Body) GetTreeId() string

func (*DropRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*DropRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*DropRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*DropRequest_Body) SetContainerId added in v0.49.0 

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

func (*DropRequest_Body) SetTreeId added in v0.49.0 

func (x *DropRequest_Body) SetTreeId(v string)

func (*DropRequest_Body) StableSize added in v0.49.0 

func (x *DropRequest_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 (*DropRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*DropRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*DropRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type DropResponse added in v0.49.0 

type DropResponse struct {
	Body      *DropResponse_Body `json:"body"`
	Signature *Signature         `json:"signature"`
}

func (*DropResponse) EmitProtobuf added in v0.49.0 

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

func (*DropResponse) GetBody added in v0.49.0 

func (x *DropResponse) GetBody() *DropResponse_Body

func (*DropResponse) GetSignature added in v0.49.0 

func (x *DropResponse) GetSignature() *Signature

func (*DropResponse) MarshalEasyJSON added in v0.49.0 

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

func (*DropResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*DropResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*DropResponse) ReadSignedData added in v0.49.0 

func (x *DropResponse) 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 (*DropResponse) SetBody added in v0.49.0 

func (x *DropResponse) SetBody(v *DropResponse_Body)

func (*DropResponse) SetSignature added in v0.49.0 

func (x *DropResponse) SetSignature(v *Signature)

func (*DropResponse) SignedDataSize added in v0.49.0 

func (x *DropResponse) 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 (*DropResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*DropResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*DropResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*DropResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type DropResponse_Body added in v0.49.0 

type DropResponse_Body struct {
}

func (*DropResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*DropResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*DropResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*DropResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*DropResponse_Body) StableSize added in v0.49.0 

func (x *DropResponse_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 (*DropResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*DropResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*DropResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type GetNodeByPathRequest 

type GetNodeByPathRequest struct {
	// Request body.
	Body *GetNodeByPathRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// Attribute to build path with. Default: "FileName".
	PathAttribute string `json:"pathAttribute"`
	// List of path components.
	Path []string `json:"path"`
	// List of attributes to include in response.
	Attributes []string `json:"attributes"`
	// Flag to return only the latest version of node.
	LatestOnly bool `json:"latestOnly"`
	// Flag to return all stored attributes.
	AllAttributes bool `json:"allAttributes"`
	// Bearer token in V2 format.
	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 {
	// Response body.
	Body *GetNodeByPathResponse_Body `json:"body"`
	// Response signature.
	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 {
	// List of nodes stored by path.
	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 {
	// Node ID.
	NodeId uint64 `json:"nodeId"`
	// Timestamp of the last operation with the node.
	Timestamp uint64 `json:"timestamp"`
	// Node meta-information.
	Meta []KeyValue `json:"meta"`
	// Parent ID.
	ParentId uint64 `json:"parentId"`
}

Information about a single tree node.

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 {
	// Request body.
	Body *GetOpLogRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// Starting height to return logs from.
	Height uint64 `json:"height"`
	// Amount of operations to return.
	Count uint64 `json:"count"`
	// If true, the op-logs will be streamed from the local node even if the node is not the container node.
	ForceLocal bool `json:"forceLocal"`
}

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) GetForceLocal added in v0.48.0 

func (x *GetOpLogRequest_Body) GetForceLocal() bool

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) SetForceLocal added in v0.48.0 

func (x *GetOpLogRequest_Body) SetForceLocal(v bool)

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 {
	// Response body.
	Body *GetOpLogResponse_Body `json:"body"`
	// Response signature.
	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 on a tree.
	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 {
	// Request body.
	Body *GetSubTreeRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// IDs of the root nodes of a subtree forest.
	RootId []uint64 `json:"rootId"`
	// Optional depth of the traversal. Zero means return only root.
	// Maximum depth is 10.
	Depth uint32 `json:"depth"`
	// Bearer token in V2 format.
	BearerToken []byte `json:"bearerToken"`
	// Result ordering.
	OrderBy   *GetSubTreeRequest_Body_Order `json:"orderBy"`
	StartFrom []string                      `json:"startFrom"`
}

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) GetStartFrom added in v0.48.0 

func (x *GetSubTreeRequest_Body) GetStartFrom() []string

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) SetStartFrom added in v0.48.0 

func (x *GetSubTreeRequest_Body) SetStartFrom(v []string)

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 {
	// Response body.
	Body *GetSubTreeResponse_Body `json:"body"`
	// Response signature.
	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 {
	// ID of the node.
	NodeId []uint64 `json:"nodeId"`
	// ID of the parent.
	ParentId []uint64 `json:"parentId"`
	// Time node was first added to a tree.
	Timestamp []uint64 `json:"timestamp"`
	// Node meta-information.
	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 {
	// Request body.
	Body *HealthcheckRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Response body.
	Body *HealthcheckResponse_Body `json:"body"`
	// Response signature.
	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 {
	// Attribute name.
	Key string `json:"key"`
	// Attribute value.
	Value []byte `json:"value"`
}

KeyValue represents key-value pair attached to an object.

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 ListOpLogLocksRequest added in v0.49.0 

type ListOpLogLocksRequest struct {
	Body      *ListOpLogLocksRequest_Body `json:"body"`
	Signature *Signature                  `json:"signature"`
}

func (*ListOpLogLocksRequest) EmitProtobuf added in v0.49.0 

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

func (*ListOpLogLocksRequest) GetBody added in v0.49.0 

func (x *ListOpLogLocksRequest) GetBody() *ListOpLogLocksRequest_Body

func (*ListOpLogLocksRequest) GetSignature added in v0.49.0 

func (x *ListOpLogLocksRequest) GetSignature() *Signature

func (*ListOpLogLocksRequest) MarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ListOpLogLocksRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ListOpLogLocksRequest) ReadSignedData added in v0.49.0 

func (x *ListOpLogLocksRequest) 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 (*ListOpLogLocksRequest) SetBody added in v0.49.0 

func (x *ListOpLogLocksRequest) SetBody(v *ListOpLogLocksRequest_Body)

func (*ListOpLogLocksRequest) SetSignature added in v0.49.0 

func (x *ListOpLogLocksRequest) SetSignature(v *Signature)

func (*ListOpLogLocksRequest) SignedDataSize added in v0.49.0 

func (x *ListOpLogLocksRequest) 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 (*ListOpLogLocksRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*ListOpLogLocksRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ListOpLogLocksRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ListOpLogLocksRequest_Body added in v0.49.0 

type ListOpLogLocksRequest_Body struct {
	ContainerId []byte `json:"containerId"`
	TreeId      string `json:"treeId"`
}

func (*ListOpLogLocksRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*ListOpLogLocksRequest_Body) GetContainerId added in v0.49.0 

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

func (*ListOpLogLocksRequest_Body) GetTreeId added in v0.49.0 

func (x *ListOpLogLocksRequest_Body) GetTreeId() string

func (*ListOpLogLocksRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ListOpLogLocksRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ListOpLogLocksRequest_Body) SetContainerId added in v0.49.0 

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

func (*ListOpLogLocksRequest_Body) SetTreeId added in v0.49.0 

func (x *ListOpLogLocksRequest_Body) SetTreeId(v string)

func (*ListOpLogLocksRequest_Body) StableSize added in v0.49.0 

func (x *ListOpLogLocksRequest_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 (*ListOpLogLocksRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ListOpLogLocksRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ListOpLogLocksResponse added in v0.49.0 

type ListOpLogLocksResponse struct {
	Body      *ListOpLogLocksResponse_Body `json:"body"`
	Signature *Signature                   `json:"signature"`
}

func (*ListOpLogLocksResponse) EmitProtobuf added in v0.49.0 

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

func (*ListOpLogLocksResponse) GetBody added in v0.49.0 

func (x *ListOpLogLocksResponse) GetBody() *ListOpLogLocksResponse_Body

func (*ListOpLogLocksResponse) GetSignature added in v0.49.0 

func (x *ListOpLogLocksResponse) GetSignature() *Signature

func (*ListOpLogLocksResponse) MarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ListOpLogLocksResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ListOpLogLocksResponse) ReadSignedData added in v0.49.0 

func (x *ListOpLogLocksResponse) 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 (*ListOpLogLocksResponse) SetBody added in v0.49.0 

func (x *ListOpLogLocksResponse) SetBody(v *ListOpLogLocksResponse_Body)

func (*ListOpLogLocksResponse) SetSignature added in v0.49.0 

func (x *ListOpLogLocksResponse) SetSignature(v *Signature)

func (*ListOpLogLocksResponse) SignedDataSize added in v0.49.0 

func (x *ListOpLogLocksResponse) 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 (*ListOpLogLocksResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*ListOpLogLocksResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ListOpLogLocksResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ListOpLogLocksResponse_Body added in v0.49.0 

type ListOpLogLocksResponse_Body struct {
	Locks []OpLogLock `json:"locks"`
}

func (*ListOpLogLocksResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*ListOpLogLocksResponse_Body) GetLocks added in v0.49.0 

func (x *ListOpLogLocksResponse_Body) GetLocks() []OpLogLock

func (*ListOpLogLocksResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ListOpLogLocksResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ListOpLogLocksResponse_Body) SetLocks added in v0.49.0 

func (x *ListOpLogLocksResponse_Body) SetLocks(v []OpLogLock)

func (*ListOpLogLocksResponse_Body) StableSize added in v0.49.0 

func (x *ListOpLogLocksResponse_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 (*ListOpLogLocksResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*ListOpLogLocksResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ListOpLogLocksResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type LocalOperationError added in v0.46.2 

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

LocalOperationError is returned when local operation failed.

func (*LocalOperationError) Error added in v0.46.2 

func (e *LocalOperationError) Error() string

func (*LocalOperationError) Unwrap added in v0.46.2 

func (e *LocalOperationError) Unwrap() error

type LogMove 

type LogMove struct {
	// ID of the parent node.
	ParentId uint64 `json:"parentID"`
	// Node meta information, including operation timestamp.
	Meta []byte `json:"meta"`
	// ID of the node to move.
	ChildId uint64 `json:"childID"`
}

LogMove represents log-entry for a single move operation.

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)
	IncSyncTasksCompleted(bool)
	AddOperation(string, string)
	IncReplication(string, string)
}

type MoveRequest 

type MoveRequest struct {
	// Request body.
	Body *MoveRequest_Body `json:"body"`
	// Request signature.
	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 {
	// TODO import frost.fs.refs.ContainerID directly.
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// ID of the new parent.
	ParentId uint64 `json:"parentId"`
	// ID of the node to move.
	NodeId uint64 `json:"nodeId"`
	// Node meta-information.
	Meta []KeyValue `json:"meta"`
	// Bearer token in V2 format.
	BearerToken []byte `json:"bearerToken"`
	// When set to true operation store locally and on all container nodes.
	// By default save locally and on one remote container node.
	Sync bool `json:"sync"`
	// `copies_number` is a placement vector [c1, c2, …, cN] where ci specifies
	// the number of object copies placed in the i-th policy selector, and cL specifies the
	// number of copies on the local node (L - the local selector).
	//
	// Constraints:
	//   - ci >= 0 for all i;
	//   - at least one ci must be positive -zero vector is invalid);
	//   - ci <= si, where si is the number of nodes in the i-th selector;
	//   - cL >= 1: a local copy is mandatory. If the request arrives at a
	//     non-container node or at a node belonging to a selector with ci = 0,
	//     the node MUST forward the request to any node of a selector where
	//     ci > 0.
	//
	// Partial failure is not fatal. If only the local copy is created the operation is still considered successful:
	//   - tree service provides eventual consistency and background;
	//   - synchronisation will deliver the operation log to the remaining nodes.
	CopiesNumber []uint32 `json:"copiesNumber"`
}

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) GetCopiesNumber added in v0.49.0 

func (x *MoveRequest_Body) GetCopiesNumber() []uint32

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) GetSync added in v0.46.0 

func (x *MoveRequest_Body) GetSync() bool

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) SetCopiesNumber added in v0.49.0 

func (x *MoveRequest_Body) SetCopiesNumber(v []uint32)

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) SetSync added in v0.46.0 

func (x *MoveRequest_Body) SetSync(v bool)

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 {
	// Response body.
	Body *MoveResponse_Body `json:"body"`
	// Response signature.
	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 OpLogHashRequest added in v0.49.0 

type OpLogHashRequest struct {
	Body      *OpLogHashRequest_Body `json:"body"`
	Signature *Signature             `json:"signature"`
}

func (*OpLogHashRequest) EmitProtobuf added in v0.49.0 

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

func (*OpLogHashRequest) GetBody added in v0.49.0 

func (x *OpLogHashRequest) GetBody() *OpLogHashRequest_Body

func (*OpLogHashRequest) GetSignature added in v0.49.0 

func (x *OpLogHashRequest) GetSignature() *Signature

func (*OpLogHashRequest) MarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*OpLogHashRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*OpLogHashRequest) ReadSignedData added in v0.49.0 

func (x *OpLogHashRequest) 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 (*OpLogHashRequest) SetBody added in v0.49.0 

func (x *OpLogHashRequest) SetBody(v *OpLogHashRequest_Body)

func (*OpLogHashRequest) SetSignature added in v0.49.0 

func (x *OpLogHashRequest) SetSignature(v *Signature)

func (*OpLogHashRequest) SignedDataSize added in v0.49.0 

func (x *OpLogHashRequest) 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 (*OpLogHashRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*OpLogHashRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*OpLogHashRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type OpLogHashRequest_Body added in v0.49.0 

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

func (*OpLogHashRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*OpLogHashRequest_Body) GetContainerId added in v0.49.0 

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

func (*OpLogHashRequest_Body) GetHeight added in v0.49.0 

func (x *OpLogHashRequest_Body) GetHeight() uint64

func (*OpLogHashRequest_Body) GetTreeId added in v0.49.0 

func (x *OpLogHashRequest_Body) GetTreeId() string

func (*OpLogHashRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*OpLogHashRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*OpLogHashRequest_Body) SetContainerId added in v0.49.0 

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

func (*OpLogHashRequest_Body) SetHeight added in v0.49.0 

func (x *OpLogHashRequest_Body) SetHeight(v uint64)

func (*OpLogHashRequest_Body) SetTreeId added in v0.49.0 

func (x *OpLogHashRequest_Body) SetTreeId(v string)

func (*OpLogHashRequest_Body) StableSize added in v0.49.0 

func (x *OpLogHashRequest_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 (*OpLogHashRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*OpLogHashRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type OpLogHashResponse added in v0.49.0 

type OpLogHashResponse struct {
	Body      *OpLogHashResponse_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func (*OpLogHashResponse) EmitProtobuf added in v0.49.0 

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

func (*OpLogHashResponse) GetBody added in v0.49.0 

func (x *OpLogHashResponse) GetBody() *OpLogHashResponse_Body

func (*OpLogHashResponse) GetSignature added in v0.49.0 

func (x *OpLogHashResponse) GetSignature() *Signature

func (*OpLogHashResponse) MarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*OpLogHashResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*OpLogHashResponse) ReadSignedData added in v0.49.0 

func (x *OpLogHashResponse) 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 (*OpLogHashResponse) SetBody added in v0.49.0 

func (x *OpLogHashResponse) SetBody(v *OpLogHashResponse_Body)

func (*OpLogHashResponse) SetSignature added in v0.49.0 

func (x *OpLogHashResponse) SetSignature(v *Signature)

func (*OpLogHashResponse) SignedDataSize added in v0.49.0 

func (x *OpLogHashResponse) 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 (*OpLogHashResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*OpLogHashResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*OpLogHashResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type OpLogHashResponse_Body added in v0.49.0 

type OpLogHashResponse_Body struct {
	Hash []byte `json:"hash"`
}

func (*OpLogHashResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*OpLogHashResponse_Body) GetHash added in v0.49.0 

func (x *OpLogHashResponse_Body) GetHash() []byte

func (*OpLogHashResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*OpLogHashResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*OpLogHashResponse_Body) SetHash added in v0.49.0 

func (x *OpLogHashResponse_Body) SetHash(v []byte)

func (*OpLogHashResponse_Body) StableSize added in v0.49.0 

func (x *OpLogHashResponse_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 (*OpLogHashResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*OpLogHashResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*OpLogHashResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type OpLogLock added in v0.49.0 

type OpLogLock struct {
	Height uint64         `json:"height"`
	Type   OpLogLock_Type `json:"type"`
}

func (*OpLogLock) EmitProtobuf added in v0.49.0 

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

func (*OpLogLock) GetHeight added in v0.49.0 

func (x *OpLogLock) GetHeight() uint64

func (*OpLogLock) GetType added in v0.49.0 

func (x *OpLogLock) GetType() OpLogLock_Type

func (*OpLogLock) MarshalEasyJSON added in v0.49.0 

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

func (*OpLogLock) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*OpLogLock) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*OpLogLock) SetHeight added in v0.49.0 

func (x *OpLogLock) SetHeight(v uint64)

func (*OpLogLock) SetType added in v0.49.0 

func (x *OpLogLock) SetType(v OpLogLock_Type)

func (*OpLogLock) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*OpLogLock) UnmarshalEasyJSON added in v0.49.0 

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

func (*OpLogLock) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*OpLogLock) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type OpLogLock_Type added in v0.49.0 

type OpLogLock_Type int32
const (
	OpLogLock_UNDEFINED OpLogLock_Type = 0
	OpLogLock_PREFIX    OpLogLock_Type = 1
	OpLogLock_SUFFIX    OpLogLock_Type = 2
)

func (*OpLogLock_Type) FromString added in v0.49.0 

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

func (OpLogLock_Type) String added in v0.49.0 

func (x OpLogLock_Type) String() string

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 WithClientCacheSize added in v0.47.5 

func WithClientCacheSize(v int) Option

func WithClientDialTimeout added in v0.47.5 

func WithClientDialTimeout(t time.Duration) Option

func WithClientMaxReconnectInterval added in v0.47.5 

func WithClientMaxReconnectInterval(v time.Duration) Option

func WithClientMetrics added in v0.48.0 

func WithClientMetrics(m ClientMetrics) Option

func WithClientMinReconnectInterval added in v0.47.5 

func WithClientMinReconnectInterval(v time.Duration) Option

func WithClientReconnectIntervalInc added in v0.47.5 

func WithClientReconnectIntervalInc(v time.Duration) Option

func WithClientWaitTimeout added in v0.47.5 

func WithClientWaitTimeout(v time.Duration) Option

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 WithDialerSource added in v0.44.0 

func WithDialerSource(ds *net.DialerSource) Option

func WithForesterBatchSize added in v0.48.0 

func WithForesterBatchSize(v int) Option

func WithForesterMaxDuration added in v0.48.0 

func WithForesterMaxDuration(d time.Duration) Option

func WithFrostfsidSubjectProvider added in v0.39.0 

func WithFrostfsidSubjectProvider(provider frostfsidcore.Source) Option

func WithLastSyncHeightLifetime added in v0.48.0 

func WithLastSyncHeightLifetime(d time.Duration) Option

func WithLocalApplyTimeout added in v0.48.0 

func WithLocalApplyTimeout(t time.Duration) 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 WithOnStateChangedCallback added in v0.48.0 

func WithOnStateChangedCallback(cb func()) 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 WithScheduledSyncWorkerPoolSize added in v0.48.0 

func WithScheduledSyncWorkerPoolSize(v int) Option

func WithStorage 

func WithStorage(s engine.ForestEngine) Option

WithStorage sets tree storage for a service.

func WithSubTreeBatchSize added in v0.48.0 

func WithSubTreeBatchSize(size int) Option

func WithSyncBatchSize added in v0.44.0 

func WithSyncBatchSize(n int) Option

func WithSyncDisabled added in v0.45.0 

func WithSyncDisabled(d bool) Option

func WithSyncMaxDuration added in v0.47.8 

func WithSyncMaxDuration(d time.Duration) Option

func WithSyncRequestTimeout added in v0.47.11 

func WithSyncRequestTimeout(t time.Duration) Option

func WithSyncWorkerCount added in v0.46.9 

func WithSyncWorkerCount(n int) Option

func WithTaskScheduler added in v0.49.0 

func WithTaskScheduler(scheduler *taskqueue.Scheduler) Option

func WithWaitSyncCompleteOnStartup added in v0.46.4 

func WithWaitSyncCompleteOnStartup(b bool) Option

type RemoveOpLogLockRequest added in v0.49.0 

type RemoveOpLogLockRequest struct {
	Body      *RemoveOpLogLockRequest_Body `json:"body"`
	Signature *Signature                   `json:"signature"`
}

func (*RemoveOpLogLockRequest) EmitProtobuf added in v0.49.0 

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

func (*RemoveOpLogLockRequest) GetBody added in v0.49.0 

func (x *RemoveOpLogLockRequest) GetBody() *RemoveOpLogLockRequest_Body

func (*RemoveOpLogLockRequest) GetSignature added in v0.49.0 

func (x *RemoveOpLogLockRequest) GetSignature() *Signature

func (*RemoveOpLogLockRequest) MarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*RemoveOpLogLockRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveOpLogLockRequest) ReadSignedData added in v0.49.0 

func (x *RemoveOpLogLockRequest) 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 (*RemoveOpLogLockRequest) SetBody added in v0.49.0 

func (x *RemoveOpLogLockRequest) SetBody(v *RemoveOpLogLockRequest_Body)

func (*RemoveOpLogLockRequest) SetSignature added in v0.49.0 

func (x *RemoveOpLogLockRequest) SetSignature(v *Signature)

func (*RemoveOpLogLockRequest) SignedDataSize added in v0.49.0 

func (x *RemoveOpLogLockRequest) 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 (*RemoveOpLogLockRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*RemoveOpLogLockRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveOpLogLockRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveOpLogLockRequest_Body added in v0.49.0 

type RemoveOpLogLockRequest_Body struct {
	ContainerId []byte     `json:"containerId"`
	TreeId      string     `json:"treeId"`
	Lock        *OpLogLock `json:"lock"`
}

func (*RemoveOpLogLockRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*RemoveOpLogLockRequest_Body) GetContainerId added in v0.49.0 

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

func (*RemoveOpLogLockRequest_Body) GetLock added in v0.49.0 

func (x *RemoveOpLogLockRequest_Body) GetLock() *OpLogLock

func (*RemoveOpLogLockRequest_Body) GetTreeId added in v0.49.0 

func (x *RemoveOpLogLockRequest_Body) GetTreeId() string

func (*RemoveOpLogLockRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*RemoveOpLogLockRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveOpLogLockRequest_Body) SetContainerId added in v0.49.0 

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

func (*RemoveOpLogLockRequest_Body) SetLock added in v0.49.0 

func (x *RemoveOpLogLockRequest_Body) SetLock(v *OpLogLock)

func (*RemoveOpLogLockRequest_Body) SetTreeId added in v0.49.0 

func (x *RemoveOpLogLockRequest_Body) SetTreeId(v string)

func (*RemoveOpLogLockRequest_Body) StableSize added in v0.49.0 

func (x *RemoveOpLogLockRequest_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 (*RemoveOpLogLockRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveOpLogLockRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveOpLogLockResponse added in v0.49.0 

type RemoveOpLogLockResponse struct {
	Body      *RemoveOpLogLockResponse_Body `json:"body"`
	Signature *Signature                    `json:"signature"`
}

func (*RemoveOpLogLockResponse) EmitProtobuf added in v0.49.0 

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

func (*RemoveOpLogLockResponse) GetBody added in v0.49.0 

func (x *RemoveOpLogLockResponse) GetBody() *RemoveOpLogLockResponse_Body

func (*RemoveOpLogLockResponse) GetSignature added in v0.49.0 

func (x *RemoveOpLogLockResponse) GetSignature() *Signature

func (*RemoveOpLogLockResponse) MarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*RemoveOpLogLockResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveOpLogLockResponse) ReadSignedData added in v0.49.0 

func (x *RemoveOpLogLockResponse) 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 (*RemoveOpLogLockResponse) SetBody added in v0.49.0 

func (x *RemoveOpLogLockResponse) SetBody(v *RemoveOpLogLockResponse_Body)

func (*RemoveOpLogLockResponse) SetSignature added in v0.49.0 

func (x *RemoveOpLogLockResponse) SetSignature(v *Signature)

func (*RemoveOpLogLockResponse) SignedDataSize added in v0.49.0 

func (x *RemoveOpLogLockResponse) 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 (*RemoveOpLogLockResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*RemoveOpLogLockResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveOpLogLockResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveOpLogLockResponse_Body added in v0.49.0 

type RemoveOpLogLockResponse_Body struct {
}

func (*RemoveOpLogLockResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*RemoveOpLogLockResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*RemoveOpLogLockResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveOpLogLockResponse_Body) StableSize added in v0.49.0 

func (x *RemoveOpLogLockResponse_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 (*RemoveOpLogLockResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*RemoveOpLogLockResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveOpLogLockResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveRequest 

type RemoveRequest struct {
	// Request body.
	Body *RemoveRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// ID of the node to remove.
	NodeId uint64 `json:"nodeId"`
	// Bearer token in V2 format.
	BearerToken []byte `json:"bearerToken"`
	// When set to true operation store locally and on all container nodes.
	// By default save locally and on one remote container node.
	Sync bool `json:"sync"`
	// `copies_number` is a placement vector [c1, c2, …, cN] where ci specifies
	// the number of object copies placed in the i-th policy selector, and cL specifies the
	// number of copies on the local node (L - the local selector).
	//
	// Constraints:
	//   - ci >= 0 for all i;
	//   - at least one ci must be positive -zero vector is invalid);
	//   - ci <= si, where si is the number of nodes in the i-th selector;
	//   - cL >= 1: a local copy is mandatory. If the request arrives at a
	//     non-container node or at a node belonging to a selector with ci = 0,
	//     the node MUST forward the request to any node of a selector where
	//     ci > 0.
	//
	// Partial failure is not fatal. If only the local copy is created the operation is still considered successful:
	//   - tree service provides eventual consistency and background;
	//   - synchronisation will deliver the operation log to the remaining nodes.
	CopiesNumber []uint32 `json:"copiesNumber"`
}

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) GetCopiesNumber added in v0.49.0 

func (x *RemoveRequest_Body) GetCopiesNumber() []uint32

func (*RemoveRequest_Body) GetNodeId 

func (x *RemoveRequest_Body) GetNodeId() uint64

func (*RemoveRequest_Body) GetSync added in v0.46.0 

func (x *RemoveRequest_Body) GetSync() bool

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) SetCopiesNumber added in v0.49.0 

func (x *RemoveRequest_Body) SetCopiesNumber(v []uint32)

func (*RemoveRequest_Body) SetNodeId added in v0.43.0 

func (x *RemoveRequest_Body) SetNodeId(v uint64)

func (*RemoveRequest_Body) SetSync added in v0.46.0 

func (x *RemoveRequest_Body) SetSync(v bool)

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 {
	// Response body.
	Body *RemoveResponse_Body `json:"body"`
	// Response signature.
	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 ReplicationError added in v0.46.2 

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

ReplicationError is returned when local operation succeeded, but replication failed.

func (*ReplicationError) Error added in v0.46.2 

func (e *ReplicationError) Error() string

func (*ReplicationError) Unwrap added in v0.46.2 

func (e *ReplicationError) Unwrap() error

type ScheduleSyncRequest added in v0.48.0 

type ScheduleSyncRequest struct {
	// Request body.
	Body *ScheduleSyncRequest_Body `json:"body"`
	// Request signature.
	Signature *Signature `json:"signature"`
}

func (*ScheduleSyncRequest) EmitProtobuf added in v0.48.0 

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

func (*ScheduleSyncRequest) GetBody added in v0.48.0 

func (x *ScheduleSyncRequest) GetBody() *ScheduleSyncRequest_Body

func (*ScheduleSyncRequest) GetSignature added in v0.48.0 

func (x *ScheduleSyncRequest) GetSignature() *Signature

func (*ScheduleSyncRequest) MarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncRequest) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ScheduleSyncRequest) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ScheduleSyncRequest) ReadSignedData added in v0.48.0 

func (x *ScheduleSyncRequest) 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 (*ScheduleSyncRequest) SetBody added in v0.48.0 

func (x *ScheduleSyncRequest) SetBody(v *ScheduleSyncRequest_Body)

func (*ScheduleSyncRequest) SetSignature added in v0.48.0 

func (x *ScheduleSyncRequest) SetSignature(v *Signature)

func (*ScheduleSyncRequest) SignedDataSize added in v0.48.0 

func (x *ScheduleSyncRequest) 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 (*ScheduleSyncRequest) StableSize added in v0.48.0 

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

StableSize returns the size of x in protobuf format.

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

func (*ScheduleSyncRequest) UnmarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncRequest) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ScheduleSyncRequest) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ScheduleSyncRequest_Body added in v0.48.0 

type ScheduleSyncRequest_Body struct {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
	// Public key of the source node for synchronization.
	NodePublicKey []byte `json:"nodePublicKey"`
	// Schedule ID for the synchronization task. This ID is used to avoid duplicate synchronization tasks.
	ScheduleId []byte `json:"scheduleId"`
}

func (*ScheduleSyncRequest_Body) EmitProtobuf added in v0.48.0 

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

func (*ScheduleSyncRequest_Body) GetContainerId added in v0.48.0 

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

func (*ScheduleSyncRequest_Body) GetNodePublicKey added in v0.48.0 

func (x *ScheduleSyncRequest_Body) GetNodePublicKey() []byte

func (*ScheduleSyncRequest_Body) GetScheduleId added in v0.48.0 

func (x *ScheduleSyncRequest_Body) GetScheduleId() []byte

func (*ScheduleSyncRequest_Body) GetTreeId added in v0.48.0 

func (x *ScheduleSyncRequest_Body) GetTreeId() string

func (*ScheduleSyncRequest_Body) MarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncRequest_Body) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ScheduleSyncRequest_Body) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ScheduleSyncRequest_Body) SetContainerId added in v0.48.0 

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

func (*ScheduleSyncRequest_Body) SetNodePublicKey added in v0.48.0 

func (x *ScheduleSyncRequest_Body) SetNodePublicKey(v []byte)

func (*ScheduleSyncRequest_Body) SetScheduleId added in v0.48.0 

func (x *ScheduleSyncRequest_Body) SetScheduleId(v []byte)

func (*ScheduleSyncRequest_Body) SetTreeId added in v0.48.0 

func (x *ScheduleSyncRequest_Body) SetTreeId(v string)

func (*ScheduleSyncRequest_Body) StableSize added in v0.48.0 

func (x *ScheduleSyncRequest_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 (*ScheduleSyncRequest_Body) UnmarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncRequest_Body) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ScheduleSyncRequest_Body) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ScheduleSyncResponse added in v0.48.0 

type ScheduleSyncResponse struct {
	// Response body.
	Body *ScheduleSyncResponse_Body `json:"body"`
	// Response signature.
	Signature *Signature `json:"signature"`
}

func (*ScheduleSyncResponse) EmitProtobuf added in v0.48.0 

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

func (*ScheduleSyncResponse) GetBody added in v0.48.0 

func (x *ScheduleSyncResponse) GetBody() *ScheduleSyncResponse_Body

func (*ScheduleSyncResponse) GetSignature added in v0.48.0 

func (x *ScheduleSyncResponse) GetSignature() *Signature

func (*ScheduleSyncResponse) MarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncResponse) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ScheduleSyncResponse) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ScheduleSyncResponse) ReadSignedData added in v0.48.0 

func (x *ScheduleSyncResponse) 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 (*ScheduleSyncResponse) SetBody added in v0.48.0 

func (x *ScheduleSyncResponse) SetBody(v *ScheduleSyncResponse_Body)

func (*ScheduleSyncResponse) SetSignature added in v0.48.0 

func (x *ScheduleSyncResponse) SetSignature(v *Signature)

func (*ScheduleSyncResponse) SignedDataSize added in v0.48.0 

func (x *ScheduleSyncResponse) 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 (*ScheduleSyncResponse) StableSize added in v0.48.0 

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

StableSize returns the size of x in protobuf format.

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

func (*ScheduleSyncResponse) UnmarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncResponse) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ScheduleSyncResponse) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type ScheduleSyncResponse_Body added in v0.48.0 

type ScheduleSyncResponse_Body struct {
	// Identifier of the created synchronization task.
	TaskId string `json:"taskId"`
}

func (*ScheduleSyncResponse_Body) EmitProtobuf added in v0.48.0 

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

func (*ScheduleSyncResponse_Body) GetTaskId added in v0.48.0 

func (x *ScheduleSyncResponse_Body) GetTaskId() string

func (*ScheduleSyncResponse_Body) MarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncResponse_Body) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*ScheduleSyncResponse_Body) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*ScheduleSyncResponse_Body) SetTaskId added in v0.48.0 

func (x *ScheduleSyncResponse_Body) SetTaskId(v string)

func (*ScheduleSyncResponse_Body) StableSize added in v0.48.0 

func (x *ScheduleSyncResponse_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 (*ScheduleSyncResponse_Body) UnmarshalEasyJSON added in v0.48.0 

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

func (*ScheduleSyncResponse_Body) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*ScheduleSyncResponse_Body) UnmarshalProtobuf added in v0.48.0 

func (x *ScheduleSyncResponse_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) AbortTask added in v0.49.0 

func (s *Service) AbortTask(ctx context.Context, req *AbortTaskRequest) (*AbortTaskResponse, error)

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) AddOpLogLock added in v0.49.0 

func (s *Service) AddOpLogLock(ctx context.Context, req *AddOpLogLockRequest) (*AddOpLogLockResponse, error)

func (*Service) Apply 

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

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

func (*Service) Drop added in v0.49.0 

func (s *Service) Drop(ctx context.Context, req *DropRequest) (*DropResponse, error)

func (*Service) DropAllTrees added in v0.48.0 

func (s *Service) DropAllTrees(ctx context.Context, cid cid.ID) error

DropAllTrees drops all tree for the given container from the database.

func (*Service) DropTree 

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

DropTree drops a tree from the database.

func (*Service) GetLastSyncHeightWithTTL added in v0.48.0 

func (s *Service) GetLastSyncHeightWithTTL(ctx context.Context, cid cid.ID, tid string) (uint64, int64, error)

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) IsServing added in v0.48.0 

func (s *Service) IsServing() bool

func (*Service) ListOpLogLocks added in v0.49.0 

func (s *Service) ListOpLogLocks(ctx context.Context, req *ListOpLogLocksRequest) (*ListOpLogLocksResponse, 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) OpLogHash added in v0.49.0 

func (s *Service) OpLogHash(ctx context.Context, req *OpLogHashRequest) (*OpLogHashResponse, error)

func (*Service) ReloadAuthorizedKeys added in v0.45.0 

func (s *Service) ReloadAuthorizedKeys(newKeys keys.PublicKeys)

func (*Service) Remove 

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

func (*Service) RemoveOpLogLock added in v0.49.0 

func (s *Service) RemoveOpLogLock(ctx context.Context, req *RemoveOpLogLockRequest) (*RemoveOpLogLockResponse, error)

func (*Service) ReplicateTreeOp added in v0.38.0 

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

func (*Service) RunForester added in v0.48.0 

func (s *Service) RunForester(ctx context.Context) error

func (*Service) ScheduleForester added in v0.48.0 

func (s *Service) ScheduleForester(ctx context.Context) error

func (*Service) ScheduleSync added in v0.48.0 

func (s *Service) ScheduleSync(ctx context.Context, req *ScheduleSyncRequest) (*ScheduleSyncResponse, error)

ScheduleSync schedules a new synchronization task for the given tree.

The call creates a new entry syncTask in the map schedSyncTasks to track the result. The entry syncTaskSubmit is enqueued to the syncTaskSubmitChan to be processed by the scheduledSyncLoop. scheduledSyncLoop delivers the task to the runScheduledSyncTask function which is processed by a worker from the worker pool.

func (*Service) ScheduleTreeResync added in v0.48.0 

func (s *Service) ScheduleTreeResync(ctx context.Context, cnr cid.ID, treeID string, localOnly bool) error

func (*Service) Shutdown 

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

Shutdown shutdowns the service.

func (*Service) SpaceUtilization added in v0.49.0 

func (s *Service) SpaceUtilization(ctx context.Context, req *SpaceUtilizationRequest) (*SpaceUtilizationResponse, error)

func (*Service) Start 

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

Start starts the service.

func (*Service) SubmitCompactionTask added in v0.49.0 

func (s *Service) SubmitCompactionTask(ctx context.Context, req *SubmitCompactionTaskRequest) (*SubmitCompactionTaskResponse, error)

func (*Service) SubmitSynchronizationTask added in v0.49.0 

func (s *Service) SubmitSynchronizationTask(ctx context.Context, req *SubmitSynchronizationTaskRequest) (*SubmitSynchronizationTaskResponse, error)

func (*Service) SyncStatus added in v0.48.0 

func (s *Service) SyncStatus(_ context.Context, req *SyncStatusRequest) (*SyncStatusResponse, error)

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, height uint64) error

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

func (*Service) TaskStatus added in v0.49.0 

func (s *Service) TaskStatus(ctx context.Context, req *TaskStatusRequest) (*TaskStatusResponse, error)

func (*Service) TreeHeight added in v0.48.0 

func (s *Service) TreeHeight(ctx context.Context, req *TreeHeightRequest) (*TreeHeightResponse, error)

func (*Service) TreeList 

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

type Signature 

type Signature struct {
	// Serialized public key as defined in FrostFS API.
	Key []byte `json:"key"`
	// Signature of a message body.
	Sign []byte `json:"signature"`
}

Signature of a message.

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 SpaceUtilizationRequest added in v0.49.0 

type SpaceUtilizationRequest struct {
	Body      *SpaceUtilizationRequest_Body `json:"body"`
	Signature *Signature                    `json:"signature"`
}

func (*SpaceUtilizationRequest) EmitProtobuf added in v0.49.0 

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

func (*SpaceUtilizationRequest) GetBody added in v0.49.0 

func (x *SpaceUtilizationRequest) GetBody() *SpaceUtilizationRequest_Body

func (*SpaceUtilizationRequest) GetSignature added in v0.49.0 

func (x *SpaceUtilizationRequest) GetSignature() *Signature

func (*SpaceUtilizationRequest) MarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SpaceUtilizationRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SpaceUtilizationRequest) ReadSignedData added in v0.49.0 

func (x *SpaceUtilizationRequest) 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 (*SpaceUtilizationRequest) SetBody added in v0.49.0 

func (x *SpaceUtilizationRequest) SetBody(v *SpaceUtilizationRequest_Body)

func (*SpaceUtilizationRequest) SetSignature added in v0.49.0 

func (x *SpaceUtilizationRequest) SetSignature(v *Signature)

func (*SpaceUtilizationRequest) SignedDataSize added in v0.49.0 

func (x *SpaceUtilizationRequest) 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 (*SpaceUtilizationRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SpaceUtilizationRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SpaceUtilizationRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SpaceUtilizationRequest_Body added in v0.49.0 

type SpaceUtilizationRequest_Body struct {
	ContainerId []byte `json:"containerId"`
	TreeId      string `json:"treeId"`
	BatchSize   int32  `json:"batchSize"`
}

func (*SpaceUtilizationRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*SpaceUtilizationRequest_Body) GetBatchSize added in v0.49.0 

func (x *SpaceUtilizationRequest_Body) GetBatchSize() int32

func (*SpaceUtilizationRequest_Body) GetContainerId added in v0.49.0 

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

func (*SpaceUtilizationRequest_Body) GetTreeId added in v0.49.0 

func (x *SpaceUtilizationRequest_Body) GetTreeId() string

func (*SpaceUtilizationRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SpaceUtilizationRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SpaceUtilizationRequest_Body) SetBatchSize added in v0.49.0 

func (x *SpaceUtilizationRequest_Body) SetBatchSize(v int32)

func (*SpaceUtilizationRequest_Body) SetContainerId added in v0.49.0 

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

func (*SpaceUtilizationRequest_Body) SetTreeId added in v0.49.0 

func (x *SpaceUtilizationRequest_Body) SetTreeId(v string)

func (*SpaceUtilizationRequest_Body) StableSize added in v0.49.0 

func (x *SpaceUtilizationRequest_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 (*SpaceUtilizationRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SpaceUtilizationRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SpaceUtilizationResponse added in v0.49.0 

type SpaceUtilizationResponse struct {
	Body      *SpaceUtilizationResponse_Body `json:"body"`
	Signature *Signature                     `json:"signature"`
}

func (*SpaceUtilizationResponse) EmitProtobuf added in v0.49.0 

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

func (*SpaceUtilizationResponse) GetBody added in v0.49.0 

func (x *SpaceUtilizationResponse) GetBody() *SpaceUtilizationResponse_Body

func (*SpaceUtilizationResponse) GetSignature added in v0.49.0 

func (x *SpaceUtilizationResponse) GetSignature() *Signature

func (*SpaceUtilizationResponse) MarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SpaceUtilizationResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SpaceUtilizationResponse) ReadSignedData added in v0.49.0 

func (x *SpaceUtilizationResponse) 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 (*SpaceUtilizationResponse) SetBody added in v0.49.0 

func (x *SpaceUtilizationResponse) SetBody(v *SpaceUtilizationResponse_Body)

func (*SpaceUtilizationResponse) SetSignature added in v0.49.0 

func (x *SpaceUtilizationResponse) SetSignature(v *Signature)

func (*SpaceUtilizationResponse) SignedDataSize added in v0.49.0 

func (x *SpaceUtilizationResponse) 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 (*SpaceUtilizationResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SpaceUtilizationResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SpaceUtilizationResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SpaceUtilizationResponse_Body added in v0.49.0 

type SpaceUtilizationResponse_Body struct {
	OpCount   uint64 `json:"opCount"`
	OpSize    uint64 `json:"opSize"`
	NodeCount uint64 `json:"nodeCount"`
	NodeSize  uint64 `json:"nodeSize"`
}

func (*SpaceUtilizationResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*SpaceUtilizationResponse_Body) GetNodeCount added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) GetNodeCount() uint64

func (*SpaceUtilizationResponse_Body) GetNodeSize added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) GetNodeSize() uint64

func (*SpaceUtilizationResponse_Body) GetOpCount added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) GetOpCount() uint64

func (*SpaceUtilizationResponse_Body) GetOpSize added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) GetOpSize() uint64

func (*SpaceUtilizationResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SpaceUtilizationResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SpaceUtilizationResponse_Body) SetNodeCount added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) SetNodeCount(v uint64)

func (*SpaceUtilizationResponse_Body) SetNodeSize added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) SetNodeSize(v uint64)

func (*SpaceUtilizationResponse_Body) SetOpCount added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) SetOpCount(v uint64)

func (*SpaceUtilizationResponse_Body) SetOpSize added in v0.49.0 

func (x *SpaceUtilizationResponse_Body) SetOpSize(v uint64)

func (*SpaceUtilizationResponse_Body) StableSize added in v0.49.0 

func (x *SpaceUtilizationResponse_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 (*SpaceUtilizationResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*SpaceUtilizationResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SpaceUtilizationResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitCompactionTaskRequest added in v0.49.0 

type SubmitCompactionTaskRequest struct {
	Body      *SubmitCompactionTaskRequest_Body `json:"body"`
	Signature *Signature                        `json:"signature"`
}

func (*SubmitCompactionTaskRequest) EmitProtobuf added in v0.49.0 

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

func (*SubmitCompactionTaskRequest) GetBody added in v0.49.0 

func (x *SubmitCompactionTaskRequest) GetBody() *SubmitCompactionTaskRequest_Body

func (*SubmitCompactionTaskRequest) GetSignature added in v0.49.0 

func (x *SubmitCompactionTaskRequest) GetSignature() *Signature

func (*SubmitCompactionTaskRequest) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitCompactionTaskRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitCompactionTaskRequest) ReadSignedData added in v0.49.0 

func (x *SubmitCompactionTaskRequest) 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 (*SubmitCompactionTaskRequest) SetBody added in v0.49.0 

func (x *SubmitCompactionTaskRequest) SetBody(v *SubmitCompactionTaskRequest_Body)

func (*SubmitCompactionTaskRequest) SetSignature added in v0.49.0 

func (x *SubmitCompactionTaskRequest) SetSignature(v *Signature)

func (*SubmitCompactionTaskRequest) SignedDataSize added in v0.49.0 

func (x *SubmitCompactionTaskRequest) 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 (*SubmitCompactionTaskRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SubmitCompactionTaskRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitCompactionTaskRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitCompactionTaskRequest_Body added in v0.49.0 

type SubmitCompactionTaskRequest_Body struct {
	TaskId      string `json:"taskId"`
	ContainerId []byte `json:"containerId"`
	UserTreeId  string `json:"userTreeId"`
	TempTreeId  string `json:"tempTreeId"`
	Height      uint64 `json:"height"`
	BatchSize   int32  `json:"batchSize"`
}

func (*SubmitCompactionTaskRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*SubmitCompactionTaskRequest_Body) GetBatchSize added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) GetBatchSize() int32

func (*SubmitCompactionTaskRequest_Body) GetContainerId added in v0.49.0 

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

func (*SubmitCompactionTaskRequest_Body) GetHeight added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) GetHeight() uint64

func (*SubmitCompactionTaskRequest_Body) GetTaskId added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) GetTaskId() string

func (*SubmitCompactionTaskRequest_Body) GetTempTreeId added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) GetTempTreeId() string

func (*SubmitCompactionTaskRequest_Body) GetUserTreeId added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) GetUserTreeId() string

func (*SubmitCompactionTaskRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitCompactionTaskRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitCompactionTaskRequest_Body) SetBatchSize added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) SetBatchSize(v int32)

func (*SubmitCompactionTaskRequest_Body) SetContainerId added in v0.49.0 

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

func (*SubmitCompactionTaskRequest_Body) SetHeight added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) SetHeight(v uint64)

func (*SubmitCompactionTaskRequest_Body) SetTaskId added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) SetTaskId(v string)

func (*SubmitCompactionTaskRequest_Body) SetTempTreeId added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) SetTempTreeId(v string)

func (*SubmitCompactionTaskRequest_Body) SetUserTreeId added in v0.49.0 

func (x *SubmitCompactionTaskRequest_Body) SetUserTreeId(v string)

func (*SubmitCompactionTaskRequest_Body) StableSize added in v0.49.0 

func (x *SubmitCompactionTaskRequest_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 (*SubmitCompactionTaskRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitCompactionTaskRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitCompactionTaskResponse added in v0.49.0 

type SubmitCompactionTaskResponse struct {
	Body      *SubmitCompactionTaskResponse_Body `json:"body"`
	Signature *Signature                         `json:"signature"`
}

func (*SubmitCompactionTaskResponse) EmitProtobuf added in v0.49.0 

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

func (*SubmitCompactionTaskResponse) GetBody added in v0.49.0 

func (x *SubmitCompactionTaskResponse) GetBody() *SubmitCompactionTaskResponse_Body

func (*SubmitCompactionTaskResponse) GetSignature added in v0.49.0 

func (x *SubmitCompactionTaskResponse) GetSignature() *Signature

func (*SubmitCompactionTaskResponse) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitCompactionTaskResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitCompactionTaskResponse) ReadSignedData added in v0.49.0 

func (x *SubmitCompactionTaskResponse) 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 (*SubmitCompactionTaskResponse) SetBody added in v0.49.0 

func (x *SubmitCompactionTaskResponse) SetBody(v *SubmitCompactionTaskResponse_Body)

func (*SubmitCompactionTaskResponse) SetSignature added in v0.49.0 

func (x *SubmitCompactionTaskResponse) SetSignature(v *Signature)

func (*SubmitCompactionTaskResponse) SignedDataSize added in v0.49.0 

func (x *SubmitCompactionTaskResponse) 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 (*SubmitCompactionTaskResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SubmitCompactionTaskResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitCompactionTaskResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitCompactionTaskResponse_Body added in v0.49.0 

type SubmitCompactionTaskResponse_Body struct {
}

func (*SubmitCompactionTaskResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*SubmitCompactionTaskResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitCompactionTaskResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitCompactionTaskResponse_Body) StableSize added in v0.49.0 

func (x *SubmitCompactionTaskResponse_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 (*SubmitCompactionTaskResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitCompactionTaskResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitCompactionTaskResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitSynchronizationTaskRequest added in v0.49.0 

type SubmitSynchronizationTaskRequest struct {
	Body      *SubmitSynchronizationTaskRequest_Body `json:"body"`
	Signature *Signature                             `json:"signature"`
}

func (*SubmitSynchronizationTaskRequest) EmitProtobuf added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest) GetBody added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest) GetBody() *SubmitSynchronizationTaskRequest_Body

func (*SubmitSynchronizationTaskRequest) GetSignature added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest) GetSignature() *Signature

func (*SubmitSynchronizationTaskRequest) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitSynchronizationTaskRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitSynchronizationTaskRequest) ReadSignedData added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest) 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 (*SubmitSynchronizationTaskRequest) SetBody added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest) SetBody(v *SubmitSynchronizationTaskRequest_Body)

func (*SubmitSynchronizationTaskRequest) SetSignature added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest) SetSignature(v *Signature)

func (*SubmitSynchronizationTaskRequest) SignedDataSize added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest) 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 (*SubmitSynchronizationTaskRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SubmitSynchronizationTaskRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitSynchronizationTaskRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitSynchronizationTaskRequest_Body added in v0.49.0 

type SubmitSynchronizationTaskRequest_Body struct {
	TaskId      string `json:"taskId"`
	ContainerId []byte `json:"containerId"`
	TreeId      string `json:"treeId"`
	ForceFull   bool   `json:"forceFull"`
}

func (*SubmitSynchronizationTaskRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest_Body) GetContainerId added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest_Body) GetForceFull added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_Body) GetForceFull() bool

func (*SubmitSynchronizationTaskRequest_Body) GetTaskId added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_Body) GetTaskId() string

func (*SubmitSynchronizationTaskRequest_Body) GetTreeId added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_Body) GetTreeId() string

func (*SubmitSynchronizationTaskRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitSynchronizationTaskRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitSynchronizationTaskRequest_Body) SetContainerId added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest_Body) SetForceFull added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_Body) SetForceFull(v bool)

func (*SubmitSynchronizationTaskRequest_Body) SetTaskId added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_Body) SetTaskId(v string)

func (*SubmitSynchronizationTaskRequest_Body) SetTreeId added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_Body) SetTreeId(v string)

func (*SubmitSynchronizationTaskRequest_Body) StableSize added in v0.49.0 

func (x *SubmitSynchronizationTaskRequest_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 (*SubmitSynchronizationTaskRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitSynchronizationTaskRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitSynchronizationTaskResponse added in v0.49.0 

type SubmitSynchronizationTaskResponse struct {
	Body      *SubmitSynchronizationTaskResponse_Body `json:"body"`
	Signature *Signature                              `json:"signature"`
}

func (*SubmitSynchronizationTaskResponse) EmitProtobuf added in v0.49.0 

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

func (*SubmitSynchronizationTaskResponse) GetBody added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse) GetBody() *SubmitSynchronizationTaskResponse_Body

func (*SubmitSynchronizationTaskResponse) GetSignature added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse) GetSignature() *Signature

func (*SubmitSynchronizationTaskResponse) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitSynchronizationTaskResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitSynchronizationTaskResponse) ReadSignedData added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse) 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 (*SubmitSynchronizationTaskResponse) SetBody added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse) SetBody(v *SubmitSynchronizationTaskResponse_Body)

func (*SubmitSynchronizationTaskResponse) SetSignature added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse) SetSignature(v *Signature)

func (*SubmitSynchronizationTaskResponse) SignedDataSize added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse) 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 (*SubmitSynchronizationTaskResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SubmitSynchronizationTaskResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitSynchronizationTaskResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SubmitSynchronizationTaskResponse_Body added in v0.49.0 

type SubmitSynchronizationTaskResponse_Body struct {
}

func (*SubmitSynchronizationTaskResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*SubmitSynchronizationTaskResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SubmitSynchronizationTaskResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SubmitSynchronizationTaskResponse_Body) StableSize added in v0.49.0 

func (x *SubmitSynchronizationTaskResponse_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 (*SubmitSynchronizationTaskResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*SubmitSynchronizationTaskResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SubmitSynchronizationTaskResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SyncStatusRequest added in v0.48.0 

type SyncStatusRequest struct {
	// Request body.
	Body *SyncStatusRequest_Body `json:"body"`
	// Request signature.
	Signature *Signature `json:"signature"`
}

func (*SyncStatusRequest) EmitProtobuf added in v0.48.0 

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

func (*SyncStatusRequest) GetBody added in v0.48.0 

func (x *SyncStatusRequest) GetBody() *SyncStatusRequest_Body

func (*SyncStatusRequest) GetSignature added in v0.48.0 

func (x *SyncStatusRequest) GetSignature() *Signature

func (*SyncStatusRequest) MarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusRequest) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SyncStatusRequest) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SyncStatusRequest) ReadSignedData added in v0.48.0 

func (x *SyncStatusRequest) 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 (*SyncStatusRequest) SetBody added in v0.48.0 

func (x *SyncStatusRequest) SetBody(v *SyncStatusRequest_Body)

func (*SyncStatusRequest) SetSignature added in v0.48.0 

func (x *SyncStatusRequest) SetSignature(v *Signature)

func (*SyncStatusRequest) SignedDataSize added in v0.48.0 

func (x *SyncStatusRequest) 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 (*SyncStatusRequest) StableSize added in v0.48.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SyncStatusRequest) UnmarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusRequest) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SyncStatusRequest) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SyncStatusRequest_Body added in v0.48.0 

type SyncStatusRequest_Body struct {
	// Identifier of the synchronization task.
	TaskId string `json:"taskId"`
}

func (*SyncStatusRequest_Body) EmitProtobuf added in v0.48.0 

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

func (*SyncStatusRequest_Body) GetTaskId added in v0.48.0 

func (x *SyncStatusRequest_Body) GetTaskId() string

func (*SyncStatusRequest_Body) MarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusRequest_Body) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SyncStatusRequest_Body) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SyncStatusRequest_Body) SetTaskId added in v0.48.0 

func (x *SyncStatusRequest_Body) SetTaskId(v string)

func (*SyncStatusRequest_Body) StableSize added in v0.48.0 

func (x *SyncStatusRequest_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 (*SyncStatusRequest_Body) UnmarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusRequest_Body) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SyncStatusRequest_Body) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SyncStatusResponse added in v0.48.0 

type SyncStatusResponse struct {
	// Response body.
	Body *SyncStatusResponse_Body `json:"body"`
	// Response signature.
	Signature *Signature `json:"signature"`
}

func (*SyncStatusResponse) EmitProtobuf added in v0.48.0 

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

func (*SyncStatusResponse) GetBody added in v0.48.0 

func (x *SyncStatusResponse) GetBody() *SyncStatusResponse_Body

func (*SyncStatusResponse) GetSignature added in v0.48.0 

func (x *SyncStatusResponse) GetSignature() *Signature

func (*SyncStatusResponse) MarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusResponse) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SyncStatusResponse) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SyncStatusResponse) ReadSignedData added in v0.48.0 

func (x *SyncStatusResponse) 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 (*SyncStatusResponse) SetBody added in v0.48.0 

func (x *SyncStatusResponse) SetBody(v *SyncStatusResponse_Body)

func (*SyncStatusResponse) SetSignature added in v0.48.0 

func (x *SyncStatusResponse) SetSignature(v *Signature)

func (*SyncStatusResponse) SignedDataSize added in v0.48.0 

func (x *SyncStatusResponse) 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 (*SyncStatusResponse) StableSize added in v0.48.0 

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

StableSize returns the size of x in protobuf format.

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

func (*SyncStatusResponse) UnmarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusResponse) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SyncStatusResponse) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SyncStatusResponse_Body added in v0.48.0 

type SyncStatusResponse_Body struct {
	// Current task status.
	Status SyncStatusResponse_Body_Status `json:"status"`
	// Optional error description when synchronization failed.
	Error string `json:"error"`
}

func (*SyncStatusResponse_Body) EmitProtobuf added in v0.48.0 

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

func (*SyncStatusResponse_Body) GetError added in v0.48.0 

func (x *SyncStatusResponse_Body) GetError() string

func (*SyncStatusResponse_Body) GetStatus added in v0.48.0 

func (x *SyncStatusResponse_Body) GetStatus() SyncStatusResponse_Body_Status

func (*SyncStatusResponse_Body) MarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusResponse_Body) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*SyncStatusResponse_Body) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*SyncStatusResponse_Body) SetError added in v0.48.0 

func (x *SyncStatusResponse_Body) SetError(v string)

func (*SyncStatusResponse_Body) SetStatus added in v0.48.0 

func (x *SyncStatusResponse_Body) SetStatus(v SyncStatusResponse_Body_Status)

func (*SyncStatusResponse_Body) StableSize added in v0.48.0 

func (x *SyncStatusResponse_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 (*SyncStatusResponse_Body) UnmarshalEasyJSON added in v0.48.0 

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

func (*SyncStatusResponse_Body) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*SyncStatusResponse_Body) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type SyncStatusResponse_Body_Status added in v0.48.0 

type SyncStatusResponse_Body_Status int32
const (
	SyncStatusResponse_Body_Undefined  SyncStatusResponse_Body_Status = 0
	SyncStatusResponse_Body_Pending    SyncStatusResponse_Body_Status = 1
	SyncStatusResponse_Body_InProgress SyncStatusResponse_Body_Status = 2
	SyncStatusResponse_Body_Completed  SyncStatusResponse_Body_Status = 3
)

func (*SyncStatusResponse_Body_Status) FromString added in v0.48.0 

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

func (SyncStatusResponse_Body_Status) String added in v0.48.0 

func (x SyncStatusResponse_Body_Status) String() string

type TaskStatusRequest added in v0.49.0 

type TaskStatusRequest struct {
	Body      *TaskStatusRequest_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func (*TaskStatusRequest) EmitProtobuf added in v0.49.0 

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

func (*TaskStatusRequest) GetBody added in v0.49.0 

func (x *TaskStatusRequest) GetBody() *TaskStatusRequest_Body

func (*TaskStatusRequest) GetSignature added in v0.49.0 

func (x *TaskStatusRequest) GetSignature() *Signature

func (*TaskStatusRequest) MarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusRequest) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TaskStatusRequest) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TaskStatusRequest) ReadSignedData added in v0.49.0 

func (x *TaskStatusRequest) 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 (*TaskStatusRequest) SetBody added in v0.49.0 

func (x *TaskStatusRequest) SetBody(v *TaskStatusRequest_Body)

func (*TaskStatusRequest) SetSignature added in v0.49.0 

func (x *TaskStatusRequest) SetSignature(v *Signature)

func (*TaskStatusRequest) SignedDataSize added in v0.49.0 

func (x *TaskStatusRequest) 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 (*TaskStatusRequest) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*TaskStatusRequest) UnmarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusRequest) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TaskStatusRequest) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TaskStatusRequest_Body added in v0.49.0 

type TaskStatusRequest_Body struct {
	TaskId string `json:"taskId"`
}

func (*TaskStatusRequest_Body) EmitProtobuf added in v0.49.0 

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

func (*TaskStatusRequest_Body) GetTaskId added in v0.49.0 

func (x *TaskStatusRequest_Body) GetTaskId() string

func (*TaskStatusRequest_Body) MarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusRequest_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TaskStatusRequest_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TaskStatusRequest_Body) SetTaskId added in v0.49.0 

func (x *TaskStatusRequest_Body) SetTaskId(v string)

func (*TaskStatusRequest_Body) StableSize added in v0.49.0 

func (x *TaskStatusRequest_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 (*TaskStatusRequest_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusRequest_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TaskStatusRequest_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TaskStatusResponse added in v0.49.0 

type TaskStatusResponse struct {
	Body      *TaskStatusResponse_Body `json:"body"`
	Signature *Signature               `json:"signature"`
}

func (*TaskStatusResponse) EmitProtobuf added in v0.49.0 

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

func (*TaskStatusResponse) GetBody added in v0.49.0 

func (x *TaskStatusResponse) GetBody() *TaskStatusResponse_Body

func (*TaskStatusResponse) GetSignature added in v0.49.0 

func (x *TaskStatusResponse) GetSignature() *Signature

func (*TaskStatusResponse) MarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusResponse) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TaskStatusResponse) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TaskStatusResponse) ReadSignedData added in v0.49.0 

func (x *TaskStatusResponse) 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 (*TaskStatusResponse) SetBody added in v0.49.0 

func (x *TaskStatusResponse) SetBody(v *TaskStatusResponse_Body)

func (*TaskStatusResponse) SetSignature added in v0.49.0 

func (x *TaskStatusResponse) SetSignature(v *Signature)

func (*TaskStatusResponse) SignedDataSize added in v0.49.0 

func (x *TaskStatusResponse) 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 (*TaskStatusResponse) StableSize added in v0.49.0 

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

StableSize returns the size of x in protobuf format.

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

func (*TaskStatusResponse) UnmarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusResponse) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TaskStatusResponse) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TaskStatusResponse_Body added in v0.49.0 

type TaskStatusResponse_Body struct {
	Status     TaskStatusResponse_Status     `json:"status"`
	Error      string                        `json:"error"`
	Properties []TaskStatusResponse_KeyValue `json:"properties"`
}

func (*TaskStatusResponse_Body) EmitProtobuf added in v0.49.0 

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

func (*TaskStatusResponse_Body) GetError added in v0.49.0 

func (x *TaskStatusResponse_Body) GetError() string

func (*TaskStatusResponse_Body) GetProperties added in v0.49.0 

func (x *TaskStatusResponse_Body) GetProperties() []TaskStatusResponse_KeyValue

func (*TaskStatusResponse_Body) GetStatus added in v0.49.0 

func (x *TaskStatusResponse_Body) GetStatus() TaskStatusResponse_Status

func (*TaskStatusResponse_Body) MarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusResponse_Body) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TaskStatusResponse_Body) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TaskStatusResponse_Body) SetError added in v0.49.0 

func (x *TaskStatusResponse_Body) SetError(v string)

func (*TaskStatusResponse_Body) SetProperties added in v0.49.0 

func (x *TaskStatusResponse_Body) SetProperties(v []TaskStatusResponse_KeyValue)

func (*TaskStatusResponse_Body) SetStatus added in v0.49.0 

func (x *TaskStatusResponse_Body) SetStatus(v TaskStatusResponse_Status)

func (*TaskStatusResponse_Body) StableSize added in v0.49.0 

func (x *TaskStatusResponse_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 (*TaskStatusResponse_Body) UnmarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusResponse_Body) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TaskStatusResponse_Body) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TaskStatusResponse_KeyValue added in v0.49.0 

type TaskStatusResponse_KeyValue struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

func (*TaskStatusResponse_KeyValue) EmitProtobuf added in v0.49.0 

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

func (*TaskStatusResponse_KeyValue) GetKey added in v0.49.0 

func (x *TaskStatusResponse_KeyValue) GetKey() string

func (*TaskStatusResponse_KeyValue) GetValue added in v0.49.0 

func (x *TaskStatusResponse_KeyValue) GetValue() string

func (*TaskStatusResponse_KeyValue) MarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusResponse_KeyValue) MarshalJSON added in v0.49.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TaskStatusResponse_KeyValue) MarshalProtobuf added in v0.49.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TaskStatusResponse_KeyValue) SetKey added in v0.49.0 

func (x *TaskStatusResponse_KeyValue) SetKey(v string)

func (*TaskStatusResponse_KeyValue) SetValue added in v0.49.0 

func (x *TaskStatusResponse_KeyValue) SetValue(v string)

func (*TaskStatusResponse_KeyValue) StableSize added in v0.49.0 

func (x *TaskStatusResponse_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 (*TaskStatusResponse_KeyValue) UnmarshalEasyJSON added in v0.49.0 

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

func (*TaskStatusResponse_KeyValue) UnmarshalJSON added in v0.49.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TaskStatusResponse_KeyValue) UnmarshalProtobuf added in v0.49.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TaskStatusResponse_Status added in v0.49.0 

type TaskStatusResponse_Status int32
const (
	TaskStatusResponse_UNDEFINED TaskStatusResponse_Status = 0
	TaskStatusResponse_QUEUED    TaskStatusResponse_Status = 1
	TaskStatusResponse_RUNNING   TaskStatusResponse_Status = 2
	TaskStatusResponse_DONE      TaskStatusResponse_Status = 3
	TaskStatusResponse_FAILED    TaskStatusResponse_Status = 4
	TaskStatusResponse_UNKNOWN   TaskStatusResponse_Status = 5
)

func (*TaskStatusResponse_Status) FromString added in v0.49.0 

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

func (TaskStatusResponse_Status) String added in v0.49.0 

func (x TaskStatusResponse_Status) String() string

type TreeHeightRequest added in v0.48.0 

type TreeHeightRequest struct {
	// Request body.
	Body *TreeHeightRequest_Body `json:"body"`
	// Request signature.
	Signature *Signature `json:"signature"`
}

func (*TreeHeightRequest) EmitProtobuf added in v0.48.0 

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

func (*TreeHeightRequest) GetBody added in v0.48.0 

func (x *TreeHeightRequest) GetBody() *TreeHeightRequest_Body

func (*TreeHeightRequest) GetSignature added in v0.48.0 

func (x *TreeHeightRequest) GetSignature() *Signature

func (*TreeHeightRequest) MarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightRequest) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TreeHeightRequest) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TreeHeightRequest) ReadSignedData added in v0.48.0 

func (x *TreeHeightRequest) 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 (*TreeHeightRequest) SetBody added in v0.48.0 

func (x *TreeHeightRequest) SetBody(v *TreeHeightRequest_Body)

func (*TreeHeightRequest) SetSignature added in v0.48.0 

func (x *TreeHeightRequest) SetSignature(v *Signature)

func (*TreeHeightRequest) SignedDataSize added in v0.48.0 

func (x *TreeHeightRequest) 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 (*TreeHeightRequest) StableSize added in v0.48.0 

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

StableSize returns the size of x in protobuf format.

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

func (*TreeHeightRequest) UnmarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightRequest) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeHeightRequest) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeHeightRequest_Body added in v0.48.0 

type TreeHeightRequest_Body struct {
	// Container ID in V2 format.
	ContainerId []byte `json:"containerId"`
	// The name of the tree.
	TreeId string `json:"treeId"`
}

func (*TreeHeightRequest_Body) EmitProtobuf added in v0.48.0 

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

func (*TreeHeightRequest_Body) GetContainerId added in v0.48.0 

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

func (*TreeHeightRequest_Body) GetTreeId added in v0.48.0 

func (x *TreeHeightRequest_Body) GetTreeId() string

func (*TreeHeightRequest_Body) MarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightRequest_Body) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TreeHeightRequest_Body) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TreeHeightRequest_Body) SetContainerId added in v0.48.0 

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

func (*TreeHeightRequest_Body) SetTreeId added in v0.48.0 

func (x *TreeHeightRequest_Body) SetTreeId(v string)

func (*TreeHeightRequest_Body) StableSize added in v0.48.0 

func (x *TreeHeightRequest_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 (*TreeHeightRequest_Body) UnmarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightRequest_Body) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeHeightRequest_Body) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeHeightResponse added in v0.48.0 

type TreeHeightResponse struct {
	// Response body.
	Body      *TreeHeightResponse_Body `json:"body"`
	Signature *Signature               `json:"signature"`
}

func (*TreeHeightResponse) EmitProtobuf added in v0.48.0 

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

func (*TreeHeightResponse) GetBody added in v0.48.0 

func (x *TreeHeightResponse) GetBody() *TreeHeightResponse_Body

func (*TreeHeightResponse) GetSignature added in v0.48.0 

func (x *TreeHeightResponse) GetSignature() *Signature

func (*TreeHeightResponse) MarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightResponse) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TreeHeightResponse) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TreeHeightResponse) ReadSignedData added in v0.48.0 

func (x *TreeHeightResponse) 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 (*TreeHeightResponse) SetBody added in v0.48.0 

func (x *TreeHeightResponse) SetBody(v *TreeHeightResponse_Body)

func (*TreeHeightResponse) SetSignature added in v0.48.0 

func (x *TreeHeightResponse) SetSignature(v *Signature)

func (*TreeHeightResponse) SignedDataSize added in v0.48.0 

func (x *TreeHeightResponse) 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 (*TreeHeightResponse) StableSize added in v0.48.0 

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

StableSize returns the size of x in protobuf format.

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

func (*TreeHeightResponse) UnmarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightResponse) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeHeightResponse) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeHeightResponse_Body added in v0.48.0 

type TreeHeightResponse_Body struct {
	Height uint64 `json:"height"`
}

func (*TreeHeightResponse_Body) EmitProtobuf added in v0.48.0 

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

func (*TreeHeightResponse_Body) GetHeight added in v0.48.0 

func (x *TreeHeightResponse_Body) GetHeight() uint64

func (*TreeHeightResponse_Body) MarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightResponse_Body) MarshalJSON added in v0.48.0 

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

MarshalJSON implements the json.Marshaler interface.

func (*TreeHeightResponse_Body) MarshalProtobuf added in v0.48.0 

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

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TreeHeightResponse_Body) SetHeight added in v0.48.0 

func (x *TreeHeightResponse_Body) SetHeight(v uint64)

func (*TreeHeightResponse_Body) StableSize added in v0.48.0 

func (x *TreeHeightResponse_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 (*TreeHeightResponse_Body) UnmarshalEasyJSON added in v0.48.0 

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

func (*TreeHeightResponse_Body) UnmarshalJSON added in v0.48.0 

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

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TreeHeightResponse_Body) UnmarshalProtobuf added in v0.48.0 

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

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TreeListRequest 

type TreeListRequest struct {
	// Request body.
	Body *TreeListRequest_Body `json:"body"`
	// Request signature.
	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 {
	// Container ID in V2 format.
	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 {
	// Response body.
	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 {
	// Tree IDs.
	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) (grpc.ServerStreamingClient[GetSubTreeResponse], error)
	// TreeList return list of the existing trees in the container.
	TreeList(ctx context.Context, in *TreeListRequest, opts ...grpc.CallOption) (*TreeListResponse, error)
	// TreeHeight returns current tree height.
	TreeHeight(ctx context.Context, in *TreeHeightRequest, opts ...grpc.CallOption) (*TreeHeightResponse, 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) (grpc.ServerStreamingClient[GetOpLogResponse], error)
	// ScheduleSync schedules tree log synchronization from a specific node.
	ScheduleSync(ctx context.Context, in *ScheduleSyncRequest, opts ...grpc.CallOption) (*ScheduleSyncResponse, error)
	// SyncStatus returns status of a previously scheduled synchronization task.
	SyncStatus(ctx context.Context, in *SyncStatusRequest, opts ...grpc.CallOption) (*SyncStatusResponse, error)
	// Healthcheck is a dummy rpc to check service availability
	Healthcheck(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error)
	SpaceUtilization(ctx context.Context, in *SpaceUtilizationRequest, opts ...grpc.CallOption) (*SpaceUtilizationResponse, error)
	SubmitSynchronizationTask(ctx context.Context, in *SubmitSynchronizationTaskRequest, opts ...grpc.CallOption) (*SubmitSynchronizationTaskResponse, error)
	SubmitCompactionTask(ctx context.Context, in *SubmitCompactionTaskRequest, opts ...grpc.CallOption) (*SubmitCompactionTaskResponse, error)
	TaskStatus(ctx context.Context, in *TaskStatusRequest, opts ...grpc.CallOption) (*TaskStatusResponse, error)
	AbortTask(ctx context.Context, in *AbortTaskRequest, opts ...grpc.CallOption) (*AbortTaskResponse, error)
	AddOpLogLock(ctx context.Context, in *AddOpLogLockRequest, opts ...grpc.CallOption) (*AddOpLogLockResponse, error)
	RemoveOpLogLock(ctx context.Context, in *RemoveOpLogLockRequest, opts ...grpc.CallOption) (*RemoveOpLogLockResponse, error)
	ListOpLogLocks(ctx context.Context, in *ListOpLogLocksRequest, opts ...grpc.CallOption) (*ListOpLogLocksResponse, error)
	OpLogHash(ctx context.Context, in *OpLogHashRequest, opts ...grpc.CallOption) (*OpLogHashResponse, error)
	Drop(ctx context.Context, in *DropRequest, opts ...grpc.CallOption) (*DropResponse, 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, grpc.ServerStreamingServer[GetSubTreeResponse]) error
	// TreeList return list of the existing trees in the container.
	TreeList(context.Context, *TreeListRequest) (*TreeListResponse, error)
	// TreeHeight returns current tree height.
	TreeHeight(context.Context, *TreeHeightRequest) (*TreeHeightResponse, 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, grpc.ServerStreamingServer[GetOpLogResponse]) error
	// ScheduleSync schedules tree log synchronization from a specific node.
	ScheduleSync(context.Context, *ScheduleSyncRequest) (*ScheduleSyncResponse, error)
	// SyncStatus returns status of a previously scheduled synchronization task.
	SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)
	// Healthcheck is a dummy rpc to check service availability
	Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)
	SpaceUtilization(context.Context, *SpaceUtilizationRequest) (*SpaceUtilizationResponse, error)
	SubmitSynchronizationTask(context.Context, *SubmitSynchronizationTaskRequest) (*SubmitSynchronizationTaskResponse, error)
	SubmitCompactionTask(context.Context, *SubmitCompactionTaskRequest) (*SubmitCompactionTaskResponse, error)
	TaskStatus(context.Context, *TaskStatusRequest) (*TaskStatusResponse, error)
	AbortTask(context.Context, *AbortTaskRequest) (*AbortTaskResponse, error)
	AddOpLogLock(context.Context, *AddOpLogLockRequest) (*AddOpLogLockResponse, error)
	RemoveOpLogLock(context.Context, *RemoveOpLogLockRequest) (*RemoveOpLogLockResponse, error)
	ListOpLogLocks(context.Context, *ListOpLogLocksRequest) (*ListOpLogLocksResponse, error)
	OpLogHash(context.Context, *OpLogHashRequest) (*OpLogHashResponse, error)
	Drop(context.Context, *DropRequest) (*DropResponse, error)
}

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

func NewIOTagAdjustServer added in v0.45.0 

func NewIOTagAdjustServer(s TreeServiceServer, a AdjustIOTag) TreeServiceServer

type TreeService_GetOpLogClient 

type TreeService_GetOpLogClient = grpc.ServerStreamingClient[GetOpLogResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TreeService_GetOpLogServer 

type TreeService_GetOpLogServer = grpc.ServerStreamingServer[GetOpLogResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TreeService_GetSubTreeClient 

type TreeService_GetSubTreeClient = grpc.ServerStreamingClient[GetSubTreeResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TreeService_GetSubTreeServer 

type TreeService_GetSubTreeServer = grpc.ServerStreamingServer[GetSubTreeResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedTreeServiceServer 

type UnimplementedTreeServiceServer struct{}

UnimplementedTreeServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTreeServiceServer) AbortTask added in v0.49.0 

func (UnimplementedTreeServiceServer) AbortTask(context.Context, *AbortTaskRequest) (*AbortTaskResponse, error)

func (UnimplementedTreeServiceServer) Add 

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

func (UnimplementedTreeServiceServer) AddByPath 

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

func (UnimplementedTreeServiceServer) AddOpLogLock added in v0.49.0 

func (UnimplementedTreeServiceServer) AddOpLogLock(context.Context, *AddOpLogLockRequest) (*AddOpLogLockResponse, error)

func (UnimplementedTreeServiceServer) Apply 

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

func (UnimplementedTreeServiceServer) Drop added in v0.49.0 

func (UnimplementedTreeServiceServer) Drop(context.Context, *DropRequest) (*DropResponse, error)

func (UnimplementedTreeServiceServer) GetNodeByPath 

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

func (UnimplementedTreeServiceServer) GetOpLog 

func (UnimplementedTreeServiceServer) GetOpLog(*GetOpLogRequest, grpc.ServerStreamingServer[GetOpLogResponse]) error

func (UnimplementedTreeServiceServer) GetSubTree 

func (UnimplementedTreeServiceServer) GetSubTree(*GetSubTreeRequest, grpc.ServerStreamingServer[GetSubTreeResponse]) error

func (UnimplementedTreeServiceServer) Healthcheck 

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

func (UnimplementedTreeServiceServer) ListOpLogLocks added in v0.49.0 

func (UnimplementedTreeServiceServer) ListOpLogLocks(context.Context, *ListOpLogLocksRequest) (*ListOpLogLocksResponse, error)

func (UnimplementedTreeServiceServer) Move 

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

func (UnimplementedTreeServiceServer) OpLogHash added in v0.49.0 

func (UnimplementedTreeServiceServer) OpLogHash(context.Context, *OpLogHashRequest) (*OpLogHashResponse, error)

func (UnimplementedTreeServiceServer) Remove 

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

func (UnimplementedTreeServiceServer) RemoveOpLogLock added in v0.49.0 

func (UnimplementedTreeServiceServer) RemoveOpLogLock(context.Context, *RemoveOpLogLockRequest) (*RemoveOpLogLockResponse, error)

func (UnimplementedTreeServiceServer) ScheduleSync added in v0.48.0 

func (UnimplementedTreeServiceServer) ScheduleSync(context.Context, *ScheduleSyncRequest) (*ScheduleSyncResponse, error)

func (UnimplementedTreeServiceServer) SpaceUtilization added in v0.49.0 

func (UnimplementedTreeServiceServer) SpaceUtilization(context.Context, *SpaceUtilizationRequest) (*SpaceUtilizationResponse, error)

func (UnimplementedTreeServiceServer) SubmitCompactionTask added in v0.49.0 

func (UnimplementedTreeServiceServer) SubmitCompactionTask(context.Context, *SubmitCompactionTaskRequest) (*SubmitCompactionTaskResponse, error)

func (UnimplementedTreeServiceServer) SubmitSynchronizationTask added in v0.49.0 

func (UnimplementedTreeServiceServer) SubmitSynchronizationTask(context.Context, *SubmitSynchronizationTaskRequest) (*SubmitSynchronizationTaskResponse, error)

func (UnimplementedTreeServiceServer) SyncStatus added in v0.48.0 

func (UnimplementedTreeServiceServer) SyncStatus(context.Context, *SyncStatusRequest) (*SyncStatusResponse, error)

func (UnimplementedTreeServiceServer) TaskStatus added in v0.49.0 

func (UnimplementedTreeServiceServer) TaskStatus(context.Context, *TaskStatusRequest) (*TaskStatusResponse, error)

func (UnimplementedTreeServiceServer) TreeHeight added in v0.48.0 

func (UnimplementedTreeServiceServer) TreeHeight(context.Context, *TreeHeightRequest) (*TreeHeightResponse, 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.