tree

Nov 25, 2024

Changes in this version

type Option

+ func WithDialerSource(ds *net.DialerSource) Option

+ func WithSyncBatchSize(n int) Option

Sep 27, 2024

Changes in this version

type AddByPathRequest

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

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

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

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

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

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

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

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

type AddByPathRequest_Body

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

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

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

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

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

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

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

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

+ func (x *AddByPathRequest_Body) SetPathAttribute(v string)

+ func (x *AddByPathRequest_Body) SetTreeId(v string)

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

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

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

type AddByPathResponse

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

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

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

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

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

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

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

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

type AddByPathResponse_Body

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

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

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

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

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

+ func (x *AddByPathResponse_Body) SetParentId(v uint64)

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

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

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

type AddRequest

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

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

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

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

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

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

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

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

type AddRequest_Body

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

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

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

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

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

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

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

+ func (x *AddRequest_Body) SetParentId(v uint64)

+ func (x *AddRequest_Body) SetTreeId(v string)

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

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

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

type AddResponse

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

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

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

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

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

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

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

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

type AddResponse_Body

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

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

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

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

+ func (x *AddResponse_Body) SetNodeId(v uint64)

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

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

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

type ApplyRequest

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

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

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

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

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

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

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

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

type ApplyRequest_Body

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

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

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

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

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

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

+ func (x *ApplyRequest_Body) SetTreeId(v string)

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

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

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

type ApplyResponse

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

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

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

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

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

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

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

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

type ApplyResponse_Body

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

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

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

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

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

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

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

type GetNodeByPathRequest

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

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

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

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

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

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

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

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

type GetNodeByPathRequest_Body

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

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

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

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

+ func (x *GetNodeByPathRequest_Body) SetAllAttributes(v bool)

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

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

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

+ func (x *GetNodeByPathRequest_Body) SetLatestOnly(v bool)

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

+ func (x *GetNodeByPathRequest_Body) SetPathAttribute(v string)

+ func (x *GetNodeByPathRequest_Body) SetTreeId(v string)

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

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

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

type GetNodeByPathResponse

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

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

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

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

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

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

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

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

type GetNodeByPathResponse_Body

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

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

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

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

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

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

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

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

type GetNodeByPathResponse_Info

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

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

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

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

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

+ func (x *GetNodeByPathResponse_Info) SetNodeId(v uint64)

+ func (x *GetNodeByPathResponse_Info) SetParentId(v uint64)

+ func (x *GetNodeByPathResponse_Info) SetTimestamp(v uint64)

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

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

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

type GetOpLogRequest

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

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

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

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

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

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

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

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

type GetOpLogRequest_Body

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

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

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

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

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

+ func (x *GetOpLogRequest_Body) SetCount(v uint64)

+ func (x *GetOpLogRequest_Body) SetHeight(v uint64)

+ func (x *GetOpLogRequest_Body) SetTreeId(v string)

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

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

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

type GetOpLogResponse

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

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

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

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

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

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

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

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

type GetOpLogResponse_Body

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

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

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

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

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

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

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

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

type GetSubTreeRequest

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

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

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

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

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

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

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

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

type GetSubTreeRequest_Body

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

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

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

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

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

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

+ func (x *GetSubTreeRequest_Body) SetDepth(v uint32)

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

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

+ func (x *GetSubTreeRequest_Body) SetTreeId(v string)

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

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

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

type GetSubTreeRequest_Body_Order

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

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

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

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

+ func (x *GetSubTreeRequest_Body_Order) SetDirection(v GetSubTreeRequest_Body_Order_Direction)

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

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

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

type GetSubTreeRequest_Body_Order_Direction

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

type GetSubTreeResponse

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

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

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

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

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

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

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

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

type GetSubTreeResponse_Body

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

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

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

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

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

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

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

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

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

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

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

type HealthcheckRequest

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

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

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

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

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

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

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

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

