ctl

package

Go to main page

Versions in this module

v1

v1.0.2

Dec 21, 2023

v1.0.1

Dec 15, 2023

Changes in this version

type CmdMethod

+ const CmdMethod_StorageUsage

v1.0.0

Nov 13, 2023

Changes in this version

type CmdMethod

+ const CmdMethod_AddFaultPoint

+ const CmdMethod_Backup

+ const CmdMethod_TraceSpan

+ type TNPingRequest struct

+ Parameter string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TNPingRequest) ProtoMessage()

+ func (m *TNPingRequest) GetParameter() string

+ func (m *TNPingRequest) Marshal() (dAtA []byte, err error)

+ func (m *TNPingRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNPingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNPingRequest) Reset()

+ func (m *TNPingRequest) Size() (n int)

+ func (m *TNPingRequest) String() string

+ func (m *TNPingRequest) Unmarshal(dAtA []byte) error

+ func (m *TNPingRequest) XXX_DiscardUnknown()

+ func (m *TNPingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNPingRequest) XXX_Merge(src proto.Message)

+ func (m *TNPingRequest) XXX_Size() int

+ func (m *TNPingRequest) XXX_Unmarshal(b []byte) error

+ type TNPingResponse struct

+ LogShardID uint64

+ ReplicaID uint64

+ ServiceAddress string

+ ShardID uint64

+ StoreID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TNPingResponse) ProtoMessage()

+ func (m *TNPingResponse) GetLogShardID() uint64

+ func (m *TNPingResponse) GetReplicaID() uint64

+ func (m *TNPingResponse) GetServiceAddress() string

+ func (m *TNPingResponse) GetShardID() uint64

+ func (m *TNPingResponse) GetStoreID() string

+ func (m *TNPingResponse) Marshal() (dAtA []byte, err error)

+ func (m *TNPingResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNPingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNPingResponse) Reset()

+ func (m *TNPingResponse) Size() (n int)

+ func (m *TNPingResponse) String() string

+ func (m *TNPingResponse) Unmarshal(dAtA []byte) error

+ func (m *TNPingResponse) XXX_DiscardUnknown()

+ func (m *TNPingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNPingResponse) XXX_Merge(src proto.Message)

+ func (m *TNPingResponse) XXX_Size() int

+ func (m *TNPingResponse) XXX_Unmarshal(b []byte) error

+ type TNStringResponse struct

+ ReturnStr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TNStringResponse) ProtoMessage()

+ func (m *TNStringResponse) GetReturnStr() string

+ func (m *TNStringResponse) Marshal() (dAtA []byte, err error)

+ func (m *TNStringResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNStringResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNStringResponse) Reset()

+ func (m *TNStringResponse) Size() (n int)

+ func (m *TNStringResponse) String() string

+ func (m *TNStringResponse) Unmarshal(dAtA []byte) error

+ func (m *TNStringResponse) XXX_DiscardUnknown()

+ func (m *TNStringResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNStringResponse) XXX_Merge(src proto.Message)

+ func (m *TNStringResponse) XXX_Size() int

+ func (m *TNStringResponse) XXX_Unmarshal(b []byte) error

v1.0.0-rc2

Oct 24, 2023

v1.0.0-rc1

Aug 24, 2023

v0

v0.8.1

Oct 9, 2023

v0.8.0

Jun 30, 2023

Changes in this version

type CmdMethod

+ const CmdMethod_GetCommit

+ const CmdMethod_Label

+ const CmdMethod_SyncCommit

+ type GetCommitRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCommitRequest) ProtoMessage()

+ func (m *GetCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetCommitRequest) Reset()

+ func (m *GetCommitRequest) Size() (n int)

+ func (m *GetCommitRequest) String() string

+ func (m *GetCommitRequest) Unmarshal(dAtA []byte) error

+ func (m *GetCommitRequest) XXX_DiscardUnknown()

+ func (m *GetCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetCommitRequest) XXX_Merge(src proto.Message)

+ func (m *GetCommitRequest) XXX_Size() int

+ func (m *GetCommitRequest) XXX_Unmarshal(b []byte) error

+ type GetCommitResponse struct

+ CurrentCommitTS timestamp.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetCommitResponse) ProtoMessage()

+ func (m *GetCommitResponse) GetCurrentCommitTS() timestamp.Timestamp

