ctl

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCtl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCtl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCtl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CmdMethod_name = map[int32]string{
	0:  "Ping",
	1:  "Flush",
	2:  "Task",
	3:  "Checkpoint",
	4:  "UseSnapshot",
	5:  "GetSnapshot",
	6:  "ForceGC",
	7:  "Inspect",
	8:  "Label",
	9:  "SyncCommit",
	10: "GetCommit",
}
View Source 
var CmdMethod_value = map[string]int32{
	"Ping":        0,
	"Flush":       1,
	"Task":        2,
	"Checkpoint":  3,
	"UseSnapshot": 4,
	"GetSnapshot": 5,
	"ForceGC":     6,
	"Inspect":     7,
	"Label":       8,
	"SyncCommit":  9,
	"GetCommit":   10,
}

Functions

This section is empty.

Types

type CmdMethod 

type CmdMethod int32

CmdMethod debug command method 

const (
	// Ping ping the service.
	CmdMethod_Ping CmdMethod = 0
	// Flush is to force flush the table data.
	// parameter should be "DbName.TableName"
	CmdMethod_Flush CmdMethod = 1
	// Task disable or enable task framework
	CmdMethod_Task CmdMethod = 2
	// Checkpoint is to force incremental checkpoint.
	CmdMethod_Checkpoint CmdMethod = 3
	// UseSnapshot use a spec snapshot timestamp, and all txn will use this ts as snapshot timestamp
	CmdMethod_UseSnapshot CmdMethod = 4
	// GetSnapshot get current snapshot timestamp
	CmdMethod_GetSnapshot CmdMethod = 5
	// ForceGC forcing a GC to free memory
	CmdMethod_ForceGC CmdMethod = 6
	// Inspect DN info
	CmdMethod_Inspect CmdMethod = 7
	// Label sets the CN label.
	CmdMethod_Label CmdMethod = 8
	// SyncCommit when we turn on Push, some BVT tests use multiple Sessions in multi-CN scenarios. To
	// ensure data visibility, we need to synchronize CommitTS between multiple CNs so that the whole
	// cluster can see the latest writes from other CNs.
	CmdMethod_SyncCommit CmdMethod = 9
	// GetCommit get latest commit timestamp of cn.
	CmdMethod_GetCommit CmdMethod = 10
)

func (CmdMethod) EnumDescriptor 

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

func (CmdMethod) String 

func (x CmdMethod) String() string

type CtlResult 

type CtlResult struct {
	Method string      `json:"method"`
	Data   interface{} `json:"result"`
}

CtlResult ctl result

type DNPingRequest 