type HealthcheckRequest_Body

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

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

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

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

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

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

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

type HealthcheckResponse

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

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

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

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

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

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

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

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

type HealthcheckResponse_Body

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

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

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

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

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

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

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

type KeyValue

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

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

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

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

+ func (x *KeyValue) SetKey(v string)

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

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

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

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

type LogMove

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

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

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

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

+ func (x *LogMove) SetChildId(v uint64)

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

+ func (x *LogMove) SetParentId(v uint64)

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

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

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

type MoveRequest

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

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

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

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

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

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

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

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

type MoveRequest_Body

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

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

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

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

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

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

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

+ func (x *MoveRequest_Body) SetNodeId(v uint64)

+ func (x *MoveRequest_Body) SetParentId(v uint64)

+ func (x *MoveRequest_Body) SetTreeId(v string)

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

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

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

type MoveResponse

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

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

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

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

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

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

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

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

type MoveResponse_Body

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

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

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

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

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

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

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

type RemoveRequest

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

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

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

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

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

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

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

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

type RemoveRequest_Body

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

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

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

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

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

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

+ func (x *RemoveRequest_Body) SetNodeId(v uint64)

+ func (x *RemoveRequest_Body) SetTreeId(v string)

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

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

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

type RemoveResponse

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

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

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

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

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

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

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

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

type RemoveResponse_Body

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

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

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

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

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

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

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

type Signature

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

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

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

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

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

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

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

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

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

type TreeListRequest

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

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

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

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

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

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

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

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

type TreeListRequest_Body

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

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

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

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

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

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

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

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

type TreeListResponse

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

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

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

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

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

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

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

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

type TreeListResponse_Body

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

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

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

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

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

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

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

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

Jul 23, 2024

Changes in this version

type Option

+ func WithAPELocalOverrideStorage(localOverrideStorage policyengine.LocalOverrideStorage) Option

+ func WithAPEMorphRuleStorage(morphRuleStorage policyengine.MorphRuleChainStorageReader) Option

Jun 14, 2024

Changes in this version

type Option

+ func WithNetmapState(state netmap.State) Option

May 14, 2024

Changes in this version

type Option

+ func WithFrostfsidSubjectProvider(provider frostfsidcore.SubjectProvider) Option

Apr 12, 2024

Changes in this version

type Option

+ func WithAPERouter(router policyengine.ChainRouter) Option

Mar 15, 2024

Changes in this version

type Service

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

Dec 7, 2023

Changes in this version

+ const TreeService_AddByPath_FullMethodName

+ const TreeService_Add_FullMethodName

+ const TreeService_Apply_FullMethodName

+ const TreeService_GetNodeByPath_FullMethodName

+ const TreeService_GetOpLog_FullMethodName

+ const TreeService_GetSubTree_FullMethodName

+ const TreeService_Healthcheck_FullMethodName

+ const TreeService_Move_FullMethodName

+ const TreeService_Remove_FullMethodName

+ const TreeService_TreeList_FullMethodName

+ var GetSubTreeRequest_Body_Order_Direction_name = map[int32]string

+ var GetSubTreeRequest_Body_Order_Direction_value = map[string]int32

type ContainerSource

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

type GetSubTreeRequest_Body

+ OrderBy *GetSubTreeRequest_Body_Order

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

+ type GetSubTreeRequest_Body_Order struct

+ Direction GetSubTreeRequest_Body_Order_Direction

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

+ func (*GetSubTreeRequest_Body_Order) ProtoMessage()

+ func (x *GetSubTreeRequest_Body_Order) GetDirection() GetSubTreeRequest_Body_Order_Direction

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

+ func (x *GetSubTreeRequest_Body_Order) Reset()

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

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

+ func (x *GetSubTreeRequest_Body_Order) String() string

+ type GetSubTreeRequest_Body_Order_Direction int32

+ const GetSubTreeRequest_Body_Order_Asc

+ const GetSubTreeRequest_Body_Order_None

+ func (GetSubTreeRequest_Body_Order_Direction) Descriptor() protoreflect.EnumDescriptor

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

+ func (GetSubTreeRequest_Body_Order_Direction) Type() protoreflect.EnumType

+ func (x GetSubTreeRequest_Body_Order_Direction) Enum() *GetSubTreeRequest_Body_Order_Direction

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

+ func (x GetSubTreeRequest_Body_Order_Direction) String() string

+ type MetricsRegister interface

+ AddReplicateTaskDuration func(time.Duration, bool)

+ AddReplicateWaitDuration func(time.Duration, bool)

+ AddSyncDuration func(time.Duration, bool)

type Option

+ func WithAuthorizedKeys(keys keys.PublicKeys) Option

+ func WithMetrics(v MetricsRegister) Option

Jul 12, 2023

Changes in this version

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

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

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

+ var File_pkg_services_tree_service_proto protoreflect.FileDescriptor

+ var File_pkg_services_tree_types_proto protoreflect.FileDescriptor

+ var TreeService_ServiceDesc = grpc.ServiceDesc

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

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

+ type AddByPathRequest struct

+ Body *AddByPathRequest_Body

+ Signature *Signature

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

+ func (*AddByPathRequest) ProtoMessage()

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

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

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

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

+ func (x *AddByPathRequest) Reset()

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

+ func (x *AddByPathRequest) SignedDataSize() int

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

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

+ func (x *AddByPathRequest) String() string

+ type AddByPathRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Meta []*KeyValue

+ Path []string

+ PathAttribute string

+ TreeId string

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

+ func (*AddByPathRequest_Body) ProtoMessage()

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

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

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

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

+ func (x *AddByPathRequest_Body) GetPathAttribute() string

+ func (x *AddByPathRequest_Body) GetTreeId() string

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

+ func (x *AddByPathRequest_Body) Reset()

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

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

+ func (x *AddByPathRequest_Body) String() string

+ type AddByPathResponse struct

+ Body *AddByPathResponse_Body

+ Signature *Signature

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

+ func (*AddByPathResponse) ProtoMessage()

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

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

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

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

+ func (x *AddByPathResponse) Reset()

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

+ func (x *AddByPathResponse) SignedDataSize() int

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

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

+ func (x *AddByPathResponse) String() string

+ type AddByPathResponse_Body struct

+ Nodes []uint64

+ ParentId uint64

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

+ func (*AddByPathResponse_Body) ProtoMessage()

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

+ func (x *AddByPathResponse_Body) GetParentId() uint64

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

+ func (x *AddByPathResponse_Body) Reset()

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

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

+ func (x *AddByPathResponse_Body) String() string

+ type AddRequest struct

+ Body *AddRequest_Body

+ Signature *Signature

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

+ func (*AddRequest) ProtoMessage()

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

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

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

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

+ func (x *AddRequest) Reset()

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

+ func (x *AddRequest) SignedDataSize() int

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

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

+ func (x *AddRequest) String() string

+ type AddRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Meta []*KeyValue

+ ParentId uint64

+ TreeId string

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

+ func (*AddRequest_Body) ProtoMessage()

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

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

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

+ func (x *AddRequest_Body) GetParentId() uint64

+ func (x *AddRequest_Body) GetTreeId() string

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

+ func (x *AddRequest_Body) Reset()

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

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

+ func (x *AddRequest_Body) String() string

+ type AddResponse struct

+ Body *AddResponse_Body

+ Signature *Signature

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

+ func (*AddResponse) ProtoMessage()

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

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

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

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

+ func (x *AddResponse) Reset()

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

+ func (x *AddResponse) SignedDataSize() int

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

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

+ func (x *AddResponse) String() string

+ type AddResponse_Body struct

+ NodeId uint64

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

+ func (*AddResponse_Body) ProtoMessage()

+ func (x *AddResponse_Body) GetNodeId() uint64

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

+ func (x *AddResponse_Body) Reset()

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

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

+ func (x *AddResponse_Body) String() string

+ type ApplyRequest struct

+ Body *ApplyRequest_Body

+ Signature *Signature

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

+ func (*ApplyRequest) ProtoMessage()

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

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

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

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

+ func (x *ApplyRequest) Reset()

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

+ func (x *ApplyRequest) SignedDataSize() int

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

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

+ func (x *ApplyRequest) String() string

+ type ApplyRequest_Body struct

+ ContainerId []byte

+ Operation *LogMove

+ TreeId string

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

+ func (*ApplyRequest_Body) ProtoMessage()

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

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

+ func (x *ApplyRequest_Body) GetTreeId() string

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

+ func (x *ApplyRequest_Body) Reset()

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

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

+ func (x *ApplyRequest_Body) String() string

+ type ApplyResponse struct

+ Body *ApplyResponse_Body

+ Signature *Signature

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

+ func (*ApplyResponse) ProtoMessage()

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

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

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

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

+ func (x *ApplyResponse) Reset()

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

+ func (x *ApplyResponse) SignedDataSize() int

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

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

+ func (x *ApplyResponse) String() string

+ type ApplyResponse_Body struct

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

+ func (*ApplyResponse_Body) ProtoMessage()

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

+ func (x *ApplyResponse_Body) Reset()

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

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

+ func (x *ApplyResponse_Body) String() string

+ type ContainerSource interface

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

+ type GetNodeByPathRequest struct

+ Body *GetNodeByPathRequest_Body

+ Signature *Signature

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

+ func (*GetNodeByPathRequest) ProtoMessage()

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

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

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

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

+ func (x *GetNodeByPathRequest) Reset()

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

+ func (x *GetNodeByPathRequest) SignedDataSize() int

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

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

+ func (x *GetNodeByPathRequest) String() string

+ type GetNodeByPathRequest_Body struct

+ AllAttributes bool

+ Attributes []string

+ BearerToken []byte

+ ContainerId []byte

+ LatestOnly bool

+ Path []string

+ PathAttribute string

+ TreeId string

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

+ func (*GetNodeByPathRequest_Body) ProtoMessage()

+ func (x *GetNodeByPathRequest_Body) GetAllAttributes() bool

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

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

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

+ func (x *GetNodeByPathRequest_Body) GetLatestOnly() bool

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

+ func (x *GetNodeByPathRequest_Body) GetPathAttribute() string

+ func (x *GetNodeByPathRequest_Body) GetTreeId() string

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

+ func (x *GetNodeByPathRequest_Body) Reset()

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

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

+ func (x *GetNodeByPathRequest_Body) String() string

+ type GetNodeByPathResponse struct

+ Body *GetNodeByPathResponse_Body

+ Signature *Signature

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

+ func (*GetNodeByPathResponse) ProtoMessage()

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

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

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

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

+ func (x *GetNodeByPathResponse) Reset()

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

+ func (x *GetNodeByPathResponse) SignedDataSize() int

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

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

+ func (x *GetNodeByPathResponse) String() string

+ type GetNodeByPathResponse_Body struct

+ Nodes []*GetNodeByPathResponse_Info

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

+ func (*GetNodeByPathResponse_Body) ProtoMessage()

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

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

+ func (x *GetNodeByPathResponse_Body) Reset()

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

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

+ func (x *GetNodeByPathResponse_Body) String() string

+ type GetNodeByPathResponse_Info struct

+ Meta []*KeyValue

+ NodeId uint64

+ ParentId uint64

+ Timestamp uint64

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

+ func (*GetNodeByPathResponse_Info) ProtoMessage()

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

+ func (x *GetNodeByPathResponse_Info) GetNodeId() uint64

+ func (x *GetNodeByPathResponse_Info) GetParentId() uint64

+ func (x *GetNodeByPathResponse_Info) GetTimestamp() uint64

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

+ func (x *GetNodeByPathResponse_Info) Reset()

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

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

+ func (x *GetNodeByPathResponse_Info) String() string

+ type GetOpLogRequest struct

+ Body *GetOpLogRequest_Body

+ Signature *Signature

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

+ func (*GetOpLogRequest) ProtoMessage()

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

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

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

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

+ func (x *GetOpLogRequest) Reset()

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

+ func (x *GetOpLogRequest) SignedDataSize() int

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

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

+ func (x *GetOpLogRequest) String() string

+ type GetOpLogRequest_Body struct

+ ContainerId []byte

+ Count uint64

+ Height uint64

+ TreeId string

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

+ func (*GetOpLogRequest_Body) ProtoMessage()

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

+ func (x *GetOpLogRequest_Body) GetCount() uint64

+ func (x *GetOpLogRequest_Body) GetHeight() uint64

+ func (x *GetOpLogRequest_Body) GetTreeId() string

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

+ func (x *GetOpLogRequest_Body) Reset()

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

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

+ func (x *GetOpLogRequest_Body) String() string

+ type GetOpLogResponse struct

+ Body *GetOpLogResponse_Body

+ Signature *Signature

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

+ func (*GetOpLogResponse) ProtoMessage()

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

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

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

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

+ func (x *GetOpLogResponse) Reset()

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

+ func (x *GetOpLogResponse) SignedDataSize() int

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

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

+ func (x *GetOpLogResponse) String() string

+ type GetOpLogResponse_Body struct

+ Operation *LogMove

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

+ func (*GetOpLogResponse_Body) ProtoMessage()

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

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

+ func (x *GetOpLogResponse_Body) Reset()

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

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

+ func (x *GetOpLogResponse_Body) String() string

+ type GetSubTreeRequest struct

+ Body *GetSubTreeRequest_Body

+ Signature *Signature

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

+ func (*GetSubTreeRequest) ProtoMessage()

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

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

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

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

+ func (x *GetSubTreeRequest) Reset()

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

+ func (x *GetSubTreeRequest) SignedDataSize() int

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

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

+ func (x *GetSubTreeRequest) String() string

+ type GetSubTreeRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Depth uint32

+ RootId uint64

+ TreeId string

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

+ func (*GetSubTreeRequest_Body) ProtoMessage()

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

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

+ func (x *GetSubTreeRequest_Body) GetDepth() uint32

+ func (x *GetSubTreeRequest_Body) GetRootId() uint64

+ func (x *GetSubTreeRequest_Body) GetTreeId() string

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

+ func (x *GetSubTreeRequest_Body) Reset()

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

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

+ func (x *GetSubTreeRequest_Body) String() string

+ type GetSubTreeResponse struct

+ Body *GetSubTreeResponse_Body

+ Signature *Signature

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

+ func (*GetSubTreeResponse) ProtoMessage()

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

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

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

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

+ func (x *GetSubTreeResponse) Reset()

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

+ func (x *GetSubTreeResponse) SignedDataSize() int

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

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

+ func (x *GetSubTreeResponse) String() string

+ type GetSubTreeResponse_Body struct

+ Meta []*KeyValue

+ NodeId uint64

+ ParentId uint64

+ Timestamp uint64

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

+ func (*GetSubTreeResponse_Body) ProtoMessage()

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

+ func (x *GetSubTreeResponse_Body) GetNodeId() uint64

+ func (x *GetSubTreeResponse_Body) GetParentId() uint64

+ func (x *GetSubTreeResponse_Body) GetTimestamp() uint64

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

+ func (x *GetSubTreeResponse_Body) Reset()

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

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

+ func (x *GetSubTreeResponse_Body) String() string

+ type HealthcheckRequest struct

+ Body *HealthcheckRequest_Body

+ Signature *Signature

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

+ func (*HealthcheckRequest) ProtoMessage()

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

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

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

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

+ func (x *HealthcheckRequest) Reset()

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

+ func (x *HealthcheckRequest) SignedDataSize() int

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

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

+ func (x *HealthcheckRequest) String() string

+ type HealthcheckRequest_Body struct

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

+ func (*HealthcheckRequest_Body) ProtoMessage()

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

+ func (x *HealthcheckRequest_Body) Reset()

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

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

+ func (x *HealthcheckRequest_Body) String() string

+ type HealthcheckResponse struct

+ Body *HealthcheckResponse_Body

+ Signature *Signature

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

+ func (*HealthcheckResponse) ProtoMessage()

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

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

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

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

+ func (x *HealthcheckResponse) Reset()

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

+ func (x *HealthcheckResponse) SignedDataSize() int

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

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

+ func (x *HealthcheckResponse) String() string

+ type HealthcheckResponse_Body struct

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

+ func (*HealthcheckResponse_Body) ProtoMessage()

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

+ func (x *HealthcheckResponse_Body) Reset()

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

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

+ func (x *HealthcheckResponse_Body) String() string

+ type KeyValue struct

+ Key string

+ Value []byte

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

+ func (*KeyValue) ProtoMessage()

+ func (x *KeyValue) GetKey() string

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

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

+ func (x *KeyValue) Reset()

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

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

+ func (x *KeyValue) String() string

+ type LogMove struct

+ ChildId uint64

+ Meta []byte

+ ParentId uint64

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

+ func (*LogMove) ProtoMessage()

+ func (x *LogMove) GetChildId() uint64

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

+ func (x *LogMove) GetParentId() uint64

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

+ func (x *LogMove) Reset()

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

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

+ func (x *LogMove) String() string

+ type MoveRequest struct

+ Body *MoveRequest_Body

+ Signature *Signature

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

+ func (*MoveRequest) ProtoMessage()

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

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

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

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

+ func (x *MoveRequest) Reset()

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

+ func (x *MoveRequest) SignedDataSize() int

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

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

+ func (x *MoveRequest) String() string

+ type MoveRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ Meta []*KeyValue

+ NodeId uint64

+ ParentId uint64

+ TreeId string

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

+ func (*MoveRequest_Body) ProtoMessage()

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

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

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

+ func (x *MoveRequest_Body) GetNodeId() uint64

+ func (x *MoveRequest_Body) GetParentId() uint64

+ func (x *MoveRequest_Body) GetTreeId() string

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

+ func (x *MoveRequest_Body) Reset()

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

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

+ func (x *MoveRequest_Body) String() string

+ type MoveResponse struct

+ Body *MoveResponse_Body

+ Signature *Signature

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

+ func (*MoveResponse) ProtoMessage()

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

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

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

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

+ func (x *MoveResponse) Reset()

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

+ func (x *MoveResponse) SignedDataSize() int

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

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

+ func (x *MoveResponse) String() string

+ type MoveResponse_Body struct

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

+ func (*MoveResponse_Body) ProtoMessage()

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

+ func (x *MoveResponse_Body) Reset()

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

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

+ func (x *MoveResponse_Body) String() string

+ type Option func(*cfg)

+ func WithContainerCacheSize(n int) Option

+ func WithContainerSource(src ContainerSource) Option

+ func WithEACLSource(src container.EACLSource) Option

+ func WithLogger(log *logger.Logger) Option

+ func WithNetmapSource(src netmap.Source) Option

+ func WithPrivateKey(key *ecdsa.PrivateKey) Option

+ func WithReplicationChannelCapacity(n int) Option

+ func WithReplicationTimeout(t time.Duration) Option

+ func WithReplicationWorkerCount(n int) Option

+ func WithStorage(s pilorama.Forest) Option

+ type RemoveRequest struct

+ Body *RemoveRequest_Body

+ Signature *Signature

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