+ func (m *GetCommitResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetCommitResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetCommitResponse) Reset()

+ func (m *GetCommitResponse) Size() (n int)

+ func (m *GetCommitResponse) String() string

+ func (m *GetCommitResponse) Unmarshal(dAtA []byte) error

+ func (m *GetCommitResponse) XXX_DiscardUnknown()

+ func (m *GetCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetCommitResponse) XXX_Merge(src proto.Message)

+ func (m *GetCommitResponse) XXX_Size() int

+ func (m *GetCommitResponse) XXX_Unmarshal(b []byte) error

+ type Request struct

+ CMDMethod CmdMethod

+ GetCommit SyncCommitRequest

+ RequestID uint64

+ SycnCommit SyncCommitRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Request) ProtoMessage()

+ func (m *Request) DebugString() string

+ func (m *Request) GetCMDMethod() CmdMethod

+ func (m *Request) GetGetCommit() SyncCommitRequest

+ func (m *Request) GetID() uint64

+ func (m *Request) GetRequestID() uint64

+ func (m *Request) GetSycnCommit() SyncCommitRequest

+ func (m *Request) Marshal() (dAtA []byte, err error)

+ func (m *Request) MarshalTo(dAtA []byte) (int, error)

+ func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Request) Method() uint32

+ func (m *Request) Reset()

+ func (m *Request) SetID(id uint64)

+ func (m *Request) SetMethod(v uint32)

+ func (m *Request) Size() (n int)

+ func (m *Request) String() string

+ func (m *Request) Unmarshal(dAtA []byte) error

+ func (m *Request) UnwrapError() error

+ func (m *Request) WrapError(err error)

+ func (m *Request) XXX_DiscardUnknown()

+ func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Request) XXX_Merge(src proto.Message)

+ func (m *Request) XXX_Size() int

+ func (m *Request) XXX_Unmarshal(b []byte) error

+ type Response struct

+ CMDMethod CmdMethod

+ Error []byte

+ GetCommit GetCommitResponse

+ RequestID uint64

+ SycnCommit SyncCommitResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Response) ProtoMessage()

+ func (m *Response) DebugString() string

+ func (m *Response) GetCMDMethod() CmdMethod

+ func (m *Response) GetError() []byte

+ func (m *Response) GetGetCommit() GetCommitResponse

+ func (m *Response) GetID() uint64

+ func (m *Response) GetRequestID() uint64

+ func (m *Response) GetSycnCommit() SyncCommitResponse

+ func (m *Response) Marshal() (dAtA []byte, err error)

+ func (m *Response) MarshalTo(dAtA []byte) (int, error)

+ func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Response) Method() uint32

+ func (m *Response) Reset()

+ func (m *Response) SetID(id uint64)

+ func (m *Response) SetMethod(v uint32)

+ func (m *Response) Size() (n int)

+ func (m *Response) String() string

+ func (m *Response) Unmarshal(dAtA []byte) error

+ func (m *Response) UnwrapError() error

+ func (m *Response) WrapError(err error)

+ func (m *Response) XXX_DiscardUnknown()

+ func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Response) XXX_Merge(src proto.Message)

+ func (m *Response) XXX_Size() int

+ func (m *Response) XXX_Unmarshal(b []byte) error

+ type SyncCommitRequest struct

+ LatestCommitTS timestamp.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SyncCommitRequest) ProtoMessage()

+ func (m *SyncCommitRequest) GetLatestCommitTS() timestamp.Timestamp

+ func (m *SyncCommitRequest) Marshal() (dAtA []byte, err error)

+ func (m *SyncCommitRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyncCommitRequest) Reset()

+ func (m *SyncCommitRequest) Size() (n int)

+ func (m *SyncCommitRequest) String() string

+ func (m *SyncCommitRequest) Unmarshal(dAtA []byte) error

+ func (m *SyncCommitRequest) XXX_DiscardUnknown()

+ func (m *SyncCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncCommitRequest) XXX_Merge(src proto.Message)

+ func (m *SyncCommitRequest) XXX_Size() int

+ func (m *SyncCommitRequest) XXX_Unmarshal(b []byte) error

+ type SyncCommitResponse struct

+ CurrentCommitTS timestamp.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SyncCommitResponse) ProtoMessage()