type DNPingRequest struct {
	Parameter            string   `protobuf:"bytes,1,opt,name=parameter,proto3" json:"parameter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DNPingRequest ping request

func (*DNPingRequest) Descriptor 

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

func (*DNPingRequest) GetParameter 

func (m *DNPingRequest) GetParameter() string

func (*DNPingRequest) Marshal 

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

func (*DNPingRequest) MarshalTo 

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

func (*DNPingRequest) MarshalToSizedBuffer 

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

func (*DNPingRequest) ProtoMessage 

func (*DNPingRequest) ProtoMessage()

func (*DNPingRequest) Reset 

func (m *DNPingRequest) Reset()

func (*DNPingRequest) Size 

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

func (*DNPingRequest) String 

func (m *DNPingRequest) String() string

func (*DNPingRequest) Unmarshal 

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

func (*DNPingRequest) XXX_DiscardUnknown 

func (m *DNPingRequest) XXX_DiscardUnknown()

func (*DNPingRequest) XXX_Marshal 

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

func (*DNPingRequest) XXX_Merge 

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

func (*DNPingRequest) XXX_Size 

func (m *DNPingRequest) XXX_Size() int

func (*DNPingRequest) XXX_Unmarshal 

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

type DNPingResponse 

type DNPingResponse struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ServiceAddress       string   `protobuf:"bytes,2,opt,name=serviceAddress,proto3" json:"serviceAddress,omitempty"`
	ShardID              uint64   `protobuf:"varint,3,opt,name=shardID,proto3" json:"shardID,omitempty"`
	ReplicaID            uint64   `protobuf:"varint,4,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	LogShardID           uint64   `protobuf:"varint,5,opt,name=logShardID,proto3" json:"logShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DNPingResponse ping response

func (*DNPingResponse) Descriptor 

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

func (*DNPingResponse) GetLogShardID 

func (m *DNPingResponse) GetLogShardID() uint64

func (*DNPingResponse) GetReplicaID 

func (m *DNPingResponse) GetReplicaID() uint64

func (*DNPingResponse) GetServiceAddress 

func (m *DNPingResponse) GetServiceAddress() string

func (*DNPingResponse) GetShardID 

func (m *DNPingResponse) GetShardID() uint64

func (*DNPingResponse) GetStoreID 

func (m *DNPingResponse) GetStoreID() string

func (*DNPingResponse) Marshal 

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

func (*DNPingResponse) MarshalTo 

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

func (*DNPingResponse) MarshalToSizedBuffer 

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

func (*DNPingResponse) ProtoMessage 

func (*DNPingResponse) ProtoMessage()

func (*DNPingResponse) Reset 

func (m *DNPingResponse) Reset()

func (*DNPingResponse) Size 

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

func (*DNPingResponse) String 

func (m *DNPingResponse) String() string

func (*DNPingResponse) Unmarshal 

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

func (*DNPingResponse) XXX_DiscardUnknown 

func (m *DNPingResponse) XXX_DiscardUnknown()

func (*DNPingResponse) XXX_Marshal 

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

func (*DNPingResponse) XXX_Merge 

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

func (*DNPingResponse) XXX_Size 

func (m *DNPingResponse) XXX_Size() int

func (*DNPingResponse) XXX_Unmarshal 

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

type DNStringResponse 

type DNStringResponse struct {
	ReturnStr            string   `protobuf:"bytes,1,opt,name=returnStr,proto3" json:"returnStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DNStringResponse string type response

func (*DNStringResponse) Descriptor 

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

func (*DNStringResponse) GetReturnStr 

func (m *DNStringResponse) GetReturnStr() string

func (*DNStringResponse) Marshal 

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

func (*DNStringResponse) MarshalTo 

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

func (*DNStringResponse) MarshalToSizedBuffer 

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

func (*DNStringResponse) ProtoMessage 

func (*DNStringResponse) ProtoMessage()

func (*DNStringResponse) Reset 

func (m *DNStringResponse) Reset()

func (*DNStringResponse) Size 

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

func (*DNStringResponse) String 

func (m *DNStringResponse) String() string

func (*DNStringResponse) Unmarshal 

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

func (*DNStringResponse) XXX_DiscardUnknown 

func (m *DNStringResponse) XXX_DiscardUnknown()

func (*DNStringResponse) XXX_Marshal 

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

func (*DNStringResponse) XXX_Merge 

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

func (*DNStringResponse) XXX_Size 

func (m *DNStringResponse) XXX_Size() int

func (*DNStringResponse) XXX_Unmarshal 

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

type GetCommitRequest added in v0.8.0 

type GetCommitRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetCommitRequest get commit timestamp request

func (*GetCommitRequest) Descriptor added in v0.8.0 

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

func (*GetCommitRequest) Marshal added in v0.8.0 

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

func (*GetCommitRequest) MarshalTo added in v0.8.0 

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

func (*GetCommitRequest) MarshalToSizedBuffer added in v0.8.0 

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

func (*GetCommitRequest) ProtoMessage added in v0.8.0 

func (*GetCommitRequest) ProtoMessage()

func (*GetCommitRequest) Reset added in v0.8.0 

func (m *GetCommitRequest) Reset()

func (*GetCommitRequest) Size added in v0.8.0 

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

func (*GetCommitRequest) String added in v0.8.0 

func (m *GetCommitRequest) String() string

func (*GetCommitRequest) Unmarshal added in v0.8.0 

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

func (*GetCommitRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *GetCommitRequest) XXX_DiscardUnknown()

func (*GetCommitRequest) XXX_Marshal added in v0.8.0 

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

func (*GetCommitRequest) XXX_Merge added in v0.8.0 

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

func (*GetCommitRequest) XXX_Size added in v0.8.0 

func (m *GetCommitRequest) XXX_Size() int

func (*GetCommitRequest) XXX_Unmarshal added in v0.8.0 

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

type GetCommitResponse added in v0.8.0 

type GetCommitResponse struct {
	// CurrentCommitTS current commit timestamp after sync
	CurrentCommitTS      timestamp.Timestamp `protobuf:"bytes,1,opt,name=CurrentCommitTS,proto3" json:"CurrentCommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

GetCommitResponse get commit timestamp response

func (*GetCommitResponse) Descriptor added in v0.8.0 

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

func (*GetCommitResponse) GetCurrentCommitTS added in v0.8.0 

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

func (*GetCommitResponse) Marshal added in v0.8.0 

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

func (*GetCommitResponse) MarshalTo added in v0.8.0 

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

func (*GetCommitResponse) MarshalToSizedBuffer added in v0.8.0 

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

func (*GetCommitResponse) ProtoMessage added in v0.8.0 

func (*GetCommitResponse) ProtoMessage()

func (*GetCommitResponse) Reset added in v0.8.0 

func (m *GetCommitResponse) Reset()

func (*GetCommitResponse) Size added in v0.8.0 

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

func (*GetCommitResponse) String added in v0.8.0 

func (m *GetCommitResponse) String() string

func (*GetCommitResponse) Unmarshal added in v0.8.0 

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

func (*GetCommitResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *GetCommitResponse) XXX_DiscardUnknown()

func (*GetCommitResponse) XXX_Marshal added in v0.8.0 

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

func (*GetCommitResponse) XXX_Merge added in v0.8.0 

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

func (*GetCommitResponse) XXX_Size added in v0.8.0 

func (m *GetCommitResponse) XXX_Size() int

func (*GetCommitResponse) XXX_Unmarshal added in v0.8.0 

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

type Request added in v0.8.0 

type Request struct {
	// RequestID request id
	RequestID            uint64            `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	CMDMethod            CmdMethod         `protobuf:"varint,2,opt,name=CMDMethod,proto3,enum=ctl.CmdMethod" json:"CMDMethod,omitempty"`
	SycnCommit           SyncCommitRequest `protobuf:"bytes,3,opt,name=SycnCommit,proto3" json:"SycnCommit"`
	GetCommit            SyncCommitRequest `protobuf:"bytes,4,opt,name=GetCommit,proto3" json:"GetCommit"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Request is used to send a request for a ctl service related operation to another ctl service.

func (*Request) DebugString added in v0.8.0 

func (m *Request) DebugString() string

DebugString returns the debug string

func (*Request) Descriptor added in v0.8.0 

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

func (*Request) GetCMDMethod added in v0.8.0 

func (m *Request) GetCMDMethod() CmdMethod

func (*Request) GetGetCommit added in v0.8.0 

func (m *Request) GetGetCommit() SyncCommitRequest

func (*Request) GetID added in v0.8.0 

func (m *Request) GetID() uint64

GetID implement morpc Messgae

func (*Request) GetRequestID added in v0.8.0 

func (m *Request) GetRequestID() uint64

func (*Request) GetSycnCommit added in v0.8.0 

func (m *Request) GetSycnCommit() SyncCommitRequest

func (*Request) Marshal added in v0.8.0 

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

func (*Request) MarshalTo added in v0.8.0 

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

func (*Request) MarshalToSizedBuffer added in v0.8.0 

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

func (*Request) Method added in v0.8.0 

func (m *Request) Method() uint32

func (*Request) ProtoMessage added in v0.8.0 

func (*Request) ProtoMessage()

func (*Request) Reset added in v0.8.0 

func (m *Request) Reset()

func (*Request) SetID added in v0.8.0 

func (m *Request) SetID(id uint64)

SetID implement morpc Messgae

func (*Request) SetMethod added in v0.8.0 

func (m *Request) SetMethod(v uint32)

func (*Request) Size added in v0.8.0 

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

func (*Request) String added in v0.8.0 

func (m *Request) String() string

func (*Request) Unmarshal added in v0.8.0 

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

func (*Request) UnwrapError added in v0.8.0 

func (m *Request) UnwrapError() error

func (*Request) WrapError added in v0.8.0 

func (m *Request) WrapError(err error)

func (*Request) XXX_DiscardUnknown added in v0.8.0 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal added in v0.8.0 

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

func (*Request) XXX_Merge added in v0.8.0 

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

func (*Request) XXX_Size added in v0.8.0 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal added in v0.8.0 

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

type Response added in v0.8.0 

type Response struct {
	// RequestID corresponding request id
	RequestID uint64    `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	CMDMethod CmdMethod `protobuf:"varint,2,opt,name=CMDMethod,proto3,enum=ctl.CmdMethod" json:"CMDMethod,omitempty"`
	// Error we use this field to send moerr from service to another service. Set
	// with moerr.MarshalBinary, and use moerr.UnmarshalBinary to restore moerr.
	Error                []byte             `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	SycnCommit           SyncCommitResponse `protobuf:"bytes,4,opt,name=SycnCommit,proto3" json:"SycnCommit"`
	GetCommit            GetCommitResponse  `protobuf:"bytes,5,opt,name=GetCommit,proto3" json:"GetCommit"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Response ctl response

func (*Response) DebugString added in v0.8.0 

func (m *Response) DebugString() string

DebugString returns the debug string

func (*Response) Descriptor added in v0.8.0 

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

func (*Response) GetCMDMethod added in v0.8.0 

func (m *Response) GetCMDMethod() CmdMethod

func (*Response) GetError added in v0.8.0 

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

func (*Response) GetGetCommit added in v0.8.0 

func (m *Response) GetGetCommit() GetCommitResponse

func (*Response) GetID added in v0.8.0 

func (m *Response) GetID() uint64

GetID implement morpc Messgae

func (*Response) GetRequestID added in v0.8.0 

func (m *Response) GetRequestID() uint64

func (*Response) GetSycnCommit added in v0.8.0 

func (m *Response) GetSycnCommit() SyncCommitResponse

func (*Response) Marshal added in v0.8.0 

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

func (*Response) MarshalTo added in v0.8.0 

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

func (*Response) MarshalToSizedBuffer added in v0.8.0 

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

func (*Response) Method added in v0.8.0 

func (m *Response) Method() uint32

func (*Response) ProtoMessage added in v0.8.0 

func (*Response) ProtoMessage()

func (*Response) Reset added in v0.8.0 

func (m *Response) Reset()

func (*Response) SetID added in v0.8.0 

func (m *Response) SetID(id uint64)

SetID implement morpc Messgae

func (*Response) SetMethod added in v0.8.0 

func (m *Response) SetMethod(v uint32)

func (*Response) Size added in v0.8.0 

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

func (*Response) String added in v0.8.0 

func (m *Response) String() string

func (*Response) Unmarshal added in v0.8.0 

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

func (*Response) UnwrapError added in v0.8.0 

func (m *Response) UnwrapError() error

UnwrapError unwrap the moerr from the error bytes

func (*Response) WrapError added in v0.8.0 

func (m *Response) WrapError(err error)

func (*Response) XXX_DiscardUnknown added in v0.8.0 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal added in v0.8.0 

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

func (*Response) XXX_Merge added in v0.8.0 

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

func (*Response) XXX_Size added in v0.8.0 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal added in v0.8.0 

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

type SyncCommitRequest added in v0.8.0 

type SyncCommitRequest struct {
	// LatestCommitTS update latest commit ts.
	LatestCommitTS       timestamp.Timestamp `protobuf:"bytes,1,opt,name=LatestCommitTS,proto3" json:"LatestCommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

SyncCommitRequest sync commit timestamp request

func (*SyncCommitRequest) Descriptor added in v0.8.0 

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

func (*SyncCommitRequest) GetLatestCommitTS added in v0.8.0 

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

func (*SyncCommitRequest) Marshal added in v0.8.0 

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

func (*SyncCommitRequest) MarshalTo added in v0.8.0 

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

func (*SyncCommitRequest) MarshalToSizedBuffer added in v0.8.0 

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

func (*SyncCommitRequest) ProtoMessage added in v0.8.0 

func (*SyncCommitRequest) ProtoMessage()

func (*SyncCommitRequest) Reset added in v0.8.0 

func (m *SyncCommitRequest) Reset()

func (*SyncCommitRequest) Size added in v0.8.0 

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

func (*SyncCommitRequest) String added in v0.8.0 

func (m *SyncCommitRequest) String() string

func (*SyncCommitRequest) Unmarshal added in v0.8.0 

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

func (*SyncCommitRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *SyncCommitRequest) XXX_DiscardUnknown()

func (*SyncCommitRequest) XXX_Marshal added in v0.8.0 

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

func (*SyncCommitRequest) XXX_Merge added in v0.8.0 

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

func (*SyncCommitRequest) XXX_Size added in v0.8.0 

func (m *SyncCommitRequest) XXX_Size() int

func (*SyncCommitRequest) XXX_Unmarshal added in v0.8.0 

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

type SyncCommitResponse added in v0.8.0 

type SyncCommitResponse struct {
	// CurrentCommitTS current commit timestamp after sync
	CurrentCommitTS      timestamp.Timestamp `protobuf:"bytes,1,opt,name=CurrentCommitTS,proto3" json:"CurrentCommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

SyncCommitResponse sync commit timestamp response

func (*SyncCommitResponse) Descriptor added in v0.8.0 

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

func (*SyncCommitResponse) GetCurrentCommitTS added in v0.8.0 

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

func (*SyncCommitResponse) Marshal added in v0.8.0 

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

func (*SyncCommitResponse) MarshalTo added in v0.8.0 

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

func (*SyncCommitResponse) MarshalToSizedBuffer added in v0.8.0 

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

func (*SyncCommitResponse) ProtoMessage added in v0.8.0 

func (*SyncCommitResponse) ProtoMessage()

func (*SyncCommitResponse) Reset added in v0.8.0 

func (m *SyncCommitResponse) Reset()

func (*SyncCommitResponse) Size added in v0.8.0 

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

func (*SyncCommitResponse) String added in v0.8.0 

func (m *SyncCommitResponse) String() string

func (*SyncCommitResponse) Unmarshal added in v0.8.0 

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

func (*SyncCommitResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *SyncCommitResponse) XXX_DiscardUnknown()

func (*SyncCommitResponse) XXX_Marshal added in v0.8.0 

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

func (*SyncCommitResponse) XXX_Merge added in v0.8.0 

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

func (*SyncCommitResponse) XXX_Size added in v0.8.0 

func (m *SyncCommitResponse) XXX_Size() int

func (*SyncCommitResponse) XXX_Unmarshal added in v0.8.0 

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

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.