+ func (*RemoveRequest) ProtoMessage()

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

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

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

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

+ func (x *RemoveRequest) Reset()

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

+ func (x *RemoveRequest) SignedDataSize() int

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

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

+ func (x *RemoveRequest) String() string

+ type RemoveRequest_Body struct

+ BearerToken []byte

+ ContainerId []byte

+ NodeId uint64

+ TreeId string

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

+ func (*RemoveRequest_Body) ProtoMessage()

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

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

+ func (x *RemoveRequest_Body) GetNodeId() uint64

+ func (x *RemoveRequest_Body) GetTreeId() string

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

+ func (x *RemoveRequest_Body) Reset()

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

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

+ func (x *RemoveRequest_Body) String() string

+ type RemoveResponse struct

+ Body *RemoveResponse_Body

+ Signature *Signature

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

+ func (*RemoveResponse) ProtoMessage()

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

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

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

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

+ func (x *RemoveResponse) Reset()

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

+ func (x *RemoveResponse) SignedDataSize() int

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

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

+ func (x *RemoveResponse) String() string

+ type RemoveResponse_Body struct

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

+ func (*RemoveResponse_Body) ProtoMessage()

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

+ func (x *RemoveResponse_Body) Reset()

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

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

+ func (x *RemoveResponse_Body) String() string

+ type Service struct

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

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

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

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

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

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

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

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

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

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

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

+ func (s *Service) Shutdown()

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

+ func (s *Service) SynchronizeAll() error

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

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

+ type Signature struct

+ Key []byte

+ Sign []byte

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

+ func (*Signature) ProtoMessage()

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

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

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

+ func (x *Signature) Reset()

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

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

+ func (x *Signature) String() string

+ type TreeListRequest struct

+ Body *TreeListRequest_Body

+ Signature *Signature

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

+ func (*TreeListRequest) ProtoMessage()

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

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

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

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

+ func (x *TreeListRequest) Reset()

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

+ func (x *TreeListRequest) SignedDataSize() int

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

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

+ func (x *TreeListRequest) String() string

+ type TreeListRequest_Body struct

+ ContainerId []byte

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

+ func (*TreeListRequest_Body) ProtoMessage()

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

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

+ func (x *TreeListRequest_Body) Reset()

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

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

+ func (x *TreeListRequest_Body) String() string

+ type TreeListResponse struct

+ Body *TreeListResponse_Body

+ Signature *Signature

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

+ func (*TreeListResponse) ProtoMessage()

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

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

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

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

+ func (x *TreeListResponse) Reset()

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

+ func (x *TreeListResponse) SignedDataSize() int

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

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

+ func (x *TreeListResponse) String() string

+ type TreeListResponse_Body struct

+ Ids []string

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

+ func (*TreeListResponse_Body) ProtoMessage()

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

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

+ func (x *TreeListResponse_Body) Reset()

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

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

+ func (x *TreeListResponse_Body) String() string

+ type TreeServiceClient interface

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

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

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

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

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

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

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

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

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

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

+ func NewTreeServiceClient(cc grpc.ClientConnInterface) TreeServiceClient

+ type TreeServiceServer interface

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

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

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

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

+ GetOpLog func(*GetOpLogRequest, TreeService_GetOpLogServer) error

+ GetSubTree func(*GetSubTreeRequest, TreeService_GetSubTreeServer) error

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

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

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

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

+ type TreeService_GetOpLogClient interface

+ Recv func() (*GetOpLogResponse, error)

+ type TreeService_GetOpLogServer interface

+ Send func(*GetOpLogResponse) error

+ type TreeService_GetSubTreeClient interface

+ Recv func() (*GetSubTreeResponse, error)

+ type TreeService_GetSubTreeServer interface

+ Send func(*GetSubTreeResponse) error

+ type UnimplementedTreeServiceServer struct

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

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

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

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

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

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

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

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

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

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

+ type UnsafeTreeServiceServer interface