+ func (m *SyncCommitResponse) GetCurrentCommitTS() timestamp.Timestamp

+ func (m *SyncCommitResponse) Marshal() (dAtA []byte, err error)

+ func (m *SyncCommitResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyncCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyncCommitResponse) Reset()

+ func (m *SyncCommitResponse) Size() (n int)

+ func (m *SyncCommitResponse) String() string

+ func (m *SyncCommitResponse) Unmarshal(dAtA []byte) error

+ func (m *SyncCommitResponse) XXX_DiscardUnknown()

+ func (m *SyncCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyncCommitResponse) XXX_Merge(src proto.Message)

+ func (m *SyncCommitResponse) XXX_Size() int

+ func (m *SyncCommitResponse) XXX_Unmarshal(b []byte) error

v0.7.0

Feb 18, 2023

Changes in this version

type CmdMethod

+ const CmdMethod_Checkpoint

+ const CmdMethod_ForceGC

+ const CmdMethod_GetSnapshot

+ const CmdMethod_Inspect

+ const CmdMethod_UseSnapshot

v0.6.0

Nov 29, 2022

Changes in this version

+ var CmdMethod_name = map[int32]string

+ var CmdMethod_value = map[string]int32

+ var ErrIntOverflowCtl = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCtl = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupCtl = fmt.Errorf("proto: unexpected end of group")

+ type CmdMethod int32

+ const CmdMethod_Flush

+ const CmdMethod_Ping

+ const CmdMethod_Task

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

+ func (x CmdMethod) String() string

+ type CtlResult struct

+ Data interface{}

+ Method string

+ type DNPingRequest struct

+ Parameter string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DNPingRequest) ProtoMessage()

+ func (m *DNPingRequest) GetParameter() string

+ func (m *DNPingRequest) Marshal() (dAtA []byte, err error)

+ func (m *DNPingRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNPingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNPingRequest) Reset()

+ func (m *DNPingRequest) Size() (n int)

+ func (m *DNPingRequest) String() string

+ func (m *DNPingRequest) Unmarshal(dAtA []byte) error

+ func (m *DNPingRequest) XXX_DiscardUnknown()

+ func (m *DNPingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNPingRequest) XXX_Merge(src proto.Message)

+ func (m *DNPingRequest) XXX_Size() int

+ func (m *DNPingRequest) XXX_Unmarshal(b []byte) error

+ type DNPingResponse struct

+ LogShardID uint64

+ ReplicaID uint64

+ ServiceAddress string

+ ShardID uint64

+ StoreID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DNPingResponse) ProtoMessage()

+ func (m *DNPingResponse) GetLogShardID() uint64

+ func (m *DNPingResponse) GetReplicaID() uint64

+ func (m *DNPingResponse) GetServiceAddress() string

+ func (m *DNPingResponse) GetShardID() uint64

+ func (m *DNPingResponse) GetStoreID() string

+ func (m *DNPingResponse) Marshal() (dAtA []byte, err error)

+ func (m *DNPingResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNPingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNPingResponse) Reset()

+ func (m *DNPingResponse) Size() (n int)

+ func (m *DNPingResponse) String() string

+ func (m *DNPingResponse) Unmarshal(dAtA []byte) error

+ func (m *DNPingResponse) XXX_DiscardUnknown()

+ func (m *DNPingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNPingResponse) XXX_Merge(src proto.Message)

+ func (m *DNPingResponse) XXX_Size() int

+ func (m *DNPingResponse) XXX_Unmarshal(b []byte) error

+ type DNStringResponse struct

+ ReturnStr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DNStringResponse) ProtoMessage()

+ func (m *DNStringResponse) GetReturnStr() string

+ func (m *DNStringResponse) Marshal() (dAtA []byte, err error)

+ func (m *DNStringResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNStringResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNStringResponse) Reset()

+ func (m *DNStringResponse) Size() (n int)

+ func (m *DNStringResponse) String() string

+ func (m *DNStringResponse) Unmarshal(dAtA []byte) error

+ func (m *DNStringResponse) XXX_DiscardUnknown()

+ func (m *DNStringResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNStringResponse) XXX_Merge(src proto.Message)

+ func (m *DNStringResponse) XXX_Size() int

+ func (m *DNStringResponse) XXX_Unmarshal(b []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL