Documentation ¶
Index ¶
- Variables
- type AlterAccountRequest
- func (*AlterAccountRequest) Descriptor() ([]byte, []int)
- func (m *AlterAccountRequest) GetStatus() string
- func (m *AlterAccountRequest) GetTenantId() int64
- func (m *AlterAccountRequest) Marshal() (dAtA []byte, err error)
- func (m *AlterAccountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AlterAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AlterAccountRequest) ProtoMessage()
- func (m *AlterAccountRequest) Reset()
- func (m *AlterAccountRequest) Size() (n int)
- func (m *AlterAccountRequest) String() string
- func (m *AlterAccountRequest) Unmarshal(dAtA []byte) error
- func (m *AlterAccountRequest) XXX_DiscardUnknown()
- func (m *AlterAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AlterAccountRequest) XXX_Merge(src proto.Message)
- func (m *AlterAccountRequest) XXX_Size() int
- func (m *AlterAccountRequest) XXX_Unmarshal(b []byte) error
- type AlterAccountResponse
- func (*AlterAccountResponse) Descriptor() ([]byte, []int)
- func (m *AlterAccountResponse) GetAlterSuccess() bool
- func (m *AlterAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *AlterAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AlterAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AlterAccountResponse) ProtoMessage()
- func (m *AlterAccountResponse) Reset()
- func (m *AlterAccountResponse) Size() (n int)
- func (m *AlterAccountResponse) String() string
- func (m *AlterAccountResponse) Unmarshal(dAtA []byte) error
- func (m *AlterAccountResponse) XXX_DiscardUnknown()
- func (m *AlterAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AlterAccountResponse) XXX_Merge(src proto.Message)
- func (m *AlterAccountResponse) XXX_Size() int
- func (m *AlterAccountResponse) XXX_Unmarshal(b []byte) error
- type CacheInfo
- func (*CacheInfo) Descriptor() ([]byte, []int)
- func (m *CacheInfo) GetCacheType() string
- func (m *CacheInfo) GetFree() uint64
- func (m *CacheInfo) GetHitRatio() float32
- func (m *CacheInfo) GetNodeId() string
- func (m *CacheInfo) GetNodeType() string
- func (m *CacheInfo) GetUsed() uint64
- func (m *CacheInfo) Marshal() (dAtA []byte, err error)
- func (m *CacheInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *CacheInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CacheInfo) ProtoMessage()
- func (m *CacheInfo) Reset()
- func (m *CacheInfo) Size() (n int)
- func (m *CacheInfo) String() string
- func (m *CacheInfo) Unmarshal(dAtA []byte) error
- func (m *CacheInfo) XXX_DiscardUnknown()
- func (m *CacheInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CacheInfo) XXX_Merge(src proto.Message)
- func (m *CacheInfo) XXX_Size() int
- func (m *CacheInfo) XXX_Unmarshal(b []byte) error
- type CacheKey
- func (*CacheKey) Descriptor() ([]byte, []int)
- func (m *CacheKey) GetOffset() int64
- func (m *CacheKey) GetPath() string
- func (m *CacheKey) GetSz() int64
- func (m *CacheKey) Marshal() (dAtA []byte, err error)
- func (m *CacheKey) MarshalTo(dAtA []byte) (int, error)
- func (m *CacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CacheKey) ProtoMessage()
- func (m *CacheKey) Reset()
- func (m *CacheKey) Size() (n int)
- func (m *CacheKey) String() string
- func (m *CacheKey) Unmarshal(dAtA []byte) error
- func (m *CacheKey) XXX_DiscardUnknown()
- func (m *CacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CacheKey) XXX_Merge(src proto.Message)
- func (m *CacheKey) XXX_Size() int
- func (m *CacheKey) XXX_Unmarshal(b []byte) error
- type CacheKeys
- func (*CacheKeys) Descriptor() ([]byte, []int)
- func (m *CacheKeys) GetKeys() []CacheKey
- func (m *CacheKeys) Marshal() (dAtA []byte, err error)
- func (m *CacheKeys) MarshalTo(dAtA []byte) (int, error)
- func (m *CacheKeys) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CacheKeys) ProtoMessage()
- func (m *CacheKeys) Reset()
- func (m *CacheKeys) Size() (n int)
- func (m *CacheKeys) String() string
- func (m *CacheKeys) Unmarshal(dAtA []byte) error
- func (m *CacheKeys) XXX_DiscardUnknown()
- func (m *CacheKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CacheKeys) XXX_Merge(src proto.Message)
- func (m *CacheKeys) XXX_Size() int
- func (m *CacheKeys) XXX_Unmarshal(b []byte) error
- type CmdMethod
- type GetCacheDataRequest
- func (*GetCacheDataRequest) Descriptor() ([]byte, []int)
- func (m *GetCacheDataRequest) GetRequestCacheKey() []*RequestCacheKey
- func (m *GetCacheDataRequest) Marshal() (dAtA []byte, err error)
- func (m *GetCacheDataRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetCacheDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetCacheDataRequest) ProtoMessage()
- func (m *GetCacheDataRequest) Reset()
- func (m *GetCacheDataRequest) Size() (n int)
- func (m *GetCacheDataRequest) String() string
- func (m *GetCacheDataRequest) Unmarshal(dAtA []byte) error
- func (m *GetCacheDataRequest) XXX_DiscardUnknown()
- func (m *GetCacheDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetCacheDataRequest) XXX_Merge(src proto.Message)
- func (m *GetCacheDataRequest) XXX_Size() int
- func (m *GetCacheDataRequest) XXX_Unmarshal(b []byte) error
- type GetCacheDataResponse
- func (*GetCacheDataResponse) Descriptor() ([]byte, []int)
- func (m *GetCacheDataResponse) GetResponseCacheData() []*ResponseCacheData
- func (m *GetCacheDataResponse) Marshal() (dAtA []byte, err error)
- func (m *GetCacheDataResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetCacheDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetCacheDataResponse) ProtoMessage()
- func (m *GetCacheDataResponse) Reset()
- func (m *GetCacheDataResponse) Size() (n int)
- func (m *GetCacheDataResponse) String() string
- func (m *GetCacheDataResponse) Unmarshal(dAtA []byte) error
- func (m *GetCacheDataResponse) XXX_DiscardUnknown()
- func (m *GetCacheDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetCacheDataResponse) XXX_Merge(src proto.Message)
- func (m *GetCacheDataResponse) XXX_Size() int
- func (m *GetCacheDataResponse) XXX_Unmarshal(b []byte) error
- type GetCacheInfoRequest
- func (*GetCacheInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetCacheInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetCacheInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetCacheInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetCacheInfoRequest) ProtoMessage()
- func (m *GetCacheInfoRequest) Reset()
- func (m *GetCacheInfoRequest) Size() (n int)
- func (m *GetCacheInfoRequest) String() string
- func (m *GetCacheInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetCacheInfoRequest) XXX_DiscardUnknown()
- func (m *GetCacheInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetCacheInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetCacheInfoRequest) XXX_Size() int
- func (m *GetCacheInfoRequest) XXX_Unmarshal(b []byte) error
- type GetCacheInfoResponse
- func (*GetCacheInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetCacheInfoResponse) GetCacheInfoList() []*CacheInfo
- func (m *GetCacheInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetCacheInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetCacheInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetCacheInfoResponse) ProtoMessage()
- func (m *GetCacheInfoResponse) Reset()
- func (m *GetCacheInfoResponse) Size() (n int)
- func (m *GetCacheInfoResponse) String() string
- func (m *GetCacheInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetCacheInfoResponse) XXX_DiscardUnknown()
- func (m *GetCacheInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetCacheInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetCacheInfoResponse) XXX_Size() int
- func (m *GetCacheInfoResponse) XXX_Unmarshal(b []byte) error
- type GetCommitRequest
- func (*GetCommitRequest) Descriptor() ([]byte, []int)
- 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 (*GetCommitRequest) ProtoMessage()
- 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
- func (*GetCommitResponse) Descriptor() ([]byte, []int)
- 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 (*GetCommitResponse) ProtoMessage()
- 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 GetLatestBindRequest
- func (*GetLatestBindRequest) Descriptor() ([]byte, []int)
- func (m *GetLatestBindRequest) GetTableID() uint64
- func (m *GetLatestBindRequest) Marshal() (dAtA []byte, err error)
- func (m *GetLatestBindRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLatestBindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLatestBindRequest) ProtoMessage()
- func (m *GetLatestBindRequest) Reset()
- func (m *GetLatestBindRequest) Size() (n int)
- func (m *GetLatestBindRequest) String() string
- func (m *GetLatestBindRequest) Unmarshal(dAtA []byte) error
- func (m *GetLatestBindRequest) XXX_DiscardUnknown()
- func (m *GetLatestBindRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLatestBindRequest) XXX_Merge(src proto.Message)
- func (m *GetLatestBindRequest) XXX_Size() int
- func (m *GetLatestBindRequest) XXX_Unmarshal(b []byte) error
- type GetLatestBindResponse
- func (*GetLatestBindResponse) Descriptor() ([]byte, []int)
- func (m *GetLatestBindResponse) GetBind() string
- func (m *GetLatestBindResponse) Marshal() (dAtA []byte, err error)
- func (m *GetLatestBindResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLatestBindResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLatestBindResponse) ProtoMessage()
- func (m *GetLatestBindResponse) Reset()
- func (m *GetLatestBindResponse) Size() (n int)
- func (m *GetLatestBindResponse) String() string
- func (m *GetLatestBindResponse) Unmarshal(dAtA []byte) error
- func (m *GetLatestBindResponse) XXX_DiscardUnknown()
- func (m *GetLatestBindResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLatestBindResponse) XXX_Merge(src proto.Message)
- func (m *GetLatestBindResponse) XXX_Size() int
- func (m *GetLatestBindResponse) XXX_Unmarshal(b []byte) error
- type GetLockInfoRequest
- func (*GetLockInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetLockInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetLockInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLockInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLockInfoRequest) ProtoMessage()
- func (m *GetLockInfoRequest) Reset()
- func (m *GetLockInfoRequest) Size() (n int)
- func (m *GetLockInfoRequest) String() string
- func (m *GetLockInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetLockInfoRequest) XXX_DiscardUnknown()
- func (m *GetLockInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLockInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetLockInfoRequest) XXX_Size() int
- func (m *GetLockInfoRequest) XXX_Unmarshal(b []byte) error
- type GetLockInfoResponse
- func (*GetLockInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetLockInfoResponse) GetCnId() string
- func (m *GetLockInfoResponse) GetLockInfoList() []*LockInfo
- func (m *GetLockInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetLockInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLockInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLockInfoResponse) ProtoMessage()
- func (m *GetLockInfoResponse) Reset()
- func (m *GetLockInfoResponse) Size() (n int)
- func (m *GetLockInfoResponse) String() string
- func (m *GetLockInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetLockInfoResponse) XXX_DiscardUnknown()
- func (m *GetLockInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLockInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetLockInfoResponse) XXX_Size() int
- func (m *GetLockInfoResponse) XXX_Unmarshal(b []byte) error
- type GetPipelineInfoRequest
- func (*GetPipelineInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetPipelineInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetPipelineInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPipelineInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPipelineInfoRequest) ProtoMessage()
- func (m *GetPipelineInfoRequest) Reset()
- func (m *GetPipelineInfoRequest) Size() (n int)
- func (m *GetPipelineInfoRequest) String() string
- func (m *GetPipelineInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetPipelineInfoRequest) XXX_DiscardUnknown()
- func (m *GetPipelineInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPipelineInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetPipelineInfoRequest) XXX_Size() int
- func (m *GetPipelineInfoRequest) XXX_Unmarshal(b []byte) error
- type GetPipelineInfoResponse
- func (*GetPipelineInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetPipelineInfoResponse) GetCount() int64
- func (m *GetPipelineInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetPipelineInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetPipelineInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetPipelineInfoResponse) ProtoMessage()
- func (m *GetPipelineInfoResponse) Reset()
- func (m *GetPipelineInfoResponse) Size() (n int)
- func (m *GetPipelineInfoResponse) String() string
- func (m *GetPipelineInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetPipelineInfoResponse) XXX_DiscardUnknown()
- func (m *GetPipelineInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetPipelineInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetPipelineInfoResponse) XXX_Size() int
- func (m *GetPipelineInfoResponse) XXX_Unmarshal(b []byte) error
- type GetStatsInfoRequest
- func (*GetStatsInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetStatsInfoRequest) GetStatsInfoKey() *statsinfo.StatsInfoKey
- func (m *GetStatsInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetStatsInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetStatsInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetStatsInfoRequest) ProtoMessage()
- func (m *GetStatsInfoRequest) Reset()
- func (m *GetStatsInfoRequest) Size() (n int)
- func (m *GetStatsInfoRequest) String() string
- func (m *GetStatsInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetStatsInfoRequest) XXX_DiscardUnknown()
- func (m *GetStatsInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetStatsInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetStatsInfoRequest) XXX_Size() int
- func (m *GetStatsInfoRequest) XXX_Unmarshal(b []byte) error
- type GetStatsInfoResponse
- func (*GetStatsInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetStatsInfoResponse) GetStatsInfo() *statsinfo.StatsInfo
- func (m *GetStatsInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetStatsInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetStatsInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetStatsInfoResponse) ProtoMessage()
- func (m *GetStatsInfoResponse) Reset()
- func (m *GetStatsInfoResponse) Size() (n int)
- func (m *GetStatsInfoResponse) String() string
- func (m *GetStatsInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetStatsInfoResponse) XXX_DiscardUnknown()
- func (m *GetStatsInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetStatsInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetStatsInfoResponse) XXX_Size() int
- func (m *GetStatsInfoResponse) XXX_Unmarshal(b []byte) error
- type GetTxnInfoRequest
- func (*GetTxnInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetTxnInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTxnInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTxnInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTxnInfoRequest) ProtoMessage()
- func (m *GetTxnInfoRequest) Reset()
- func (m *GetTxnInfoRequest) Size() (n int)
- func (m *GetTxnInfoRequest) String() string
- func (m *GetTxnInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetTxnInfoRequest) XXX_DiscardUnknown()
- func (m *GetTxnInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTxnInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetTxnInfoRequest) XXX_Size() int
- func (m *GetTxnInfoRequest) XXX_Unmarshal(b []byte) error
- type GetTxnInfoResponse
- func (*GetTxnInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetTxnInfoResponse) GetCnId() string
- func (m *GetTxnInfoResponse) GetTxnInfoList() []*TxnInfo
- func (m *GetTxnInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetTxnInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTxnInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTxnInfoResponse) ProtoMessage()
- func (m *GetTxnInfoResponse) Reset()
- func (m *GetTxnInfoResponse) Size() (n int)
- func (m *GetTxnInfoResponse) String() string
- func (m *GetTxnInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetTxnInfoResponse) XXX_DiscardUnknown()
- func (m *GetTxnInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTxnInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetTxnInfoResponse) XXX_Size() int
- func (m *GetTxnInfoResponse) XXX_Unmarshal(b []byte) error
- type KillConnRequest
- func (*KillConnRequest) Descriptor() ([]byte, []int)
- func (m *KillConnRequest) GetAccountID() int64
- func (m *KillConnRequest) GetVersion() uint64
- func (m *KillConnRequest) Marshal() (dAtA []byte, err error)
- func (m *KillConnRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *KillConnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KillConnRequest) ProtoMessage()
- func (m *KillConnRequest) Reset()
- func (m *KillConnRequest) Size() (n int)
- func (m *KillConnRequest) String() string
- func (m *KillConnRequest) Unmarshal(dAtA []byte) error
- func (m *KillConnRequest) XXX_DiscardUnknown()
- func (m *KillConnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KillConnRequest) XXX_Merge(src proto.Message)
- func (m *KillConnRequest) XXX_Size() int
- func (m *KillConnRequest) XXX_Unmarshal(b []byte) error
- type KillConnResponse
- func (*KillConnResponse) Descriptor() ([]byte, []int)
- func (m *KillConnResponse) GetSuccess() bool
- func (m *KillConnResponse) Marshal() (dAtA []byte, err error)
- func (m *KillConnResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *KillConnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KillConnResponse) ProtoMessage()
- func (m *KillConnResponse) Reset()
- func (m *KillConnResponse) Size() (n int)
- func (m *KillConnResponse) String() string
- func (m *KillConnResponse) Unmarshal(dAtA []byte) error
- func (m *KillConnResponse) XXX_DiscardUnknown()
- func (m *KillConnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KillConnResponse) XXX_Merge(src proto.Message)
- func (m *KillConnResponse) XXX_Size() int
- func (m *KillConnResponse) XXX_Unmarshal(b []byte) error
- type LockInfo
- func (*LockInfo) Descriptor() ([]byte, []int)
- func (m *LockInfo) GetHolders() []*lock.WaitTxn
- func (m *LockInfo) GetIsRangeLock() bool
- func (m *LockInfo) GetKeys() [][]byte
- func (m *LockInfo) GetLockMode() lock.LockMode
- func (m *LockInfo) GetTableId() uint64
- func (m *LockInfo) GetWaiters() []*lock.WaitTxn
- func (m *LockInfo) Marshal() (dAtA []byte, err error)
- func (m *LockInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *LockInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LockInfo) ProtoMessage()
- func (m *LockInfo) Reset()
- func (m *LockInfo) Size() (n int)
- func (m *LockInfo) String() string
- func (m *LockInfo) Unmarshal(dAtA []byte) error
- func (m *LockInfo) XXX_DiscardUnknown()
- func (m *LockInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LockInfo) XXX_Merge(src proto.Message)
- func (m *LockInfo) XXX_Size() int
- func (m *LockInfo) XXX_Unmarshal(b []byte) error
- type MigrateConnFromRequest
- func (*MigrateConnFromRequest) Descriptor() ([]byte, []int)
- func (m *MigrateConnFromRequest) GetConnID() uint32
- func (m *MigrateConnFromRequest) Marshal() (dAtA []byte, err error)
- func (m *MigrateConnFromRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrateConnFromRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrateConnFromRequest) ProtoMessage()
- func (m *MigrateConnFromRequest) Reset()
- func (m *MigrateConnFromRequest) Size() (n int)
- func (m *MigrateConnFromRequest) String() string
- func (m *MigrateConnFromRequest) Unmarshal(dAtA []byte) error
- func (m *MigrateConnFromRequest) XXX_DiscardUnknown()
- func (m *MigrateConnFromRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrateConnFromRequest) XXX_Merge(src proto.Message)
- func (m *MigrateConnFromRequest) XXX_Size() int
- func (m *MigrateConnFromRequest) XXX_Unmarshal(b []byte) error
- type MigrateConnFromResponse
- func (*MigrateConnFromResponse) Descriptor() ([]byte, []int)
- func (m *MigrateConnFromResponse) GetDB() string
- func (m *MigrateConnFromResponse) GetPrepareStmts() []*PrepareStmt
- func (m *MigrateConnFromResponse) Marshal() (dAtA []byte, err error)
- func (m *MigrateConnFromResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrateConnFromResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrateConnFromResponse) ProtoMessage()
- func (m *MigrateConnFromResponse) Reset()
- func (m *MigrateConnFromResponse) Size() (n int)
- func (m *MigrateConnFromResponse) String() string
- func (m *MigrateConnFromResponse) Unmarshal(dAtA []byte) error
- func (m *MigrateConnFromResponse) XXX_DiscardUnknown()
- func (m *MigrateConnFromResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrateConnFromResponse) XXX_Merge(src proto.Message)
- func (m *MigrateConnFromResponse) XXX_Size() int
- func (m *MigrateConnFromResponse) XXX_Unmarshal(b []byte) error
- type MigrateConnToRequest
- func (*MigrateConnToRequest) Descriptor() ([]byte, []int)
- func (m *MigrateConnToRequest) GetConnID() uint32
- func (m *MigrateConnToRequest) GetDB() string
- func (m *MigrateConnToRequest) GetPrepareStmts() []*PrepareStmt
- func (m *MigrateConnToRequest) GetSetVarStmts() []string
- func (m *MigrateConnToRequest) Marshal() (dAtA []byte, err error)
- func (m *MigrateConnToRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrateConnToRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrateConnToRequest) ProtoMessage()
- func (m *MigrateConnToRequest) Reset()
- func (m *MigrateConnToRequest) Size() (n int)
- func (m *MigrateConnToRequest) String() string
- func (m *MigrateConnToRequest) Unmarshal(dAtA []byte) error
- func (m *MigrateConnToRequest) XXX_DiscardUnknown()
- func (m *MigrateConnToRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrateConnToRequest) XXX_Merge(src proto.Message)
- func (m *MigrateConnToRequest) XXX_Size() int
- func (m *MigrateConnToRequest) XXX_Unmarshal(b []byte) error
- type MigrateConnToResponse
- func (*MigrateConnToResponse) Descriptor() ([]byte, []int)
- func (m *MigrateConnToResponse) GetSuccess() bool
- func (m *MigrateConnToResponse) Marshal() (dAtA []byte, err error)
- func (m *MigrateConnToResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrateConnToResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrateConnToResponse) ProtoMessage()
- func (m *MigrateConnToResponse) Reset()
- func (m *MigrateConnToResponse) Size() (n int)
- func (m *MigrateConnToResponse) String() string
- func (m *MigrateConnToResponse) Unmarshal(dAtA []byte) error
- func (m *MigrateConnToResponse) XXX_DiscardUnknown()
- func (m *MigrateConnToResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrateConnToResponse) XXX_Merge(src proto.Message)
- func (m *MigrateConnToResponse) XXX_Size() int
- func (m *MigrateConnToResponse) XXX_Unmarshal(b []byte) error
- type PrepareStmt
- func (*PrepareStmt) Descriptor() ([]byte, []int)
- func (m *PrepareStmt) GetName() string
- func (m *PrepareStmt) GetParamTypes() []byte
- func (m *PrepareStmt) GetSQL() string
- func (m *PrepareStmt) Marshal() (dAtA []byte, err error)
- func (m *PrepareStmt) MarshalTo(dAtA []byte) (int, error)
- func (m *PrepareStmt) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrepareStmt) ProtoMessage()
- func (m *PrepareStmt) Reset()
- func (m *PrepareStmt) Size() (n int)
- func (m *PrepareStmt) String() string
- func (m *PrepareStmt) Unmarshal(dAtA []byte) error
- func (m *PrepareStmt) XXX_DiscardUnknown()
- func (m *PrepareStmt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrepareStmt) XXX_Merge(src proto.Message)
- func (m *PrepareStmt) XXX_Size() int
- func (m *PrepareStmt) XXX_Unmarshal(b []byte) error
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (m *QueryRequest) GetQuery() string
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- func (m *QueryRequest) XXX_DiscardUnknown()
- func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryRequest) XXX_Merge(src proto.Message)
- func (m *QueryRequest) XXX_Size() int
- func (m *QueryRequest) XXX_Unmarshal(b []byte) error
- type RemoveRemoteLockTableRequest
- func (*RemoveRemoteLockTableRequest) Descriptor() ([]byte, []int)
- func (m *RemoveRemoteLockTableRequest) GetTableID() uint64
- func (m *RemoveRemoteLockTableRequest) GetVersion() uint64
- func (m *RemoveRemoteLockTableRequest) Marshal() (dAtA []byte, err error)
- func (m *RemoveRemoteLockTableRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RemoveRemoteLockTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RemoveRemoteLockTableRequest) ProtoMessage()
- func (m *RemoveRemoteLockTableRequest) Reset()
- func (m *RemoveRemoteLockTableRequest) Size() (n int)
- func (m *RemoveRemoteLockTableRequest) String() string
- func (m *RemoveRemoteLockTableRequest) Unmarshal(dAtA []byte) error
- func (m *RemoveRemoteLockTableRequest) XXX_DiscardUnknown()
- func (m *RemoveRemoteLockTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveRemoteLockTableRequest) XXX_Merge(src proto.Message)
- func (m *RemoveRemoteLockTableRequest) XXX_Size() int
- func (m *RemoveRemoteLockTableRequest) XXX_Unmarshal(b []byte) error
- type RemoveRemoteLockTableResponse
- func (*RemoveRemoteLockTableResponse) Descriptor() ([]byte, []int)
- func (m *RemoveRemoteLockTableResponse) GetCount() int32
- func (m *RemoveRemoteLockTableResponse) Marshal() (dAtA []byte, err error)
- func (m *RemoveRemoteLockTableResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RemoveRemoteLockTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RemoveRemoteLockTableResponse) ProtoMessage()
- func (m *RemoveRemoteLockTableResponse) Reset()
- func (m *RemoveRemoteLockTableResponse) Size() (n int)
- func (m *RemoveRemoteLockTableResponse) String() string
- func (m *RemoveRemoteLockTableResponse) Unmarshal(dAtA []byte) error
- func (m *RemoveRemoteLockTableResponse) XXX_DiscardUnknown()
- func (m *RemoveRemoteLockTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveRemoteLockTableResponse) XXX_Merge(src proto.Message)
- func (m *RemoveRemoteLockTableResponse) XXX_Size() int
- func (m *RemoveRemoteLockTableResponse) XXX_Unmarshal(b []byte) error
- type Request
- func (m *Request) DebugString() string
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetAlterAccountRequest() *AlterAccountRequest
- func (m *Request) GetCmdMethod() CmdMethod
- func (m *Request) GetGetCacheDataRequest() *GetCacheDataRequest
- func (m *Request) GetGetCacheInfoRequest() *GetCacheInfoRequest
- func (m *Request) GetGetCommit() *GetCommitRequest
- func (m *Request) GetGetLatestBind() *GetLatestBindRequest
- func (m *Request) GetGetLockInfoRequest() *GetLockInfoRequest
- func (m *Request) GetGetPipelineInfoRequest() *GetPipelineInfoRequest
- func (m *Request) GetGetStatsInfoRequest() *GetStatsInfoRequest
- func (m *Request) GetGetTxnInfoRequest() *GetTxnInfoRequest
- func (m *Request) GetID() uint64
- func (m *Request) GetKillConnRequest() *KillConnRequest
- func (m *Request) GetMigrateConnFromRequest() *MigrateConnFromRequest
- func (m *Request) GetMigrateConnToRequest() *MigrateConnToRequest
- func (m *Request) GetQueryRequest() *QueryRequest
- func (m *Request) GetRemoveRemoteLockTable() *RemoveRemoteLockTableRequest
- func (m *Request) GetRequestID() uint64
- func (m *Request) GetRunTask() *RunTaskRequest
- func (m *Request) GetShowProcessListRequest() *ShowProcessListRequest
- func (m *Request) GetSycnCommit() *SyncCommitRequest
- func (m *Request) GetTraceSpanRequest() *TraceSpanRequest
- func (m *Request) GetUnsubscribeTable() *UnsubscribeTableRequest
- 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 (*Request) ProtoMessage()
- 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 RequestCacheKey
- func (*RequestCacheKey) Descriptor() ([]byte, []int)
- func (m *RequestCacheKey) GetCacheKey() *CacheKey
- func (m *RequestCacheKey) GetIndex() int32
- func (m *RequestCacheKey) Marshal() (dAtA []byte, err error)
- func (m *RequestCacheKey) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestCacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestCacheKey) ProtoMessage()
- func (m *RequestCacheKey) Reset()
- func (m *RequestCacheKey) Size() (n int)
- func (m *RequestCacheKey) String() string
- func (m *RequestCacheKey) Unmarshal(dAtA []byte) error
- func (m *RequestCacheKey) XXX_DiscardUnknown()
- func (m *RequestCacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestCacheKey) XXX_Merge(src proto.Message)
- func (m *RequestCacheKey) XXX_Size() int
- func (m *RequestCacheKey) XXX_Unmarshal(b []byte) error
- type Response
- func (m *Response) DebugString() string
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetAlterAccountResponse() *AlterAccountResponse
- func (m *Response) GetCmdMethod() CmdMethod
- func (m *Response) GetError() []byte
- func (m *Response) GetGetCacheDataResponse() *GetCacheDataResponse
- func (m *Response) GetGetCacheInfoResponse() *GetCacheInfoResponse
- func (m *Response) GetGetCommit() *GetCommitResponse
- func (m *Response) GetGetLatestBind() *GetLatestBindResponse
- func (m *Response) GetGetLockInfoResponse() *GetLockInfoResponse
- func (m *Response) GetGetPipelineInfoResponse() *GetPipelineInfoResponse
- func (m *Response) GetGetStatsInfoResponse() *GetStatsInfoResponse
- func (m *Response) GetGetTxnInfoResponse() *GetTxnInfoResponse
- func (m *Response) GetID() uint64
- func (m *Response) GetKillConnResponse() *KillConnResponse
- func (m *Response) GetMigrateConnFromResponse() *MigrateConnFromResponse
- func (m *Response) GetMigrateConnToResponse() *MigrateConnToResponse
- func (m *Response) GetRemoveRemoteLockTable() *RemoveRemoteLockTableResponse
- func (m *Response) GetRequestID() uint64
- func (m *Response) GetRunTask() *RunTaskResponse
- func (m *Response) GetShowProcessListResponse() *ShowProcessListResponse
- func (m *Response) GetSyncCommit() *SyncCommitResponse
- func (m *Response) GetTraceSpanResponse() *TraceSpanResponse
- func (m *Response) GetUnsubscribeTable() *UnsubscribeTableResponse
- 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 (*Response) ProtoMessage()
- 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 ResponseCacheData
- func (*ResponseCacheData) Descriptor() ([]byte, []int)
- func (m *ResponseCacheData) GetData() []byte
- func (m *ResponseCacheData) GetHit() bool
- func (m *ResponseCacheData) GetIndex() int32
- func (m *ResponseCacheData) Marshal() (dAtA []byte, err error)
- func (m *ResponseCacheData) MarshalTo(dAtA []byte) (int, error)
- func (m *ResponseCacheData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResponseCacheData) ProtoMessage()
- func (m *ResponseCacheData) Reset()
- func (m *ResponseCacheData) Size() (n int)
- func (m *ResponseCacheData) String() string
- func (m *ResponseCacheData) Unmarshal(dAtA []byte) error
- func (m *ResponseCacheData) XXX_DiscardUnknown()
- func (m *ResponseCacheData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseCacheData) XXX_Merge(src proto.Message)
- func (m *ResponseCacheData) XXX_Size() int
- func (m *ResponseCacheData) XXX_Unmarshal(b []byte) error
- type RunTaskRequest
- func (*RunTaskRequest) Descriptor() ([]byte, []int)
- func (m *RunTaskRequest) GetTaskCode() int32
- func (m *RunTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *RunTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RunTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RunTaskRequest) ProtoMessage()
- func (m *RunTaskRequest) Reset()
- func (m *RunTaskRequest) Size() (n int)
- func (m *RunTaskRequest) String() string
- func (m *RunTaskRequest) Unmarshal(dAtA []byte) error
- func (m *RunTaskRequest) XXX_DiscardUnknown()
- func (m *RunTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunTaskRequest) XXX_Merge(src proto.Message)
- func (m *RunTaskRequest) XXX_Size() int
- func (m *RunTaskRequest) XXX_Unmarshal(b []byte) error
- type RunTaskResponse
- func (*RunTaskResponse) Descriptor() ([]byte, []int)
- func (m *RunTaskResponse) GetResult() string
- func (m *RunTaskResponse) Marshal() (dAtA []byte, err error)
- func (m *RunTaskResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RunTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RunTaskResponse) ProtoMessage()
- func (m *RunTaskResponse) Reset()
- func (m *RunTaskResponse) Size() (n int)
- func (m *RunTaskResponse) String() string
- func (m *RunTaskResponse) Unmarshal(dAtA []byte) error
- func (m *RunTaskResponse) XXX_DiscardUnknown()
- func (m *RunTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunTaskResponse) XXX_Merge(src proto.Message)
- func (m *RunTaskResponse) XXX_Size() int
- func (m *RunTaskResponse) XXX_Unmarshal(b []byte) error
- type ShowProcessListRequest
- func (*ShowProcessListRequest) Descriptor() ([]byte, []int)
- func (m *ShowProcessListRequest) GetSysTenant() bool
- func (m *ShowProcessListRequest) GetTenant() string
- func (m *ShowProcessListRequest) Marshal() (dAtA []byte, err error)
- func (m *ShowProcessListRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ShowProcessListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShowProcessListRequest) ProtoMessage()
- func (m *ShowProcessListRequest) Reset()
- func (m *ShowProcessListRequest) Size() (n int)
- func (m *ShowProcessListRequest) String() string
- func (m *ShowProcessListRequest) Unmarshal(dAtA []byte) error
- func (m *ShowProcessListRequest) XXX_DiscardUnknown()
- func (m *ShowProcessListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowProcessListRequest) XXX_Merge(src proto.Message)
- func (m *ShowProcessListRequest) XXX_Size() int
- func (m *ShowProcessListRequest) XXX_Unmarshal(b []byte) error
- type ShowProcessListResponse
- func (*ShowProcessListResponse) Descriptor() ([]byte, []int)
- func (m *ShowProcessListResponse) GetSessions() []*status.Session
- func (m *ShowProcessListResponse) Marshal() (dAtA []byte, err error)
- func (m *ShowProcessListResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ShowProcessListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShowProcessListResponse) ProtoMessage()
- func (m *ShowProcessListResponse) Reset()
- func (m *ShowProcessListResponse) Size() (n int)
- func (m *ShowProcessListResponse) String() string
- func (m *ShowProcessListResponse) Unmarshal(dAtA []byte) error
- func (m *ShowProcessListResponse) XXX_DiscardUnknown()
- func (m *ShowProcessListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowProcessListResponse) XXX_Merge(src proto.Message)
- func (m *ShowProcessListResponse) XXX_Size() int
- func (m *ShowProcessListResponse) XXX_Unmarshal(b []byte) error
- type SyncCommitRequest
- func (*SyncCommitRequest) Descriptor() ([]byte, []int)
- 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 (*SyncCommitRequest) ProtoMessage()
- 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
- func (*SyncCommitResponse) Descriptor() ([]byte, []int)
- 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 (*SyncCommitResponse) ProtoMessage()
- 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
- type TraceSpanRequest
- func (*TraceSpanRequest) Descriptor() ([]byte, []int)
- func (m *TraceSpanRequest) GetCmd() string
- func (m *TraceSpanRequest) GetSpans() string
- func (m *TraceSpanRequest) GetThreshold() int64
- func (m *TraceSpanRequest) Marshal() (dAtA []byte, err error)
- func (m *TraceSpanRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TraceSpanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TraceSpanRequest) ProtoMessage()
- func (m *TraceSpanRequest) Reset()
- func (m *TraceSpanRequest) Size() (n int)
- func (m *TraceSpanRequest) String() string
- func (m *TraceSpanRequest) Unmarshal(dAtA []byte) error
- func (m *TraceSpanRequest) XXX_DiscardUnknown()
- func (m *TraceSpanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TraceSpanRequest) XXX_Merge(src proto.Message)
- func (m *TraceSpanRequest) XXX_Size() int
- func (m *TraceSpanRequest) XXX_Unmarshal(b []byte) error
- type TraceSpanResponse
- func (*TraceSpanResponse) Descriptor() ([]byte, []int)
- func (m *TraceSpanResponse) GetResp() string
- func (m *TraceSpanResponse) Marshal() (dAtA []byte, err error)
- func (m *TraceSpanResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *TraceSpanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TraceSpanResponse) ProtoMessage()
- func (m *TraceSpanResponse) Reset()
- func (m *TraceSpanResponse) Size() (n int)
- func (m *TraceSpanResponse) String() string
- func (m *TraceSpanResponse) Unmarshal(dAtA []byte) error
- func (m *TraceSpanResponse) XXX_DiscardUnknown()
- func (m *TraceSpanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TraceSpanResponse) XXX_Merge(src proto.Message)
- func (m *TraceSpanResponse) XXX_Size() int
- func (m *TraceSpanResponse) XXX_Unmarshal(b []byte) error
- type TxnInfo
- func (*TxnInfo) Descriptor() ([]byte, []int)
- func (m *TxnInfo) GetCreateAt() time.Time
- func (m *TxnInfo) GetMeta() *txn.TxnMeta
- func (m *TxnInfo) GetUserTxn() bool
- func (m *TxnInfo) GetWaitLocks() []*TxnLockInfo
- func (m *TxnInfo) Marshal() (dAtA []byte, err error)
- func (m *TxnInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *TxnInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TxnInfo) ProtoMessage()
- func (m *TxnInfo) Reset()
- func (m *TxnInfo) Size() (n int)
- func (m *TxnInfo) String() string
- func (m *TxnInfo) Unmarshal(dAtA []byte) error
- func (m *TxnInfo) XXX_DiscardUnknown()
- func (m *TxnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TxnInfo) XXX_Merge(src proto.Message)
- func (m *TxnInfo) XXX_Size() int
- func (m *TxnInfo) XXX_Unmarshal(b []byte) error
- type TxnLockInfo
- func (*TxnLockInfo) Descriptor() ([]byte, []int)
- func (m *TxnLockInfo) GetOptions() *lock.LockOptions
- func (m *TxnLockInfo) GetRows() [][]byte
- func (m *TxnLockInfo) GetTableId() uint64
- func (m *TxnLockInfo) Marshal() (dAtA []byte, err error)
- func (m *TxnLockInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *TxnLockInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TxnLockInfo) ProtoMessage()
- func (m *TxnLockInfo) Reset()
- func (m *TxnLockInfo) Size() (n int)
- func (m *TxnLockInfo) String() string
- func (m *TxnLockInfo) Unmarshal(dAtA []byte) error
- func (m *TxnLockInfo) XXX_DiscardUnknown()
- func (m *TxnLockInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TxnLockInfo) XXX_Merge(src proto.Message)
- func (m *TxnLockInfo) XXX_Size() int
- func (m *TxnLockInfo) XXX_Unmarshal(b []byte) error
- type UnsubscribeTableRequest
- func (*UnsubscribeTableRequest) Descriptor() ([]byte, []int)
- func (m *UnsubscribeTableRequest) GetDatabaseID() uint64
- func (m *UnsubscribeTableRequest) GetTableID() uint64
- func (m *UnsubscribeTableRequest) Marshal() (dAtA []byte, err error)
- func (m *UnsubscribeTableRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UnsubscribeTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnsubscribeTableRequest) ProtoMessage()
- func (m *UnsubscribeTableRequest) Reset()
- func (m *UnsubscribeTableRequest) Size() (n int)
- func (m *UnsubscribeTableRequest) String() string
- func (m *UnsubscribeTableRequest) Unmarshal(dAtA []byte) error
- func (m *UnsubscribeTableRequest) XXX_DiscardUnknown()
- func (m *UnsubscribeTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnsubscribeTableRequest) XXX_Merge(src proto.Message)
- func (m *UnsubscribeTableRequest) XXX_Size() int
- func (m *UnsubscribeTableRequest) XXX_Unmarshal(b []byte) error
- type UnsubscribeTableResponse
- func (*UnsubscribeTableResponse) Descriptor() ([]byte, []int)
- func (m *UnsubscribeTableResponse) GetSuccess() bool
- func (m *UnsubscribeTableResponse) Marshal() (dAtA []byte, err error)
- func (m *UnsubscribeTableResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UnsubscribeTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnsubscribeTableResponse) ProtoMessage()
- func (m *UnsubscribeTableResponse) Reset()
- func (m *UnsubscribeTableResponse) Size() (n int)
- func (m *UnsubscribeTableResponse) String() string
- func (m *UnsubscribeTableResponse) Unmarshal(dAtA []byte) error
- func (m *UnsubscribeTableResponse) XXX_DiscardUnknown()
- func (m *UnsubscribeTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnsubscribeTableResponse) XXX_Merge(src proto.Message)
- func (m *UnsubscribeTableResponse) XXX_Size() int
- func (m *UnsubscribeTableResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var CmdMethod_name = map[int32]string{
0: "Query",
1: "ShowProcessList",
2: "AlterAccount",
3: "KillConn",
4: "TraceSpan",
5: "GetLockInfo",
6: "GetTxnInfo",
7: "GetCacheInfo",
8: "SyncCommit",
9: "GetCommit",
13: "RunTask",
14: "RemoveRemoteLockTable",
15: "GetLatestBind",
16: "UnsubscribeTable",
17: "GetCacheData",
18: "GetStatsInfo",
19: "GetPipelineInfo",
20: "MigrateConnFrom",
21: "MigrateConnTo",
}
var CmdMethod_value = map[string]int32{
"Query": 0,
"ShowProcessList": 1,
"AlterAccount": 2,
"KillConn": 3,
"TraceSpan": 4,
"GetLockInfo": 5,
"GetTxnInfo": 6,
"GetCacheInfo": 7,
"SyncCommit": 8,
"GetCommit": 9,
"RunTask": 13,
"RemoveRemoteLockTable": 14,
"GetLatestBind": 15,
"UnsubscribeTable": 16,
"GetCacheData": 17,
"GetStatsInfo": 18,
"GetPipelineInfo": 19,
"MigrateConnFrom": 20,
"MigrateConnTo": 21,
}
Functions ¶
This section is empty.
Types ¶
type AlterAccountRequest ¶
type AlterAccountRequest struct { // Tenant is the tenant which to alter. TenantId int64 `protobuf:"varint,1,opt,name=TenantId,proto3" json:"TenantId,omitempty"` // Status is the tenant which will be alter to. Status string `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AlterAccountRequest is the "alter account restricted" query request.
func (*AlterAccountRequest) Descriptor ¶
func (*AlterAccountRequest) Descriptor() ([]byte, []int)
func (*AlterAccountRequest) GetStatus ¶
func (m *AlterAccountRequest) GetStatus() string
func (*AlterAccountRequest) GetTenantId ¶
func (m *AlterAccountRequest) GetTenantId() int64
func (*AlterAccountRequest) Marshal ¶
func (m *AlterAccountRequest) Marshal() (dAtA []byte, err error)
func (*AlterAccountRequest) MarshalTo ¶
func (m *AlterAccountRequest) MarshalTo(dAtA []byte) (int, error)
func (*AlterAccountRequest) MarshalToSizedBuffer ¶
func (m *AlterAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AlterAccountRequest) ProtoMessage ¶
func (*AlterAccountRequest) ProtoMessage()
func (*AlterAccountRequest) Reset ¶
func (m *AlterAccountRequest) Reset()
func (*AlterAccountRequest) Size ¶
func (m *AlterAccountRequest) Size() (n int)
func (*AlterAccountRequest) String ¶
func (m *AlterAccountRequest) String() string
func (*AlterAccountRequest) Unmarshal ¶
func (m *AlterAccountRequest) Unmarshal(dAtA []byte) error
func (*AlterAccountRequest) XXX_DiscardUnknown ¶
func (m *AlterAccountRequest) XXX_DiscardUnknown()
func (*AlterAccountRequest) XXX_Marshal ¶
func (m *AlterAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterAccountRequest) XXX_Merge ¶
func (m *AlterAccountRequest) XXX_Merge(src proto.Message)
func (*AlterAccountRequest) XXX_Size ¶
func (m *AlterAccountRequest) XXX_Size() int
func (*AlterAccountRequest) XXX_Unmarshal ¶
func (m *AlterAccountRequest) XXX_Unmarshal(b []byte) error
type AlterAccountResponse ¶
type AlterAccountResponse struct { AlterSuccess bool `protobuf:"varint,1,opt,name=alterSuccess,proto3" json:"alterSuccess,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AlterAccountResponse is the response of command AlterAccount.
func (*AlterAccountResponse) Descriptor ¶
func (*AlterAccountResponse) Descriptor() ([]byte, []int)
func (*AlterAccountResponse) GetAlterSuccess ¶
func (m *AlterAccountResponse) GetAlterSuccess() bool
func (*AlterAccountResponse) Marshal ¶
func (m *AlterAccountResponse) Marshal() (dAtA []byte, err error)
func (*AlterAccountResponse) MarshalTo ¶
func (m *AlterAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*AlterAccountResponse) MarshalToSizedBuffer ¶
func (m *AlterAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AlterAccountResponse) ProtoMessage ¶
func (*AlterAccountResponse) ProtoMessage()
func (*AlterAccountResponse) Reset ¶
func (m *AlterAccountResponse) Reset()
func (*AlterAccountResponse) Size ¶
func (m *AlterAccountResponse) Size() (n int)
func (*AlterAccountResponse) String ¶
func (m *AlterAccountResponse) String() string
func (*AlterAccountResponse) Unmarshal ¶
func (m *AlterAccountResponse) Unmarshal(dAtA []byte) error
func (*AlterAccountResponse) XXX_DiscardUnknown ¶
func (m *AlterAccountResponse) XXX_DiscardUnknown()
func (*AlterAccountResponse) XXX_Marshal ¶
func (m *AlterAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterAccountResponse) XXX_Merge ¶
func (m *AlterAccountResponse) XXX_Merge(src proto.Message)
func (*AlterAccountResponse) XXX_Size ¶
func (m *AlterAccountResponse) XXX_Size() int
func (*AlterAccountResponse) XXX_Unmarshal ¶
func (m *AlterAccountResponse) XXX_Unmarshal(b []byte) error
type CacheInfo ¶ added in v1.1.0
type CacheInfo struct { // NodeType is the type of the node. cn, tn NodeType string `protobuf:"bytes,1,opt,name=NodeType,proto3" json:"NodeType,omitempty"` // NodeId is the uuid of the node. NodeId string `protobuf:"bytes,2,opt,name=NodeId,proto3" json:"NodeId,omitempty"` // CacheType is the type of the cache. memory, disk CacheType string `protobuf:"bytes,3,opt,name=CacheType,proto3" json:"CacheType,omitempty"` // Used is the used bytes of the cache for memory cache Used uint64 `protobuf:"varint,4,opt,name=Used,proto3" json:"Used,omitempty"` // Free is the free bytes of the cache for memory cache Free uint64 `protobuf:"varint,5,opt,name=Free,proto3" json:"Free,omitempty"` // HitRatio is the hit ratio of the cache. HitRatio float32 `protobuf:"fixed32,6,opt,name=HitRatio,proto3" json:"HitRatio,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CacheInfo) Descriptor ¶ added in v1.1.0
func (*CacheInfo) GetCacheType ¶ added in v1.1.0
func (*CacheInfo) GetHitRatio ¶ added in v1.1.0
func (*CacheInfo) GetNodeType ¶ added in v1.1.0
func (*CacheInfo) MarshalToSizedBuffer ¶ added in v1.1.0
func (*CacheInfo) ProtoMessage ¶ added in v1.1.0
func (*CacheInfo) ProtoMessage()
func (*CacheInfo) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *CacheInfo) XXX_DiscardUnknown()
func (*CacheInfo) XXX_Marshal ¶ added in v1.1.0
func (*CacheInfo) XXX_Unmarshal ¶ added in v1.1.0
type CacheKey ¶ added in v1.1.2
type CacheKey struct { Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=Offset,proto3" json:"Offset,omitempty"` Sz int64 `protobuf:"varint,3,opt,name=Sz,proto3" json:"Sz,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CacheKey) Descriptor ¶ added in v1.1.2
func (*CacheKey) MarshalToSizedBuffer ¶ added in v1.1.2
func (*CacheKey) ProtoMessage ¶ added in v1.1.2
func (*CacheKey) ProtoMessage()
func (*CacheKey) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *CacheKey) XXX_DiscardUnknown()
func (*CacheKey) XXX_Marshal ¶ added in v1.1.2
func (*CacheKey) XXX_Unmarshal ¶ added in v1.1.2
type CacheKeys ¶ added in v1.1.2
type CacheKeys struct { Keys []CacheKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CacheKeys) Descriptor ¶ added in v1.1.2
func (*CacheKeys) MarshalToSizedBuffer ¶ added in v1.1.2
func (*CacheKeys) ProtoMessage ¶ added in v1.1.2
func (*CacheKeys) ProtoMessage()
func (*CacheKeys) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *CacheKeys) XXX_DiscardUnknown()
func (*CacheKeys) XXX_Marshal ¶ added in v1.1.2
func (*CacheKeys) XXX_Unmarshal ¶ added in v1.1.2
type CmdMethod ¶
type CmdMethod int32
const ( // Query is the common query command. CmdMethod_Query CmdMethod = 0 // ShowProcessList represents the show process list query. CmdMethod_ShowProcessList CmdMethod = 1 // AlterAccount represent set account status as restricted CmdMethod_AlterAccount CmdMethod = 2 // KillConn represents the kill connection request. CmdMethod_KillConn CmdMethod = 3 // ProcessTraceSpan process the trace span cmd transferred from // other cn CmdMethod_TraceSpan CmdMethod = 4 // GetLockInfo gets the lock info from the cn CmdMethod_GetLockInfo CmdMethod = 5 // GetTxnInfo gets the txn info from the cn CmdMethod_GetTxnInfo CmdMethod = 6 // GetCacheInfo gets the cache info from the cn,tn CmdMethod_GetCacheInfo CmdMethod = 7 // 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 = 8 // GetCommit get latest commit timestamp of cn. CmdMethod_GetCommit CmdMethod = 9 CmdMethod_RunTask CmdMethod = 13 // RemoveRemoteLockTable remove remote lock table on all cn CmdMethod_RemoveRemoteLockTable CmdMethod = 14 CmdMethod_GetLatestBind CmdMethod = 15 // UnsubscribeTable unsubscribes a table in logtail client. CmdMethod_UnsubscribeTable CmdMethod = 16 // GetCacheData is the method to get cached data from fileservice in remote node. CmdMethod_GetCacheData CmdMethod = 17 // GetStatsInfo is the method to get stats info from remote node. CmdMethod_GetStatsInfo CmdMethod = 18 // GetPipelineInfo is the method to get pipeline info from CN CmdMethod_GetPipelineInfo CmdMethod = 19 // MigrateConnFrom get session info from the previous cn node. CmdMethod_MigrateConnFrom CmdMethod = 20 // MigrateConnTo migrate the session info to the new cn node. CmdMethod_MigrateConnTo CmdMethod = 21 )
func (CmdMethod) EnumDescriptor ¶
type GetCacheDataRequest ¶ added in v1.1.2
type GetCacheDataRequest struct { // RequestCacheKey is the requested cache key. RequestCacheKey []*RequestCacheKey `protobuf:"bytes,1,rep,name=RequestCacheKey,proto3" json:"RequestCacheKey,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
GetCacheDataRequest is the request that try to get cache from remote node.
func (*GetCacheDataRequest) Descriptor ¶ added in v1.1.2
func (*GetCacheDataRequest) Descriptor() ([]byte, []int)
func (*GetCacheDataRequest) GetRequestCacheKey ¶ added in v1.1.2
func (m *GetCacheDataRequest) GetRequestCacheKey() []*RequestCacheKey
func (*GetCacheDataRequest) Marshal ¶ added in v1.1.2
func (m *GetCacheDataRequest) Marshal() (dAtA []byte, err error)
func (*GetCacheDataRequest) MarshalTo ¶ added in v1.1.2
func (m *GetCacheDataRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetCacheDataRequest) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *GetCacheDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCacheDataRequest) ProtoMessage ¶ added in v1.1.2
func (*GetCacheDataRequest) ProtoMessage()
func (*GetCacheDataRequest) Reset ¶ added in v1.1.2
func (m *GetCacheDataRequest) Reset()
func (*GetCacheDataRequest) Size ¶ added in v1.1.2
func (m *GetCacheDataRequest) Size() (n int)
func (*GetCacheDataRequest) String ¶ added in v1.1.2
func (m *GetCacheDataRequest) String() string
func (*GetCacheDataRequest) Unmarshal ¶ added in v1.1.2
func (m *GetCacheDataRequest) Unmarshal(dAtA []byte) error
func (*GetCacheDataRequest) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *GetCacheDataRequest) XXX_DiscardUnknown()
func (*GetCacheDataRequest) XXX_Marshal ¶ added in v1.1.2
func (m *GetCacheDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCacheDataRequest) XXX_Merge ¶ added in v1.1.2
func (m *GetCacheDataRequest) XXX_Merge(src proto.Message)
func (*GetCacheDataRequest) XXX_Size ¶ added in v1.1.2
func (m *GetCacheDataRequest) XXX_Size() int
func (*GetCacheDataRequest) XXX_Unmarshal ¶ added in v1.1.2
func (m *GetCacheDataRequest) XXX_Unmarshal(b []byte) error
type GetCacheDataResponse ¶ added in v1.1.2
type GetCacheDataResponse struct { ResponseCacheData []*ResponseCacheData `protobuf:"bytes,1,rep,name=ResponseCacheData,proto3" json:"ResponseCacheData,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
GetCacheDataResponse is the response of get cache data.
func (*GetCacheDataResponse) Descriptor ¶ added in v1.1.2
func (*GetCacheDataResponse) Descriptor() ([]byte, []int)
func (*GetCacheDataResponse) GetResponseCacheData ¶ added in v1.1.2
func (m *GetCacheDataResponse) GetResponseCacheData() []*ResponseCacheData
func (*GetCacheDataResponse) Marshal ¶ added in v1.1.2
func (m *GetCacheDataResponse) Marshal() (dAtA []byte, err error)
func (*GetCacheDataResponse) MarshalTo ¶ added in v1.1.2
func (m *GetCacheDataResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetCacheDataResponse) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *GetCacheDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCacheDataResponse) ProtoMessage ¶ added in v1.1.2
func (*GetCacheDataResponse) ProtoMessage()
func (*GetCacheDataResponse) Reset ¶ added in v1.1.2
func (m *GetCacheDataResponse) Reset()
func (*GetCacheDataResponse) Size ¶ added in v1.1.2
func (m *GetCacheDataResponse) Size() (n int)
func (*GetCacheDataResponse) String ¶ added in v1.1.2
func (m *GetCacheDataResponse) String() string
func (*GetCacheDataResponse) Unmarshal ¶ added in v1.1.2
func (m *GetCacheDataResponse) Unmarshal(dAtA []byte) error
func (*GetCacheDataResponse) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *GetCacheDataResponse) XXX_DiscardUnknown()
func (*GetCacheDataResponse) XXX_Marshal ¶ added in v1.1.2
func (m *GetCacheDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCacheDataResponse) XXX_Merge ¶ added in v1.1.2
func (m *GetCacheDataResponse) XXX_Merge(src proto.Message)
func (*GetCacheDataResponse) XXX_Size ¶ added in v1.1.2
func (m *GetCacheDataResponse) XXX_Size() int
func (*GetCacheDataResponse) XXX_Unmarshal ¶ added in v1.1.2
func (m *GetCacheDataResponse) XXX_Unmarshal(b []byte) error
type GetCacheInfoRequest ¶ added in v1.1.0
type GetCacheInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetCacheInfoRequest) Descriptor ¶ added in v1.1.0
func (*GetCacheInfoRequest) Descriptor() ([]byte, []int)
func (*GetCacheInfoRequest) Marshal ¶ added in v1.1.0
func (m *GetCacheInfoRequest) Marshal() (dAtA []byte, err error)
func (*GetCacheInfoRequest) MarshalTo ¶ added in v1.1.0
func (m *GetCacheInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetCacheInfoRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetCacheInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCacheInfoRequest) ProtoMessage ¶ added in v1.1.0
func (*GetCacheInfoRequest) ProtoMessage()
func (*GetCacheInfoRequest) Reset ¶ added in v1.1.0
func (m *GetCacheInfoRequest) Reset()
func (*GetCacheInfoRequest) Size ¶ added in v1.1.0
func (m *GetCacheInfoRequest) Size() (n int)
func (*GetCacheInfoRequest) String ¶ added in v1.1.0
func (m *GetCacheInfoRequest) String() string
func (*GetCacheInfoRequest) Unmarshal ¶ added in v1.1.0
func (m *GetCacheInfoRequest) Unmarshal(dAtA []byte) error
func (*GetCacheInfoRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetCacheInfoRequest) XXX_DiscardUnknown()
func (*GetCacheInfoRequest) XXX_Marshal ¶ added in v1.1.0
func (m *GetCacheInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCacheInfoRequest) XXX_Merge ¶ added in v1.1.0
func (m *GetCacheInfoRequest) XXX_Merge(src proto.Message)
func (*GetCacheInfoRequest) XXX_Size ¶ added in v1.1.0
func (m *GetCacheInfoRequest) XXX_Size() int
func (*GetCacheInfoRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetCacheInfoRequest) XXX_Unmarshal(b []byte) error
type GetCacheInfoResponse ¶ added in v1.1.0
type GetCacheInfoResponse struct { CacheInfoList []*CacheInfo `protobuf:"bytes,1,rep,name=CacheInfoList,proto3" json:"CacheInfoList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetCacheInfoResponse) Descriptor ¶ added in v1.1.0
func (*GetCacheInfoResponse) Descriptor() ([]byte, []int)
func (*GetCacheInfoResponse) GetCacheInfoList ¶ added in v1.1.0
func (m *GetCacheInfoResponse) GetCacheInfoList() []*CacheInfo
func (*GetCacheInfoResponse) Marshal ¶ added in v1.1.0
func (m *GetCacheInfoResponse) Marshal() (dAtA []byte, err error)
func (*GetCacheInfoResponse) MarshalTo ¶ added in v1.1.0
func (m *GetCacheInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetCacheInfoResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetCacheInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCacheInfoResponse) ProtoMessage ¶ added in v1.1.0
func (*GetCacheInfoResponse) ProtoMessage()
func (*GetCacheInfoResponse) Reset ¶ added in v1.1.0
func (m *GetCacheInfoResponse) Reset()
func (*GetCacheInfoResponse) Size ¶ added in v1.1.0
func (m *GetCacheInfoResponse) Size() (n int)
func (*GetCacheInfoResponse) String ¶ added in v1.1.0
func (m *GetCacheInfoResponse) String() string
func (*GetCacheInfoResponse) Unmarshal ¶ added in v1.1.0
func (m *GetCacheInfoResponse) Unmarshal(dAtA []byte) error
func (*GetCacheInfoResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetCacheInfoResponse) XXX_DiscardUnknown()
func (*GetCacheInfoResponse) XXX_Marshal ¶ added in v1.1.0
func (m *GetCacheInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCacheInfoResponse) XXX_Merge ¶ added in v1.1.0
func (m *GetCacheInfoResponse) XXX_Merge(src proto.Message)
func (*GetCacheInfoResponse) XXX_Size ¶ added in v1.1.0
func (m *GetCacheInfoResponse) XXX_Size() int
func (*GetCacheInfoResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetCacheInfoResponse) XXX_Unmarshal(b []byte) error
type GetCommitRequest ¶ added in v1.1.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 v1.1.0
func (*GetCommitRequest) Descriptor() ([]byte, []int)
func (*GetCommitRequest) Marshal ¶ added in v1.1.0
func (m *GetCommitRequest) Marshal() (dAtA []byte, err error)
func (*GetCommitRequest) MarshalTo ¶ added in v1.1.0
func (m *GetCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetCommitRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCommitRequest) ProtoMessage ¶ added in v1.1.0
func (*GetCommitRequest) ProtoMessage()
func (*GetCommitRequest) Reset ¶ added in v1.1.0
func (m *GetCommitRequest) Reset()
func (*GetCommitRequest) Size ¶ added in v1.1.0
func (m *GetCommitRequest) Size() (n int)
func (*GetCommitRequest) String ¶ added in v1.1.0
func (m *GetCommitRequest) String() string
func (*GetCommitRequest) Unmarshal ¶ added in v1.1.0
func (m *GetCommitRequest) Unmarshal(dAtA []byte) error
func (*GetCommitRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetCommitRequest) XXX_DiscardUnknown()
func (*GetCommitRequest) XXX_Marshal ¶ added in v1.1.0
func (m *GetCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCommitRequest) XXX_Merge ¶ added in v1.1.0
func (m *GetCommitRequest) XXX_Merge(src proto.Message)
func (*GetCommitRequest) XXX_Size ¶ added in v1.1.0
func (m *GetCommitRequest) XXX_Size() int
func (*GetCommitRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetCommitRequest) XXX_Unmarshal(b []byte) error
type GetCommitResponse ¶ added in v1.1.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 v1.1.0
func (*GetCommitResponse) Descriptor() ([]byte, []int)
func (*GetCommitResponse) GetCurrentCommitTS ¶ added in v1.1.0
func (m *GetCommitResponse) GetCurrentCommitTS() timestamp.Timestamp
func (*GetCommitResponse) Marshal ¶ added in v1.1.0
func (m *GetCommitResponse) Marshal() (dAtA []byte, err error)
func (*GetCommitResponse) MarshalTo ¶ added in v1.1.0
func (m *GetCommitResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetCommitResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCommitResponse) ProtoMessage ¶ added in v1.1.0
func (*GetCommitResponse) ProtoMessage()
func (*GetCommitResponse) Reset ¶ added in v1.1.0
func (m *GetCommitResponse) Reset()
func (*GetCommitResponse) Size ¶ added in v1.1.0
func (m *GetCommitResponse) Size() (n int)
func (*GetCommitResponse) String ¶ added in v1.1.0
func (m *GetCommitResponse) String() string
func (*GetCommitResponse) Unmarshal ¶ added in v1.1.0
func (m *GetCommitResponse) Unmarshal(dAtA []byte) error
func (*GetCommitResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetCommitResponse) XXX_DiscardUnknown()
func (*GetCommitResponse) XXX_Marshal ¶ added in v1.1.0
func (m *GetCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCommitResponse) XXX_Merge ¶ added in v1.1.0
func (m *GetCommitResponse) XXX_Merge(src proto.Message)
func (*GetCommitResponse) XXX_Size ¶ added in v1.1.0
func (m *GetCommitResponse) XXX_Size() int
func (*GetCommitResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetCommitResponse) XXX_Unmarshal(b []byte) error
type GetLatestBindRequest ¶ added in v1.1.1
type GetLatestBindRequest struct { TableID uint64 `protobuf:"varint,1,opt,name=TableID,proto3" json:"TableID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLatestBindRequest) Descriptor ¶ added in v1.1.1
func (*GetLatestBindRequest) Descriptor() ([]byte, []int)
func (*GetLatestBindRequest) GetTableID ¶ added in v1.1.1
func (m *GetLatestBindRequest) GetTableID() uint64
func (*GetLatestBindRequest) Marshal ¶ added in v1.1.1
func (m *GetLatestBindRequest) Marshal() (dAtA []byte, err error)
func (*GetLatestBindRequest) MarshalTo ¶ added in v1.1.1
func (m *GetLatestBindRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetLatestBindRequest) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *GetLatestBindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetLatestBindRequest) ProtoMessage ¶ added in v1.1.1
func (*GetLatestBindRequest) ProtoMessage()
func (*GetLatestBindRequest) Reset ¶ added in v1.1.1
func (m *GetLatestBindRequest) Reset()
func (*GetLatestBindRequest) Size ¶ added in v1.1.1
func (m *GetLatestBindRequest) Size() (n int)
func (*GetLatestBindRequest) String ¶ added in v1.1.1
func (m *GetLatestBindRequest) String() string
func (*GetLatestBindRequest) Unmarshal ¶ added in v1.1.1
func (m *GetLatestBindRequest) Unmarshal(dAtA []byte) error
func (*GetLatestBindRequest) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *GetLatestBindRequest) XXX_DiscardUnknown()
func (*GetLatestBindRequest) XXX_Marshal ¶ added in v1.1.1
func (m *GetLatestBindRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLatestBindRequest) XXX_Merge ¶ added in v1.1.1
func (m *GetLatestBindRequest) XXX_Merge(src proto.Message)
func (*GetLatestBindRequest) XXX_Size ¶ added in v1.1.1
func (m *GetLatestBindRequest) XXX_Size() int
func (*GetLatestBindRequest) XXX_Unmarshal ¶ added in v1.1.1
func (m *GetLatestBindRequest) XXX_Unmarshal(b []byte) error
type GetLatestBindResponse ¶ added in v1.1.1
type GetLatestBindResponse struct { Bind string `protobuf:"bytes,1,opt,name=Bind,proto3" json:"Bind,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLatestBindResponse) Descriptor ¶ added in v1.1.1
func (*GetLatestBindResponse) Descriptor() ([]byte, []int)
func (*GetLatestBindResponse) GetBind ¶ added in v1.1.1
func (m *GetLatestBindResponse) GetBind() string
func (*GetLatestBindResponse) Marshal ¶ added in v1.1.1
func (m *GetLatestBindResponse) Marshal() (dAtA []byte, err error)
func (*GetLatestBindResponse) MarshalTo ¶ added in v1.1.1
func (m *GetLatestBindResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetLatestBindResponse) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *GetLatestBindResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetLatestBindResponse) ProtoMessage ¶ added in v1.1.1
func (*GetLatestBindResponse) ProtoMessage()
func (*GetLatestBindResponse) Reset ¶ added in v1.1.1
func (m *GetLatestBindResponse) Reset()
func (*GetLatestBindResponse) Size ¶ added in v1.1.1
func (m *GetLatestBindResponse) Size() (n int)
func (*GetLatestBindResponse) String ¶ added in v1.1.1
func (m *GetLatestBindResponse) String() string
func (*GetLatestBindResponse) Unmarshal ¶ added in v1.1.1
func (m *GetLatestBindResponse) Unmarshal(dAtA []byte) error
func (*GetLatestBindResponse) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *GetLatestBindResponse) XXX_DiscardUnknown()
func (*GetLatestBindResponse) XXX_Marshal ¶ added in v1.1.1
func (m *GetLatestBindResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLatestBindResponse) XXX_Merge ¶ added in v1.1.1
func (m *GetLatestBindResponse) XXX_Merge(src proto.Message)
func (*GetLatestBindResponse) XXX_Size ¶ added in v1.1.1
func (m *GetLatestBindResponse) XXX_Size() int
func (*GetLatestBindResponse) XXX_Unmarshal ¶ added in v1.1.1
func (m *GetLatestBindResponse) XXX_Unmarshal(b []byte) error
type GetLockInfoRequest ¶ added in v1.1.0
type GetLockInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLockInfoRequest) Descriptor ¶ added in v1.1.0
func (*GetLockInfoRequest) Descriptor() ([]byte, []int)
func (*GetLockInfoRequest) Marshal ¶ added in v1.1.0
func (m *GetLockInfoRequest) Marshal() (dAtA []byte, err error)
func (*GetLockInfoRequest) MarshalTo ¶ added in v1.1.0
func (m *GetLockInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetLockInfoRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetLockInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetLockInfoRequest) ProtoMessage ¶ added in v1.1.0
func (*GetLockInfoRequest) ProtoMessage()
func (*GetLockInfoRequest) Reset ¶ added in v1.1.0
func (m *GetLockInfoRequest) Reset()
func (*GetLockInfoRequest) Size ¶ added in v1.1.0
func (m *GetLockInfoRequest) Size() (n int)
func (*GetLockInfoRequest) String ¶ added in v1.1.0
func (m *GetLockInfoRequest) String() string
func (*GetLockInfoRequest) Unmarshal ¶ added in v1.1.0
func (m *GetLockInfoRequest) Unmarshal(dAtA []byte) error
func (*GetLockInfoRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetLockInfoRequest) XXX_DiscardUnknown()
func (*GetLockInfoRequest) XXX_Marshal ¶ added in v1.1.0
func (m *GetLockInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLockInfoRequest) XXX_Merge ¶ added in v1.1.0
func (m *GetLockInfoRequest) XXX_Merge(src proto.Message)
func (*GetLockInfoRequest) XXX_Size ¶ added in v1.1.0
func (m *GetLockInfoRequest) XXX_Size() int
func (*GetLockInfoRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetLockInfoRequest) XXX_Unmarshal(b []byte) error
type GetLockInfoResponse ¶ added in v1.1.0
type GetLockInfoResponse struct { CnId string `protobuf:"bytes,1,opt,name=CnId,proto3" json:"CnId,omitempty"` LockInfoList []*LockInfo `protobuf:"bytes,2,rep,name=LockInfoList,proto3" json:"LockInfoList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLockInfoResponse) Descriptor ¶ added in v1.1.0
func (*GetLockInfoResponse) Descriptor() ([]byte, []int)
func (*GetLockInfoResponse) GetCnId ¶ added in v1.1.0
func (m *GetLockInfoResponse) GetCnId() string
func (*GetLockInfoResponse) GetLockInfoList ¶ added in v1.1.0
func (m *GetLockInfoResponse) GetLockInfoList() []*LockInfo
func (*GetLockInfoResponse) Marshal ¶ added in v1.1.0
func (m *GetLockInfoResponse) Marshal() (dAtA []byte, err error)
func (*GetLockInfoResponse) MarshalTo ¶ added in v1.1.0
func (m *GetLockInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetLockInfoResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetLockInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetLockInfoResponse) ProtoMessage ¶ added in v1.1.0
func (*GetLockInfoResponse) ProtoMessage()
func (*GetLockInfoResponse) Reset ¶ added in v1.1.0
func (m *GetLockInfoResponse) Reset()
func (*GetLockInfoResponse) Size ¶ added in v1.1.0
func (m *GetLockInfoResponse) Size() (n int)
func (*GetLockInfoResponse) String ¶ added in v1.1.0
func (m *GetLockInfoResponse) String() string
func (*GetLockInfoResponse) Unmarshal ¶ added in v1.1.0
func (m *GetLockInfoResponse) Unmarshal(dAtA []byte) error
func (*GetLockInfoResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetLockInfoResponse) XXX_DiscardUnknown()
func (*GetLockInfoResponse) XXX_Marshal ¶ added in v1.1.0
func (m *GetLockInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLockInfoResponse) XXX_Merge ¶ added in v1.1.0
func (m *GetLockInfoResponse) XXX_Merge(src proto.Message)
func (*GetLockInfoResponse) XXX_Size ¶ added in v1.1.0
func (m *GetLockInfoResponse) XXX_Size() int
func (*GetLockInfoResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetLockInfoResponse) XXX_Unmarshal(b []byte) error
type GetPipelineInfoRequest ¶ added in v1.1.2
type GetPipelineInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetPipelineInfoRequest) Descriptor ¶ added in v1.1.2
func (*GetPipelineInfoRequest) Descriptor() ([]byte, []int)
func (*GetPipelineInfoRequest) Marshal ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) Marshal() (dAtA []byte, err error)
func (*GetPipelineInfoRequest) MarshalTo ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetPipelineInfoRequest) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetPipelineInfoRequest) ProtoMessage ¶ added in v1.1.2
func (*GetPipelineInfoRequest) ProtoMessage()
func (*GetPipelineInfoRequest) Reset ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) Reset()
func (*GetPipelineInfoRequest) Size ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) Size() (n int)
func (*GetPipelineInfoRequest) String ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) String() string
func (*GetPipelineInfoRequest) Unmarshal ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) Unmarshal(dAtA []byte) error
func (*GetPipelineInfoRequest) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) XXX_DiscardUnknown()
func (*GetPipelineInfoRequest) XXX_Marshal ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPipelineInfoRequest) XXX_Merge ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) XXX_Merge(src proto.Message)
func (*GetPipelineInfoRequest) XXX_Size ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) XXX_Size() int
func (*GetPipelineInfoRequest) XXX_Unmarshal ¶ added in v1.1.2
func (m *GetPipelineInfoRequest) XXX_Unmarshal(b []byte) error
type GetPipelineInfoResponse ¶ added in v1.1.2
type GetPipelineInfoResponse struct { // Count is the total pipelines running in the server Count int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetPipelineInfoResponse) Descriptor ¶ added in v1.1.2
func (*GetPipelineInfoResponse) Descriptor() ([]byte, []int)
func (*GetPipelineInfoResponse) GetCount ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) GetCount() int64
func (*GetPipelineInfoResponse) Marshal ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) Marshal() (dAtA []byte, err error)
func (*GetPipelineInfoResponse) MarshalTo ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetPipelineInfoResponse) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetPipelineInfoResponse) ProtoMessage ¶ added in v1.1.2
func (*GetPipelineInfoResponse) ProtoMessage()
func (*GetPipelineInfoResponse) Reset ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) Reset()
func (*GetPipelineInfoResponse) Size ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) Size() (n int)
func (*GetPipelineInfoResponse) String ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) String() string
func (*GetPipelineInfoResponse) Unmarshal ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) Unmarshal(dAtA []byte) error
func (*GetPipelineInfoResponse) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) XXX_DiscardUnknown()
func (*GetPipelineInfoResponse) XXX_Marshal ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPipelineInfoResponse) XXX_Merge ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) XXX_Merge(src proto.Message)
func (*GetPipelineInfoResponse) XXX_Size ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) XXX_Size() int
func (*GetPipelineInfoResponse) XXX_Unmarshal ¶ added in v1.1.2
func (m *GetPipelineInfoResponse) XXX_Unmarshal(b []byte) error
type GetStatsInfoRequest ¶ added in v1.1.2
type GetStatsInfoRequest struct { StatsInfoKey *statsinfo.StatsInfoKey `protobuf:"bytes,1,opt,name=StatsInfoKey,proto3" json:"StatsInfoKey,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetStatsInfoRequest) Descriptor ¶ added in v1.1.2
func (*GetStatsInfoRequest) Descriptor() ([]byte, []int)
func (*GetStatsInfoRequest) GetStatsInfoKey ¶ added in v1.1.2
func (m *GetStatsInfoRequest) GetStatsInfoKey() *statsinfo.StatsInfoKey
func (*GetStatsInfoRequest) Marshal ¶ added in v1.1.2
func (m *GetStatsInfoRequest) Marshal() (dAtA []byte, err error)
func (*GetStatsInfoRequest) MarshalTo ¶ added in v1.1.2
func (m *GetStatsInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetStatsInfoRequest) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *GetStatsInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetStatsInfoRequest) ProtoMessage ¶ added in v1.1.2
func (*GetStatsInfoRequest) ProtoMessage()
func (*GetStatsInfoRequest) Reset ¶ added in v1.1.2
func (m *GetStatsInfoRequest) Reset()
func (*GetStatsInfoRequest) Size ¶ added in v1.1.2
func (m *GetStatsInfoRequest) Size() (n int)
func (*GetStatsInfoRequest) String ¶ added in v1.1.2
func (m *GetStatsInfoRequest) String() string
func (*GetStatsInfoRequest) Unmarshal ¶ added in v1.1.2
func (m *GetStatsInfoRequest) Unmarshal(dAtA []byte) error
func (*GetStatsInfoRequest) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *GetStatsInfoRequest) XXX_DiscardUnknown()
func (*GetStatsInfoRequest) XXX_Marshal ¶ added in v1.1.2
func (m *GetStatsInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetStatsInfoRequest) XXX_Merge ¶ added in v1.1.2
func (m *GetStatsInfoRequest) XXX_Merge(src proto.Message)
func (*GetStatsInfoRequest) XXX_Size ¶ added in v1.1.2
func (m *GetStatsInfoRequest) XXX_Size() int
func (*GetStatsInfoRequest) XXX_Unmarshal ¶ added in v1.1.2
func (m *GetStatsInfoRequest) XXX_Unmarshal(b []byte) error
type GetStatsInfoResponse ¶ added in v1.1.2
type GetStatsInfoResponse struct { StatsInfo *statsinfo.StatsInfo `protobuf:"bytes,1,opt,name=StatsInfo,proto3" json:"StatsInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetStatsInfoResponse) Descriptor ¶ added in v1.1.2
func (*GetStatsInfoResponse) Descriptor() ([]byte, []int)
func (*GetStatsInfoResponse) GetStatsInfo ¶ added in v1.1.2
func (m *GetStatsInfoResponse) GetStatsInfo() *statsinfo.StatsInfo
func (*GetStatsInfoResponse) Marshal ¶ added in v1.1.2
func (m *GetStatsInfoResponse) Marshal() (dAtA []byte, err error)
func (*GetStatsInfoResponse) MarshalTo ¶ added in v1.1.2
func (m *GetStatsInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetStatsInfoResponse) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *GetStatsInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetStatsInfoResponse) ProtoMessage ¶ added in v1.1.2
func (*GetStatsInfoResponse) ProtoMessage()
func (*GetStatsInfoResponse) Reset ¶ added in v1.1.2
func (m *GetStatsInfoResponse) Reset()
func (*GetStatsInfoResponse) Size ¶ added in v1.1.2
func (m *GetStatsInfoResponse) Size() (n int)
func (*GetStatsInfoResponse) String ¶ added in v1.1.2
func (m *GetStatsInfoResponse) String() string
func (*GetStatsInfoResponse) Unmarshal ¶ added in v1.1.2
func (m *GetStatsInfoResponse) Unmarshal(dAtA []byte) error
func (*GetStatsInfoResponse) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *GetStatsInfoResponse) XXX_DiscardUnknown()
func (*GetStatsInfoResponse) XXX_Marshal ¶ added in v1.1.2
func (m *GetStatsInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetStatsInfoResponse) XXX_Merge ¶ added in v1.1.2
func (m *GetStatsInfoResponse) XXX_Merge(src proto.Message)
func (*GetStatsInfoResponse) XXX_Size ¶ added in v1.1.2
func (m *GetStatsInfoResponse) XXX_Size() int
func (*GetStatsInfoResponse) XXX_Unmarshal ¶ added in v1.1.2
func (m *GetStatsInfoResponse) XXX_Unmarshal(b []byte) error
type GetTxnInfoRequest ¶ added in v1.1.0
type GetTxnInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTxnInfoRequest) Descriptor ¶ added in v1.1.0
func (*GetTxnInfoRequest) Descriptor() ([]byte, []int)
func (*GetTxnInfoRequest) Marshal ¶ added in v1.1.0
func (m *GetTxnInfoRequest) Marshal() (dAtA []byte, err error)
func (*GetTxnInfoRequest) MarshalTo ¶ added in v1.1.0
func (m *GetTxnInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetTxnInfoRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetTxnInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetTxnInfoRequest) ProtoMessage ¶ added in v1.1.0
func (*GetTxnInfoRequest) ProtoMessage()
func (*GetTxnInfoRequest) Reset ¶ added in v1.1.0
func (m *GetTxnInfoRequest) Reset()
func (*GetTxnInfoRequest) Size ¶ added in v1.1.0
func (m *GetTxnInfoRequest) Size() (n int)
func (*GetTxnInfoRequest) String ¶ added in v1.1.0
func (m *GetTxnInfoRequest) String() string
func (*GetTxnInfoRequest) Unmarshal ¶ added in v1.1.0
func (m *GetTxnInfoRequest) Unmarshal(dAtA []byte) error
func (*GetTxnInfoRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetTxnInfoRequest) XXX_DiscardUnknown()
func (*GetTxnInfoRequest) XXX_Marshal ¶ added in v1.1.0
func (m *GetTxnInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTxnInfoRequest) XXX_Merge ¶ added in v1.1.0
func (m *GetTxnInfoRequest) XXX_Merge(src proto.Message)
func (*GetTxnInfoRequest) XXX_Size ¶ added in v1.1.0
func (m *GetTxnInfoRequest) XXX_Size() int
func (*GetTxnInfoRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetTxnInfoRequest) XXX_Unmarshal(b []byte) error
type GetTxnInfoResponse ¶ added in v1.1.0
type GetTxnInfoResponse struct { CnId string `protobuf:"bytes,1,opt,name=CnId,proto3" json:"CnId,omitempty"` TxnInfoList []*TxnInfo `protobuf:"bytes,2,rep,name=TxnInfoList,proto3" json:"TxnInfoList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTxnInfoResponse) Descriptor ¶ added in v1.1.0
func (*GetTxnInfoResponse) Descriptor() ([]byte, []int)
func (*GetTxnInfoResponse) GetCnId ¶ added in v1.1.0
func (m *GetTxnInfoResponse) GetCnId() string
func (*GetTxnInfoResponse) GetTxnInfoList ¶ added in v1.1.0
func (m *GetTxnInfoResponse) GetTxnInfoList() []*TxnInfo
func (*GetTxnInfoResponse) Marshal ¶ added in v1.1.0
func (m *GetTxnInfoResponse) Marshal() (dAtA []byte, err error)
func (*GetTxnInfoResponse) MarshalTo ¶ added in v1.1.0
func (m *GetTxnInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetTxnInfoResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *GetTxnInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetTxnInfoResponse) ProtoMessage ¶ added in v1.1.0
func (*GetTxnInfoResponse) ProtoMessage()
func (*GetTxnInfoResponse) Reset ¶ added in v1.1.0
func (m *GetTxnInfoResponse) Reset()
func (*GetTxnInfoResponse) Size ¶ added in v1.1.0
func (m *GetTxnInfoResponse) Size() (n int)
func (*GetTxnInfoResponse) String ¶ added in v1.1.0
func (m *GetTxnInfoResponse) String() string
func (*GetTxnInfoResponse) Unmarshal ¶ added in v1.1.0
func (m *GetTxnInfoResponse) Unmarshal(dAtA []byte) error
func (*GetTxnInfoResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *GetTxnInfoResponse) XXX_DiscardUnknown()
func (*GetTxnInfoResponse) XXX_Marshal ¶ added in v1.1.0
func (m *GetTxnInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTxnInfoResponse) XXX_Merge ¶ added in v1.1.0
func (m *GetTxnInfoResponse) XXX_Merge(src proto.Message)
func (*GetTxnInfoResponse) XXX_Size ¶ added in v1.1.0
func (m *GetTxnInfoResponse) XXX_Size() int
func (*GetTxnInfoResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *GetTxnInfoResponse) XXX_Unmarshal(b []byte) error
type KillConnRequest ¶
type KillConnRequest struct { AccountID int64 `protobuf:"varint,1,opt,name=AccountID,proto3" json:"AccountID,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=Version,proto3" json:"Version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KillConnRequest is the request that kill the connections belongs to the account.
func (*KillConnRequest) Descriptor ¶
func (*KillConnRequest) Descriptor() ([]byte, []int)
func (*KillConnRequest) GetAccountID ¶
func (m *KillConnRequest) GetAccountID() int64
func (*KillConnRequest) GetVersion ¶
func (m *KillConnRequest) GetVersion() uint64
func (*KillConnRequest) Marshal ¶
func (m *KillConnRequest) Marshal() (dAtA []byte, err error)
func (*KillConnRequest) MarshalToSizedBuffer ¶
func (m *KillConnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KillConnRequest) ProtoMessage ¶
func (*KillConnRequest) ProtoMessage()
func (*KillConnRequest) Reset ¶
func (m *KillConnRequest) Reset()
func (*KillConnRequest) Size ¶
func (m *KillConnRequest) Size() (n int)
func (*KillConnRequest) String ¶
func (m *KillConnRequest) String() string
func (*KillConnRequest) Unmarshal ¶
func (m *KillConnRequest) Unmarshal(dAtA []byte) error
func (*KillConnRequest) XXX_DiscardUnknown ¶
func (m *KillConnRequest) XXX_DiscardUnknown()
func (*KillConnRequest) XXX_Marshal ¶
func (m *KillConnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KillConnRequest) XXX_Merge ¶
func (m *KillConnRequest) XXX_Merge(src proto.Message)
func (*KillConnRequest) XXX_Size ¶
func (m *KillConnRequest) XXX_Size() int
func (*KillConnRequest) XXX_Unmarshal ¶
func (m *KillConnRequest) XXX_Unmarshal(b []byte) error
type KillConnResponse ¶
type KillConnResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KillConnResponse is the response to the kill connection request.
func (*KillConnResponse) Descriptor ¶
func (*KillConnResponse) Descriptor() ([]byte, []int)
func (*KillConnResponse) GetSuccess ¶
func (m *KillConnResponse) GetSuccess() bool
func (*KillConnResponse) Marshal ¶
func (m *KillConnResponse) Marshal() (dAtA []byte, err error)
func (*KillConnResponse) MarshalToSizedBuffer ¶
func (m *KillConnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KillConnResponse) ProtoMessage ¶
func (*KillConnResponse) ProtoMessage()
func (*KillConnResponse) Reset ¶
func (m *KillConnResponse) Reset()
func (*KillConnResponse) Size ¶
func (m *KillConnResponse) Size() (n int)
func (*KillConnResponse) String ¶
func (m *KillConnResponse) String() string
func (*KillConnResponse) Unmarshal ¶
func (m *KillConnResponse) Unmarshal(dAtA []byte) error
func (*KillConnResponse) XXX_DiscardUnknown ¶
func (m *KillConnResponse) XXX_DiscardUnknown()
func (*KillConnResponse) XXX_Marshal ¶
func (m *KillConnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KillConnResponse) XXX_Merge ¶
func (m *KillConnResponse) XXX_Merge(src proto.Message)
func (*KillConnResponse) XXX_Size ¶
func (m *KillConnResponse) XXX_Size() int
func (*KillConnResponse) XXX_Unmarshal ¶
func (m *KillConnResponse) XXX_Unmarshal(b []byte) error
type LockInfo ¶ added in v1.1.0
type LockInfo struct { TableId uint64 `protobuf:"varint,1,opt,name=TableId,proto3" json:"TableId,omitempty"` Keys [][]byte `protobuf:"bytes,2,rep,name=Keys,proto3" json:"Keys,omitempty"` LockMode lock.LockMode `protobuf:"varint,3,opt,name=LockMode,proto3,enum=lock.LockMode" json:"LockMode,omitempty"` IsRangeLock bool `protobuf:"varint,4,opt,name=isRangeLock,proto3" json:"isRangeLock,omitempty"` Holders []*lock.WaitTxn `protobuf:"bytes,5,rep,name=Holders,proto3" json:"Holders,omitempty"` Waiters []*lock.WaitTxn `protobuf:"bytes,6,rep,name=Waiters,proto3" json:"Waiters,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LockInfo) Descriptor ¶ added in v1.1.0
func (*LockInfo) GetHolders ¶ added in v1.1.0
func (*LockInfo) GetIsRangeLock ¶ added in v1.1.0
func (*LockInfo) GetLockMode ¶ added in v1.1.0
func (*LockInfo) GetTableId ¶ added in v1.1.0
func (*LockInfo) GetWaiters ¶ added in v1.1.0
func (*LockInfo) MarshalToSizedBuffer ¶ added in v1.1.0
func (*LockInfo) ProtoMessage ¶ added in v1.1.0
func (*LockInfo) ProtoMessage()
func (*LockInfo) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *LockInfo) XXX_DiscardUnknown()
func (*LockInfo) XXX_Marshal ¶ added in v1.1.0
func (*LockInfo) XXX_Unmarshal ¶ added in v1.1.0
type MigrateConnFromRequest ¶ added in v1.1.2
type MigrateConnFromRequest struct { ConnID uint32 `protobuf:"varint,1,opt,name=ConnID,proto3" json:"ConnID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MigrateConnFromRequest) Descriptor ¶ added in v1.1.2
func (*MigrateConnFromRequest) Descriptor() ([]byte, []int)
func (*MigrateConnFromRequest) GetConnID ¶ added in v1.1.2
func (m *MigrateConnFromRequest) GetConnID() uint32
func (*MigrateConnFromRequest) Marshal ¶ added in v1.1.2
func (m *MigrateConnFromRequest) Marshal() (dAtA []byte, err error)
func (*MigrateConnFromRequest) MarshalTo ¶ added in v1.1.2
func (m *MigrateConnFromRequest) MarshalTo(dAtA []byte) (int, error)
func (*MigrateConnFromRequest) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *MigrateConnFromRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrateConnFromRequest) ProtoMessage ¶ added in v1.1.2
func (*MigrateConnFromRequest) ProtoMessage()
func (*MigrateConnFromRequest) Reset ¶ added in v1.1.2
func (m *MigrateConnFromRequest) Reset()
func (*MigrateConnFromRequest) Size ¶ added in v1.1.2
func (m *MigrateConnFromRequest) Size() (n int)
func (*MigrateConnFromRequest) String ¶ added in v1.1.2
func (m *MigrateConnFromRequest) String() string
func (*MigrateConnFromRequest) Unmarshal ¶ added in v1.1.2
func (m *MigrateConnFromRequest) Unmarshal(dAtA []byte) error
func (*MigrateConnFromRequest) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *MigrateConnFromRequest) XXX_DiscardUnknown()
func (*MigrateConnFromRequest) XXX_Marshal ¶ added in v1.1.2
func (m *MigrateConnFromRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrateConnFromRequest) XXX_Merge ¶ added in v1.1.2
func (m *MigrateConnFromRequest) XXX_Merge(src proto.Message)
func (*MigrateConnFromRequest) XXX_Size ¶ added in v1.1.2
func (m *MigrateConnFromRequest) XXX_Size() int
func (*MigrateConnFromRequest) XXX_Unmarshal ¶ added in v1.1.2
func (m *MigrateConnFromRequest) XXX_Unmarshal(b []byte) error
type MigrateConnFromResponse ¶ added in v1.1.2
type MigrateConnFromResponse struct { DB string `protobuf:"bytes,1,opt,name=DB,proto3" json:"DB,omitempty"` PrepareStmts []*PrepareStmt `protobuf:"bytes,2,rep,name=PrepareStmts,proto3" json:"PrepareStmts,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MigrateConnFromResponse) Descriptor ¶ added in v1.1.2
func (*MigrateConnFromResponse) Descriptor() ([]byte, []int)
func (*MigrateConnFromResponse) GetDB ¶ added in v1.1.2
func (m *MigrateConnFromResponse) GetDB() string
func (*MigrateConnFromResponse) GetPrepareStmts ¶ added in v1.1.2
func (m *MigrateConnFromResponse) GetPrepareStmts() []*PrepareStmt
func (*MigrateConnFromResponse) Marshal ¶ added in v1.1.2
func (m *MigrateConnFromResponse) Marshal() (dAtA []byte, err error)
func (*MigrateConnFromResponse) MarshalTo ¶ added in v1.1.2
func (m *MigrateConnFromResponse) MarshalTo(dAtA []byte) (int, error)
func (*MigrateConnFromResponse) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *MigrateConnFromResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrateConnFromResponse) ProtoMessage ¶ added in v1.1.2
func (*MigrateConnFromResponse) ProtoMessage()
func (*MigrateConnFromResponse) Reset ¶ added in v1.1.2
func (m *MigrateConnFromResponse) Reset()
func (*MigrateConnFromResponse) Size ¶ added in v1.1.2
func (m *MigrateConnFromResponse) Size() (n int)
func (*MigrateConnFromResponse) String ¶ added in v1.1.2
func (m *MigrateConnFromResponse) String() string
func (*MigrateConnFromResponse) Unmarshal ¶ added in v1.1.2
func (m *MigrateConnFromResponse) Unmarshal(dAtA []byte) error
func (*MigrateConnFromResponse) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *MigrateConnFromResponse) XXX_DiscardUnknown()
func (*MigrateConnFromResponse) XXX_Marshal ¶ added in v1.1.2
func (m *MigrateConnFromResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrateConnFromResponse) XXX_Merge ¶ added in v1.1.2
func (m *MigrateConnFromResponse) XXX_Merge(src proto.Message)
func (*MigrateConnFromResponse) XXX_Size ¶ added in v1.1.2
func (m *MigrateConnFromResponse) XXX_Size() int
func (*MigrateConnFromResponse) XXX_Unmarshal ¶ added in v1.1.2
func (m *MigrateConnFromResponse) XXX_Unmarshal(b []byte) error
type MigrateConnToRequest ¶ added in v1.1.2
type MigrateConnToRequest struct { ConnID uint32 `protobuf:"varint,1,opt,name=ConnID,proto3" json:"ConnID,omitempty"` DB string `protobuf:"bytes,2,opt,name=DB,proto3" json:"DB,omitempty"` SetVarStmts []string `protobuf:"bytes,3,rep,name=SetVarStmts,proto3" json:"SetVarStmts,omitempty"` PrepareStmts []*PrepareStmt `protobuf:"bytes,4,rep,name=PrepareStmts,proto3" json:"PrepareStmts,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MigrateConnToRequest) Descriptor ¶ added in v1.1.2
func (*MigrateConnToRequest) Descriptor() ([]byte, []int)
func (*MigrateConnToRequest) GetConnID ¶ added in v1.1.2
func (m *MigrateConnToRequest) GetConnID() uint32
func (*MigrateConnToRequest) GetDB ¶ added in v1.1.2
func (m *MigrateConnToRequest) GetDB() string
func (*MigrateConnToRequest) GetPrepareStmts ¶ added in v1.1.2
func (m *MigrateConnToRequest) GetPrepareStmts() []*PrepareStmt
func (*MigrateConnToRequest) GetSetVarStmts ¶ added in v1.1.2
func (m *MigrateConnToRequest) GetSetVarStmts() []string
func (*MigrateConnToRequest) Marshal ¶ added in v1.1.2
func (m *MigrateConnToRequest) Marshal() (dAtA []byte, err error)
func (*MigrateConnToRequest) MarshalTo ¶ added in v1.1.2
func (m *MigrateConnToRequest) MarshalTo(dAtA []byte) (int, error)
func (*MigrateConnToRequest) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *MigrateConnToRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrateConnToRequest) ProtoMessage ¶ added in v1.1.2
func (*MigrateConnToRequest) ProtoMessage()
func (*MigrateConnToRequest) Reset ¶ added in v1.1.2
func (m *MigrateConnToRequest) Reset()
func (*MigrateConnToRequest) Size ¶ added in v1.1.2
func (m *MigrateConnToRequest) Size() (n int)
func (*MigrateConnToRequest) String ¶ added in v1.1.2
func (m *MigrateConnToRequest) String() string
func (*MigrateConnToRequest) Unmarshal ¶ added in v1.1.2
func (m *MigrateConnToRequest) Unmarshal(dAtA []byte) error
func (*MigrateConnToRequest) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *MigrateConnToRequest) XXX_DiscardUnknown()
func (*MigrateConnToRequest) XXX_Marshal ¶ added in v1.1.2
func (m *MigrateConnToRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrateConnToRequest) XXX_Merge ¶ added in v1.1.2
func (m *MigrateConnToRequest) XXX_Merge(src proto.Message)
func (*MigrateConnToRequest) XXX_Size ¶ added in v1.1.2
func (m *MigrateConnToRequest) XXX_Size() int
func (*MigrateConnToRequest) XXX_Unmarshal ¶ added in v1.1.2
func (m *MigrateConnToRequest) XXX_Unmarshal(b []byte) error
type MigrateConnToResponse ¶ added in v1.1.2
type MigrateConnToResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MigrateConnToResponse) Descriptor ¶ added in v1.1.2
func (*MigrateConnToResponse) Descriptor() ([]byte, []int)
func (*MigrateConnToResponse) GetSuccess ¶ added in v1.1.2
func (m *MigrateConnToResponse) GetSuccess() bool
func (*MigrateConnToResponse) Marshal ¶ added in v1.1.2
func (m *MigrateConnToResponse) Marshal() (dAtA []byte, err error)
func (*MigrateConnToResponse) MarshalTo ¶ added in v1.1.2
func (m *MigrateConnToResponse) MarshalTo(dAtA []byte) (int, error)
func (*MigrateConnToResponse) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *MigrateConnToResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrateConnToResponse) ProtoMessage ¶ added in v1.1.2
func (*MigrateConnToResponse) ProtoMessage()
func (*MigrateConnToResponse) Reset ¶ added in v1.1.2
func (m *MigrateConnToResponse) Reset()
func (*MigrateConnToResponse) Size ¶ added in v1.1.2
func (m *MigrateConnToResponse) Size() (n int)
func (*MigrateConnToResponse) String ¶ added in v1.1.2
func (m *MigrateConnToResponse) String() string
func (*MigrateConnToResponse) Unmarshal ¶ added in v1.1.2
func (m *MigrateConnToResponse) Unmarshal(dAtA []byte) error
func (*MigrateConnToResponse) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *MigrateConnToResponse) XXX_DiscardUnknown()
func (*MigrateConnToResponse) XXX_Marshal ¶ added in v1.1.2
func (m *MigrateConnToResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrateConnToResponse) XXX_Merge ¶ added in v1.1.2
func (m *MigrateConnToResponse) XXX_Merge(src proto.Message)
func (*MigrateConnToResponse) XXX_Size ¶ added in v1.1.2
func (m *MigrateConnToResponse) XXX_Size() int
func (*MigrateConnToResponse) XXX_Unmarshal ¶ added in v1.1.2
func (m *MigrateConnToResponse) XXX_Unmarshal(b []byte) error
type PrepareStmt ¶ added in v1.1.2
type PrepareStmt struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` SQL string `protobuf:"bytes,2,opt,name=SQL,proto3" json:"SQL,omitempty"` ParamTypes []byte `protobuf:"bytes,3,opt,name=ParamTypes,proto3" json:"ParamTypes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PrepareStmt) Descriptor ¶ added in v1.1.2
func (*PrepareStmt) Descriptor() ([]byte, []int)
func (*PrepareStmt) GetName ¶ added in v1.1.2
func (m *PrepareStmt) GetName() string
func (*PrepareStmt) GetParamTypes ¶ added in v1.1.2
func (m *PrepareStmt) GetParamTypes() []byte
func (*PrepareStmt) GetSQL ¶ added in v1.1.2
func (m *PrepareStmt) GetSQL() string
func (*PrepareStmt) Marshal ¶ added in v1.1.2
func (m *PrepareStmt) Marshal() (dAtA []byte, err error)
func (*PrepareStmt) MarshalTo ¶ added in v1.1.2
func (m *PrepareStmt) MarshalTo(dAtA []byte) (int, error)
func (*PrepareStmt) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *PrepareStmt) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrepareStmt) ProtoMessage ¶ added in v1.1.2
func (*PrepareStmt) ProtoMessage()
func (*PrepareStmt) Reset ¶ added in v1.1.2
func (m *PrepareStmt) Reset()
func (*PrepareStmt) Size ¶ added in v1.1.2
func (m *PrepareStmt) Size() (n int)
func (*PrepareStmt) String ¶ added in v1.1.2
func (m *PrepareStmt) String() string
func (*PrepareStmt) Unmarshal ¶ added in v1.1.2
func (m *PrepareStmt) Unmarshal(dAtA []byte) error
func (*PrepareStmt) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *PrepareStmt) XXX_DiscardUnknown()
func (*PrepareStmt) XXX_Marshal ¶ added in v1.1.2
func (m *PrepareStmt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrepareStmt) XXX_Merge ¶ added in v1.1.2
func (m *PrepareStmt) XXX_Merge(src proto.Message)
func (*PrepareStmt) XXX_Size ¶ added in v1.1.2
func (m *PrepareStmt) XXX_Size() int
func (*PrepareStmt) XXX_Unmarshal ¶ added in v1.1.2
func (m *PrepareStmt) XXX_Unmarshal(b []byte) error
type QueryRequest ¶
type QueryRequest struct { // Query is the query statement. Query string `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
QueryRequest is the common query request. It contains the query statement that need to be executed on the specified CN node.
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) GetQuery ¶
func (m *QueryRequest) GetQuery() string
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) MarshalToSizedBuffer ¶
func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
func (*QueryRequest) XXX_DiscardUnknown ¶
func (m *QueryRequest) XXX_DiscardUnknown()
func (*QueryRequest) XXX_Marshal ¶
func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryRequest) XXX_Merge ¶
func (m *QueryRequest) XXX_Merge(src proto.Message)
func (*QueryRequest) XXX_Size ¶
func (m *QueryRequest) XXX_Size() int
func (*QueryRequest) XXX_Unmarshal ¶
func (m *QueryRequest) XXX_Unmarshal(b []byte) error
type RemoveRemoteLockTableRequest ¶ added in v1.1.1
type RemoveRemoteLockTableRequest struct { TableID uint64 `protobuf:"varint,1,opt,name=TableID,proto3" json:"TableID,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=Version,proto3" json:"Version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoveRemoteLockTableRequest) Descriptor ¶ added in v1.1.1
func (*RemoveRemoteLockTableRequest) Descriptor() ([]byte, []int)
func (*RemoveRemoteLockTableRequest) GetTableID ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) GetTableID() uint64
func (*RemoveRemoteLockTableRequest) GetVersion ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) GetVersion() uint64
func (*RemoveRemoteLockTableRequest) Marshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) Marshal() (dAtA []byte, err error)
func (*RemoveRemoteLockTableRequest) MarshalTo ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) MarshalTo(dAtA []byte) (int, error)
func (*RemoveRemoteLockTableRequest) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RemoveRemoteLockTableRequest) ProtoMessage ¶ added in v1.1.1
func (*RemoveRemoteLockTableRequest) ProtoMessage()
func (*RemoveRemoteLockTableRequest) Reset ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) Reset()
func (*RemoveRemoteLockTableRequest) Size ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) Size() (n int)
func (*RemoveRemoteLockTableRequest) String ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) String() string
func (*RemoveRemoteLockTableRequest) Unmarshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) Unmarshal(dAtA []byte) error
func (*RemoveRemoteLockTableRequest) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) XXX_DiscardUnknown()
func (*RemoveRemoteLockTableRequest) XXX_Marshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveRemoteLockTableRequest) XXX_Merge ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) XXX_Merge(src proto.Message)
func (*RemoveRemoteLockTableRequest) XXX_Size ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) XXX_Size() int
func (*RemoveRemoteLockTableRequest) XXX_Unmarshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableRequest) XXX_Unmarshal(b []byte) error
type RemoveRemoteLockTableResponse ¶ added in v1.1.1
type RemoveRemoteLockTableResponse struct { Count int32 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoveRemoteLockTableResponse) Descriptor ¶ added in v1.1.1
func (*RemoveRemoteLockTableResponse) Descriptor() ([]byte, []int)
func (*RemoveRemoteLockTableResponse) GetCount ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) GetCount() int32
func (*RemoveRemoteLockTableResponse) Marshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) Marshal() (dAtA []byte, err error)
func (*RemoveRemoteLockTableResponse) MarshalTo ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) MarshalTo(dAtA []byte) (int, error)
func (*RemoveRemoteLockTableResponse) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RemoveRemoteLockTableResponse) ProtoMessage ¶ added in v1.1.1
func (*RemoveRemoteLockTableResponse) ProtoMessage()
func (*RemoveRemoteLockTableResponse) Reset ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) Reset()
func (*RemoveRemoteLockTableResponse) Size ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) Size() (n int)
func (*RemoveRemoteLockTableResponse) String ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) String() string
func (*RemoveRemoteLockTableResponse) Unmarshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) Unmarshal(dAtA []byte) error
func (*RemoveRemoteLockTableResponse) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) XXX_DiscardUnknown()
func (*RemoveRemoteLockTableResponse) XXX_Marshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveRemoteLockTableResponse) XXX_Merge ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) XXX_Merge(src proto.Message)
func (*RemoveRemoteLockTableResponse) XXX_Size ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) XXX_Size() int
func (*RemoveRemoteLockTableResponse) XXX_Unmarshal ¶ added in v1.1.1
func (m *RemoveRemoteLockTableResponse) XXX_Unmarshal(b []byte) error
type Request ¶
type Request struct { // RequestID is the request ID. RequestID uint64 `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"` // CmdMethod is the type of command. CmdMethod CmdMethod `protobuf:"varint,2,opt,name=CmdMethod,proto3,enum=query.CmdMethod" json:"CmdMethod,omitempty"` // QueryRequest is the common query request. QueryRequest *QueryRequest `protobuf:"bytes,3,opt,name=QueryRequest,proto3" json:"QueryRequest,omitempty"` // ShowProcessListRequest is the request for show process list. ShowProcessListRequest *ShowProcessListRequest `protobuf:"bytes,4,opt,name=ShowProcessListRequest,proto3" json:"ShowProcessListRequest,omitempty"` // AlterAccountRequest is the request for alter account restricted AlterAccountRequest *AlterAccountRequest `protobuf:"bytes,5,opt,name=AlterAccountRequest,proto3" json:"AlterAccountRequest,omitempty"` // KillConnRequest is the request which kills the connections. KillConnRequest *KillConnRequest `protobuf:"bytes,6,opt,name=KillConnRequest,proto3" json:"KillConnRequest,omitempty"` // TraceSpanRequest is the request for transferred span cmd TraceSpanRequest *TraceSpanRequest `protobuf:"bytes,7,opt,name=TraceSpanRequest,proto3" json:"TraceSpanRequest,omitempty"` // GetLockInfoRequest is the request for getting the lock from the cn GetLockInfoRequest *GetLockInfoRequest `protobuf:"bytes,8,opt,name=GetLockInfoRequest,proto3" json:"GetLockInfoRequest,omitempty"` // GetTxnInfoRequest is the request for getting the txn info from the cn GetTxnInfoRequest *GetTxnInfoRequest `protobuf:"bytes,9,opt,name=GetTxnInfoRequest,proto3" json:"GetTxnInfoRequest,omitempty"` // GetCacheInfoRequest is the request for getting the cache info from the cn,tn GetCacheInfoRequest *GetCacheInfoRequest `protobuf:"bytes,10,opt,name=GetCacheInfoRequest,proto3" json:"GetCacheInfoRequest,omitempty"` SycnCommit *SyncCommitRequest `protobuf:"bytes,11,opt,name=SycnCommit,proto3" json:"SycnCommit,omitempty"` GetCommit *GetCommitRequest `protobuf:"bytes,12,opt,name=GetCommit,proto3" json:"GetCommit,omitempty"` RunTask *RunTaskRequest `protobuf:"bytes,16,opt,name=RunTask,proto3" json:"RunTask,omitempty"` RemoveRemoteLockTable *RemoveRemoteLockTableRequest `protobuf:"bytes,17,opt,name=RemoveRemoteLockTable,proto3" json:"RemoveRemoteLockTable,omitempty"` GetLatestBind *GetLatestBindRequest `protobuf:"bytes,18,opt,name=GetLatestBind,proto3" json:"GetLatestBind,omitempty"` // cherry-picked from 1.2, field numbers 19~21 has been used in 1.2 UnsubscribeTable *UnsubscribeTableRequest `protobuf:"bytes,19,opt,name=UnsubscribeTable,proto3" json:"UnsubscribeTable,omitempty"` // GetCacheDataRequest is the request of getting cache data from remote fileservice. GetCacheDataRequest *GetCacheDataRequest `protobuf:"bytes,20,opt,name=GetCacheDataRequest,proto3" json:"GetCacheDataRequest,omitempty"` // GetStatsInfoRequest is the request of getting stats info from remote cn node. GetStatsInfoRequest *GetStatsInfoRequest `protobuf:"bytes,21,opt,name=GetStatsInfoRequest,proto3" json:"GetStatsInfoRequest,omitempty"` GetPipelineInfoRequest *GetPipelineInfoRequest `protobuf:"bytes,22,opt,name=GetPipelineInfoRequest,proto3" json:"GetPipelineInfoRequest,omitempty"` MigrateConnFromRequest *MigrateConnFromRequest `protobuf:"bytes,23,opt,name=MigrateConnFromRequest,proto3" json:"MigrateConnFromRequest,omitempty"` MigrateConnToRequest *MigrateConnToRequest `protobuf:"bytes,24,opt,name=MigrateConnToRequest,proto3" json:"MigrateConnToRequest,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request is the query request.
func (*Request) DebugString ¶
DebugString implements the morpc.Message interface.
func (*Request) Descriptor ¶
func (*Request) GetAlterAccountRequest ¶
func (m *Request) GetAlterAccountRequest() *AlterAccountRequest
func (*Request) GetCmdMethod ¶
func (*Request) GetGetCacheDataRequest ¶ added in v1.1.2
func (m *Request) GetGetCacheDataRequest() *GetCacheDataRequest
func (*Request) GetGetCacheInfoRequest ¶ added in v1.1.0
func (m *Request) GetGetCacheInfoRequest() *GetCacheInfoRequest
func (*Request) GetGetCommit ¶ added in v1.1.0
func (m *Request) GetGetCommit() *GetCommitRequest
func (*Request) GetGetLatestBind ¶ added in v1.1.1
func (m *Request) GetGetLatestBind() *GetLatestBindRequest
func (*Request) GetGetLockInfoRequest ¶ added in v1.1.0
func (m *Request) GetGetLockInfoRequest() *GetLockInfoRequest
func (*Request) GetGetPipelineInfoRequest ¶ added in v1.1.2
func (m *Request) GetGetPipelineInfoRequest() *GetPipelineInfoRequest
func (*Request) GetGetStatsInfoRequest ¶ added in v1.1.2
func (m *Request) GetGetStatsInfoRequest() *GetStatsInfoRequest
func (*Request) GetGetTxnInfoRequest ¶ added in v1.1.0
func (m *Request) GetGetTxnInfoRequest() *GetTxnInfoRequest
func (*Request) GetKillConnRequest ¶
func (m *Request) GetKillConnRequest() *KillConnRequest
func (*Request) GetMigrateConnFromRequest ¶ added in v1.1.2
func (m *Request) GetMigrateConnFromRequest() *MigrateConnFromRequest
func (*Request) GetMigrateConnToRequest ¶ added in v1.1.2
func (m *Request) GetMigrateConnToRequest() *MigrateConnToRequest
func (*Request) GetQueryRequest ¶
func (m *Request) GetQueryRequest() *QueryRequest
func (*Request) GetRemoveRemoteLockTable ¶ added in v1.1.1
func (m *Request) GetRemoveRemoteLockTable() *RemoveRemoteLockTableRequest
func (*Request) GetRequestID ¶
func (*Request) GetRunTask ¶ added in v1.1.1
func (m *Request) GetRunTask() *RunTaskRequest
func (*Request) GetShowProcessListRequest ¶
func (m *Request) GetShowProcessListRequest() *ShowProcessListRequest
func (*Request) GetSycnCommit ¶ added in v1.1.0
func (m *Request) GetSycnCommit() *SyncCommitRequest
func (*Request) GetTraceSpanRequest ¶
func (m *Request) GetTraceSpanRequest() *TraceSpanRequest
func (*Request) GetUnsubscribeTable ¶ added in v1.1.2
func (m *Request) GetUnsubscribeTable() *UnsubscribeTableRequest
func (*Request) MarshalToSizedBuffer ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) UnwrapError ¶
UnwrapError implements the morpc.MethodBasedMessage interface.
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type RequestCacheKey ¶ added in v1.1.2
type RequestCacheKey struct { Index int32 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"` CacheKey *CacheKey `protobuf:"bytes,2,opt,name=CacheKey,proto3" json:"CacheKey,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RequestCacheKey) Descriptor ¶ added in v1.1.2
func (*RequestCacheKey) Descriptor() ([]byte, []int)
func (*RequestCacheKey) GetCacheKey ¶ added in v1.1.2
func (m *RequestCacheKey) GetCacheKey() *CacheKey
func (*RequestCacheKey) GetIndex ¶ added in v1.1.2
func (m *RequestCacheKey) GetIndex() int32
func (*RequestCacheKey) Marshal ¶ added in v1.1.2
func (m *RequestCacheKey) Marshal() (dAtA []byte, err error)
func (*RequestCacheKey) MarshalTo ¶ added in v1.1.2
func (m *RequestCacheKey) MarshalTo(dAtA []byte) (int, error)
func (*RequestCacheKey) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *RequestCacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequestCacheKey) ProtoMessage ¶ added in v1.1.2
func (*RequestCacheKey) ProtoMessage()
func (*RequestCacheKey) Reset ¶ added in v1.1.2
func (m *RequestCacheKey) Reset()
func (*RequestCacheKey) Size ¶ added in v1.1.2
func (m *RequestCacheKey) Size() (n int)
func (*RequestCacheKey) String ¶ added in v1.1.2
func (m *RequestCacheKey) String() string
func (*RequestCacheKey) Unmarshal ¶ added in v1.1.2
func (m *RequestCacheKey) Unmarshal(dAtA []byte) error
func (*RequestCacheKey) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *RequestCacheKey) XXX_DiscardUnknown()
func (*RequestCacheKey) XXX_Marshal ¶ added in v1.1.2
func (m *RequestCacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestCacheKey) XXX_Merge ¶ added in v1.1.2
func (m *RequestCacheKey) XXX_Merge(src proto.Message)
func (*RequestCacheKey) XXX_Size ¶ added in v1.1.2
func (m *RequestCacheKey) XXX_Size() int
func (*RequestCacheKey) XXX_Unmarshal ¶ added in v1.1.2
func (m *RequestCacheKey) XXX_Unmarshal(b []byte) error
type Response ¶
type Response struct { // RequestID is the request ID. RequestID uint64 `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"` // CmdMethod is the type of command. CmdMethod CmdMethod `protobuf:"varint,2,opt,name=CmdMethod,proto3,enum=query.CmdMethod" json:"CmdMethod,omitempty"` // Error is used to return moerr. Set Error []byte `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` // ShowProcessListResponse is the response of ShowProcessListRequest. ShowProcessListResponse *ShowProcessListResponse `protobuf:"bytes,4,opt,name=ShowProcessListResponse,proto3" json:"ShowProcessListResponse,omitempty"` // AlterAccountResponse is the response of AlterAccount. AlterAccountResponse *AlterAccountResponse `protobuf:"bytes,5,opt,name=AlterAccountResponse,proto3" json:"AlterAccountResponse,omitempty"` // KillConnResponse is the response of KillConnRequest. KillConnResponse *KillConnResponse `protobuf:"bytes,6,opt,name=KillConnResponse,proto3" json:"KillConnResponse,omitempty"` // TraceSpanResponse is the response of TraceSpanRequest TraceSpanResponse *TraceSpanResponse `protobuf:"bytes,7,opt,name=TraceSpanResponse,proto3" json:"TraceSpanResponse,omitempty"` // GetLockInfoResponse is the response of GetLockInfo GetLockInfoResponse *GetLockInfoResponse `protobuf:"bytes,8,opt,name=GetLockInfoResponse,proto3" json:"GetLockInfoResponse,omitempty"` // GetTxnInfoResponse is the response to GetTxnInfo GetTxnInfoResponse *GetTxnInfoResponse `protobuf:"bytes,9,opt,name=GetTxnInfoResponse,proto3" json:"GetTxnInfoResponse,omitempty"` // GetCacheInfoResponse is the response to GetCacheInfo GetCacheInfoResponse *GetCacheInfoResponse `protobuf:"bytes,10,opt,name=GetCacheInfoResponse,proto3" json:"GetCacheInfoResponse,omitempty"` SyncCommit *SyncCommitResponse `protobuf:"bytes,11,opt,name=SyncCommit,proto3" json:"SyncCommit,omitempty"` GetCommit *GetCommitResponse `protobuf:"bytes,12,opt,name=GetCommit,proto3" json:"GetCommit,omitempty"` RunTask *RunTaskResponse `protobuf:"bytes,16,opt,name=RunTask,proto3" json:"RunTask,omitempty"` RemoveRemoteLockTable *RemoveRemoteLockTableResponse `protobuf:"bytes,17,opt,name=RemoveRemoteLockTable,proto3" json:"RemoveRemoteLockTable,omitempty"` GetLatestBind *GetLatestBindResponse `protobuf:"bytes,18,opt,name=GetLatestBind,proto3" json:"GetLatestBind,omitempty"` // cherry-picked from 1.2, field numbers 19~21 has been used in 1.2 UnsubscribeTable *UnsubscribeTableResponse `protobuf:"bytes,19,opt,name=UnsubscribeTable,proto3" json:"UnsubscribeTable,omitempty"` // GetCacheDataResponse is the response of GetCacheDataRequest. GetCacheDataResponse *GetCacheDataResponse `protobuf:"bytes,20,opt,name=GetCacheDataResponse,proto3" json:"GetCacheDataResponse,omitempty"` // GetStatsInfoResponse is the response of GetStatsInfoRequest. GetStatsInfoResponse *GetStatsInfoResponse `protobuf:"bytes,21,opt,name=GetStatsInfoResponse,proto3" json:"GetStatsInfoResponse,omitempty"` GetPipelineInfoResponse *GetPipelineInfoResponse `protobuf:"bytes,22,opt,name=GetPipelineInfoResponse,proto3" json:"GetPipelineInfoResponse,omitempty"` MigrateConnFromResponse *MigrateConnFromResponse `protobuf:"bytes,23,opt,name=MigrateConnFromResponse,proto3" json:"MigrateConnFromResponse,omitempty"` MigrateConnToResponse *MigrateConnToResponse `protobuf:"bytes,24,opt,name=MigrateConnToResponse,proto3" json:"MigrateConnToResponse,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response is the response to query request.
func (*Response) DebugString ¶
DebugString implements the morpc.Message interface.
func (*Response) Descriptor ¶
func (*Response) GetAlterAccountResponse ¶
func (m *Response) GetAlterAccountResponse() *AlterAccountResponse
func (*Response) GetCmdMethod ¶
func (*Response) GetGetCacheDataResponse ¶ added in v1.1.2
func (m *Response) GetGetCacheDataResponse() *GetCacheDataResponse
func (*Response) GetGetCacheInfoResponse ¶ added in v1.1.0
func (m *Response) GetGetCacheInfoResponse() *GetCacheInfoResponse
func (*Response) GetGetCommit ¶ added in v1.1.0
func (m *Response) GetGetCommit() *GetCommitResponse
func (*Response) GetGetLatestBind ¶ added in v1.1.1
func (m *Response) GetGetLatestBind() *GetLatestBindResponse
func (*Response) GetGetLockInfoResponse ¶ added in v1.1.0
func (m *Response) GetGetLockInfoResponse() *GetLockInfoResponse
func (*Response) GetGetPipelineInfoResponse ¶ added in v1.1.2
func (m *Response) GetGetPipelineInfoResponse() *GetPipelineInfoResponse
func (*Response) GetGetStatsInfoResponse ¶ added in v1.1.2
func (m *Response) GetGetStatsInfoResponse() *GetStatsInfoResponse
func (*Response) GetGetTxnInfoResponse ¶ added in v1.1.0
func (m *Response) GetGetTxnInfoResponse() *GetTxnInfoResponse
func (*Response) GetKillConnResponse ¶
func (m *Response) GetKillConnResponse() *KillConnResponse
func (*Response) GetMigrateConnFromResponse ¶ added in v1.1.2
func (m *Response) GetMigrateConnFromResponse() *MigrateConnFromResponse
func (*Response) GetMigrateConnToResponse ¶ added in v1.1.2
func (m *Response) GetMigrateConnToResponse() *MigrateConnToResponse
func (*Response) GetRemoveRemoteLockTable ¶ added in v1.1.1
func (m *Response) GetRemoveRemoteLockTable() *RemoveRemoteLockTableResponse
func (*Response) GetRequestID ¶
func (*Response) GetRunTask ¶ added in v1.1.1
func (m *Response) GetRunTask() *RunTaskResponse
func (*Response) GetShowProcessListResponse ¶
func (m *Response) GetShowProcessListResponse() *ShowProcessListResponse
func (*Response) GetSyncCommit ¶ added in v1.1.0
func (m *Response) GetSyncCommit() *SyncCommitResponse
func (*Response) GetTraceSpanResponse ¶
func (m *Response) GetTraceSpanResponse() *TraceSpanResponse
func (*Response) GetUnsubscribeTable ¶ added in v1.1.2
func (m *Response) GetUnsubscribeTable() *UnsubscribeTableResponse
func (*Response) MarshalToSizedBuffer ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) UnwrapError ¶
UnwrapError implements the morpc.MethodBasedMessage interface.
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_Unmarshal ¶
type ResponseCacheData ¶ added in v1.1.2
type ResponseCacheData struct { Index int32 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"` Hit bool `protobuf:"varint,2,opt,name=Hit,proto3" json:"Hit,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ResponseCacheData is the response of cached data.
func (*ResponseCacheData) Descriptor ¶ added in v1.1.2
func (*ResponseCacheData) Descriptor() ([]byte, []int)
func (*ResponseCacheData) GetData ¶ added in v1.1.2
func (m *ResponseCacheData) GetData() []byte
func (*ResponseCacheData) GetHit ¶ added in v1.1.2
func (m *ResponseCacheData) GetHit() bool
func (*ResponseCacheData) GetIndex ¶ added in v1.1.2
func (m *ResponseCacheData) GetIndex() int32
func (*ResponseCacheData) Marshal ¶ added in v1.1.2
func (m *ResponseCacheData) Marshal() (dAtA []byte, err error)
func (*ResponseCacheData) MarshalTo ¶ added in v1.1.2
func (m *ResponseCacheData) MarshalTo(dAtA []byte) (int, error)
func (*ResponseCacheData) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *ResponseCacheData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResponseCacheData) ProtoMessage ¶ added in v1.1.2
func (*ResponseCacheData) ProtoMessage()
func (*ResponseCacheData) Reset ¶ added in v1.1.2
func (m *ResponseCacheData) Reset()
func (*ResponseCacheData) Size ¶ added in v1.1.2
func (m *ResponseCacheData) Size() (n int)
func (*ResponseCacheData) String ¶ added in v1.1.2
func (m *ResponseCacheData) String() string
func (*ResponseCacheData) Unmarshal ¶ added in v1.1.2
func (m *ResponseCacheData) Unmarshal(dAtA []byte) error
func (*ResponseCacheData) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *ResponseCacheData) XXX_DiscardUnknown()
func (*ResponseCacheData) XXX_Marshal ¶ added in v1.1.2
func (m *ResponseCacheData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseCacheData) XXX_Merge ¶ added in v1.1.2
func (m *ResponseCacheData) XXX_Merge(src proto.Message)
func (*ResponseCacheData) XXX_Size ¶ added in v1.1.2
func (m *ResponseCacheData) XXX_Size() int
func (*ResponseCacheData) XXX_Unmarshal ¶ added in v1.1.2
func (m *ResponseCacheData) XXX_Unmarshal(b []byte) error
type RunTaskRequest ¶ added in v1.1.1
type RunTaskRequest struct { TaskCode int32 `protobuf:"varint,1,opt,name=TaskCode,proto3" json:"TaskCode,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunTaskRequest) Descriptor ¶ added in v1.1.1
func (*RunTaskRequest) Descriptor() ([]byte, []int)
func (*RunTaskRequest) GetTaskCode ¶ added in v1.1.1
func (m *RunTaskRequest) GetTaskCode() int32
func (*RunTaskRequest) Marshal ¶ added in v1.1.1
func (m *RunTaskRequest) Marshal() (dAtA []byte, err error)
func (*RunTaskRequest) MarshalTo ¶ added in v1.1.1
func (m *RunTaskRequest) MarshalTo(dAtA []byte) (int, error)
func (*RunTaskRequest) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *RunTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RunTaskRequest) ProtoMessage ¶ added in v1.1.1
func (*RunTaskRequest) ProtoMessage()
func (*RunTaskRequest) Reset ¶ added in v1.1.1
func (m *RunTaskRequest) Reset()
func (*RunTaskRequest) Size ¶ added in v1.1.1
func (m *RunTaskRequest) Size() (n int)
func (*RunTaskRequest) String ¶ added in v1.1.1
func (m *RunTaskRequest) String() string
func (*RunTaskRequest) Unmarshal ¶ added in v1.1.1
func (m *RunTaskRequest) Unmarshal(dAtA []byte) error
func (*RunTaskRequest) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *RunTaskRequest) XXX_DiscardUnknown()
func (*RunTaskRequest) XXX_Marshal ¶ added in v1.1.1
func (m *RunTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunTaskRequest) XXX_Merge ¶ added in v1.1.1
func (m *RunTaskRequest) XXX_Merge(src proto.Message)
func (*RunTaskRequest) XXX_Size ¶ added in v1.1.1
func (m *RunTaskRequest) XXX_Size() int
func (*RunTaskRequest) XXX_Unmarshal ¶ added in v1.1.1
func (m *RunTaskRequest) XXX_Unmarshal(b []byte) error
type RunTaskResponse ¶ added in v1.1.1
type RunTaskResponse struct { Result string `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunTaskResponse) Descriptor ¶ added in v1.1.1
func (*RunTaskResponse) Descriptor() ([]byte, []int)
func (*RunTaskResponse) GetResult ¶ added in v1.1.1
func (m *RunTaskResponse) GetResult() string
func (*RunTaskResponse) Marshal ¶ added in v1.1.1
func (m *RunTaskResponse) Marshal() (dAtA []byte, err error)
func (*RunTaskResponse) MarshalTo ¶ added in v1.1.1
func (m *RunTaskResponse) MarshalTo(dAtA []byte) (int, error)
func (*RunTaskResponse) MarshalToSizedBuffer ¶ added in v1.1.1
func (m *RunTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RunTaskResponse) ProtoMessage ¶ added in v1.1.1
func (*RunTaskResponse) ProtoMessage()
func (*RunTaskResponse) Reset ¶ added in v1.1.1
func (m *RunTaskResponse) Reset()
func (*RunTaskResponse) Size ¶ added in v1.1.1
func (m *RunTaskResponse) Size() (n int)
func (*RunTaskResponse) String ¶ added in v1.1.1
func (m *RunTaskResponse) String() string
func (*RunTaskResponse) Unmarshal ¶ added in v1.1.1
func (m *RunTaskResponse) Unmarshal(dAtA []byte) error
func (*RunTaskResponse) XXX_DiscardUnknown ¶ added in v1.1.1
func (m *RunTaskResponse) XXX_DiscardUnknown()
func (*RunTaskResponse) XXX_Marshal ¶ added in v1.1.1
func (m *RunTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunTaskResponse) XXX_Merge ¶ added in v1.1.1
func (m *RunTaskResponse) XXX_Merge(src proto.Message)
func (*RunTaskResponse) XXX_Size ¶ added in v1.1.1
func (m *RunTaskResponse) XXX_Size() int
func (*RunTaskResponse) XXX_Unmarshal ¶ added in v1.1.1
func (m *RunTaskResponse) XXX_Unmarshal(b []byte) error
type ShowProcessListRequest ¶
type ShowProcessListRequest struct { // Tenant is the tenant which the processes belong to. Tenant string `protobuf:"bytes,1,opt,name=Tenant,proto3" json:"Tenant,omitempty"` // SysTenet is true if the tenant is a system tenant. SysTenant bool `protobuf:"varint,2,opt,name=SysTenant,proto3" json:"SysTenant,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShowProcessListRequest is the "show process list" query request.
func (*ShowProcessListRequest) Descriptor ¶
func (*ShowProcessListRequest) Descriptor() ([]byte, []int)
func (*ShowProcessListRequest) GetSysTenant ¶
func (m *ShowProcessListRequest) GetSysTenant() bool
func (*ShowProcessListRequest) GetTenant ¶
func (m *ShowProcessListRequest) GetTenant() string
func (*ShowProcessListRequest) Marshal ¶
func (m *ShowProcessListRequest) Marshal() (dAtA []byte, err error)
func (*ShowProcessListRequest) MarshalTo ¶
func (m *ShowProcessListRequest) MarshalTo(dAtA []byte) (int, error)
func (*ShowProcessListRequest) MarshalToSizedBuffer ¶
func (m *ShowProcessListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShowProcessListRequest) ProtoMessage ¶
func (*ShowProcessListRequest) ProtoMessage()
func (*ShowProcessListRequest) Reset ¶
func (m *ShowProcessListRequest) Reset()
func (*ShowProcessListRequest) Size ¶
func (m *ShowProcessListRequest) Size() (n int)
func (*ShowProcessListRequest) String ¶
func (m *ShowProcessListRequest) String() string
func (*ShowProcessListRequest) Unmarshal ¶
func (m *ShowProcessListRequest) Unmarshal(dAtA []byte) error
func (*ShowProcessListRequest) XXX_DiscardUnknown ¶
func (m *ShowProcessListRequest) XXX_DiscardUnknown()
func (*ShowProcessListRequest) XXX_Marshal ¶
func (m *ShowProcessListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowProcessListRequest) XXX_Merge ¶
func (m *ShowProcessListRequest) XXX_Merge(src proto.Message)
func (*ShowProcessListRequest) XXX_Size ¶
func (m *ShowProcessListRequest) XXX_Size() int
func (*ShowProcessListRequest) XXX_Unmarshal ¶
func (m *ShowProcessListRequest) XXX_Unmarshal(b []byte) error
type ShowProcessListResponse ¶
type ShowProcessListResponse struct { Sessions []*status.Session `protobuf:"bytes,1,rep,name=Sessions,proto3" json:"Sessions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShowProcessListResponse is the response of command ShowProcessList.
func (*ShowProcessListResponse) Descriptor ¶
func (*ShowProcessListResponse) Descriptor() ([]byte, []int)
func (*ShowProcessListResponse) GetSessions ¶
func (m *ShowProcessListResponse) GetSessions() []*status.Session
func (*ShowProcessListResponse) Marshal ¶
func (m *ShowProcessListResponse) Marshal() (dAtA []byte, err error)
func (*ShowProcessListResponse) MarshalTo ¶
func (m *ShowProcessListResponse) MarshalTo(dAtA []byte) (int, error)
func (*ShowProcessListResponse) MarshalToSizedBuffer ¶
func (m *ShowProcessListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShowProcessListResponse) ProtoMessage ¶
func (*ShowProcessListResponse) ProtoMessage()
func (*ShowProcessListResponse) Reset ¶
func (m *ShowProcessListResponse) Reset()
func (*ShowProcessListResponse) Size ¶
func (m *ShowProcessListResponse) Size() (n int)
func (*ShowProcessListResponse) String ¶
func (m *ShowProcessListResponse) String() string
func (*ShowProcessListResponse) Unmarshal ¶
func (m *ShowProcessListResponse) Unmarshal(dAtA []byte) error
func (*ShowProcessListResponse) XXX_DiscardUnknown ¶
func (m *ShowProcessListResponse) XXX_DiscardUnknown()
func (*ShowProcessListResponse) XXX_Marshal ¶
func (m *ShowProcessListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowProcessListResponse) XXX_Merge ¶
func (m *ShowProcessListResponse) XXX_Merge(src proto.Message)
func (*ShowProcessListResponse) XXX_Size ¶
func (m *ShowProcessListResponse) XXX_Size() int
func (*ShowProcessListResponse) XXX_Unmarshal ¶
func (m *ShowProcessListResponse) XXX_Unmarshal(b []byte) error
type SyncCommitRequest ¶ added in v1.1.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 v1.1.0
func (*SyncCommitRequest) Descriptor() ([]byte, []int)
func (*SyncCommitRequest) GetLatestCommitTS ¶ added in v1.1.0
func (m *SyncCommitRequest) GetLatestCommitTS() timestamp.Timestamp
func (*SyncCommitRequest) Marshal ¶ added in v1.1.0
func (m *SyncCommitRequest) Marshal() (dAtA []byte, err error)
func (*SyncCommitRequest) MarshalTo ¶ added in v1.1.0
func (m *SyncCommitRequest) MarshalTo(dAtA []byte) (int, error)
func (*SyncCommitRequest) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *SyncCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncCommitRequest) ProtoMessage ¶ added in v1.1.0
func (*SyncCommitRequest) ProtoMessage()
func (*SyncCommitRequest) Reset ¶ added in v1.1.0
func (m *SyncCommitRequest) Reset()
func (*SyncCommitRequest) Size ¶ added in v1.1.0
func (m *SyncCommitRequest) Size() (n int)
func (*SyncCommitRequest) String ¶ added in v1.1.0
func (m *SyncCommitRequest) String() string
func (*SyncCommitRequest) Unmarshal ¶ added in v1.1.0
func (m *SyncCommitRequest) Unmarshal(dAtA []byte) error
func (*SyncCommitRequest) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *SyncCommitRequest) XXX_DiscardUnknown()
func (*SyncCommitRequest) XXX_Marshal ¶ added in v1.1.0
func (m *SyncCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncCommitRequest) XXX_Merge ¶ added in v1.1.0
func (m *SyncCommitRequest) XXX_Merge(src proto.Message)
func (*SyncCommitRequest) XXX_Size ¶ added in v1.1.0
func (m *SyncCommitRequest) XXX_Size() int
func (*SyncCommitRequest) XXX_Unmarshal ¶ added in v1.1.0
func (m *SyncCommitRequest) XXX_Unmarshal(b []byte) error
type SyncCommitResponse ¶ added in v1.1.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 v1.1.0
func (*SyncCommitResponse) Descriptor() ([]byte, []int)
func (*SyncCommitResponse) GetCurrentCommitTS ¶ added in v1.1.0
func (m *SyncCommitResponse) GetCurrentCommitTS() timestamp.Timestamp
func (*SyncCommitResponse) Marshal ¶ added in v1.1.0
func (m *SyncCommitResponse) Marshal() (dAtA []byte, err error)
func (*SyncCommitResponse) MarshalTo ¶ added in v1.1.0
func (m *SyncCommitResponse) MarshalTo(dAtA []byte) (int, error)
func (*SyncCommitResponse) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *SyncCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncCommitResponse) ProtoMessage ¶ added in v1.1.0
func (*SyncCommitResponse) ProtoMessage()
func (*SyncCommitResponse) Reset ¶ added in v1.1.0
func (m *SyncCommitResponse) Reset()
func (*SyncCommitResponse) Size ¶ added in v1.1.0
func (m *SyncCommitResponse) Size() (n int)
func (*SyncCommitResponse) String ¶ added in v1.1.0
func (m *SyncCommitResponse) String() string
func (*SyncCommitResponse) Unmarshal ¶ added in v1.1.0
func (m *SyncCommitResponse) Unmarshal(dAtA []byte) error
func (*SyncCommitResponse) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *SyncCommitResponse) XXX_DiscardUnknown()
func (*SyncCommitResponse) XXX_Marshal ¶ added in v1.1.0
func (m *SyncCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncCommitResponse) XXX_Merge ¶ added in v1.1.0
func (m *SyncCommitResponse) XXX_Merge(src proto.Message)
func (*SyncCommitResponse) XXX_Size ¶ added in v1.1.0
func (m *SyncCommitResponse) XXX_Size() int
func (*SyncCommitResponse) XXX_Unmarshal ¶ added in v1.1.0
func (m *SyncCommitResponse) XXX_Unmarshal(b []byte) error
type TraceSpanRequest ¶
type TraceSpanRequest struct { Cmd string `protobuf:"bytes,1,opt,name=Cmd,proto3" json:"Cmd,omitempty"` Spans string `protobuf:"bytes,2,opt,name=Spans,proto3" json:"Spans,omitempty"` Threshold int64 `protobuf:"varint,3,opt,name=Threshold,proto3" json:"Threshold,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TraceSpanRequest) Descriptor ¶
func (*TraceSpanRequest) Descriptor() ([]byte, []int)
func (*TraceSpanRequest) GetCmd ¶
func (m *TraceSpanRequest) GetCmd() string
func (*TraceSpanRequest) GetSpans ¶
func (m *TraceSpanRequest) GetSpans() string
func (*TraceSpanRequest) GetThreshold ¶
func (m *TraceSpanRequest) GetThreshold() int64
func (*TraceSpanRequest) Marshal ¶
func (m *TraceSpanRequest) Marshal() (dAtA []byte, err error)
func (*TraceSpanRequest) MarshalToSizedBuffer ¶
func (m *TraceSpanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TraceSpanRequest) ProtoMessage ¶
func (*TraceSpanRequest) ProtoMessage()
func (*TraceSpanRequest) Reset ¶
func (m *TraceSpanRequest) Reset()
func (*TraceSpanRequest) Size ¶
func (m *TraceSpanRequest) Size() (n int)
func (*TraceSpanRequest) String ¶
func (m *TraceSpanRequest) String() string
func (*TraceSpanRequest) Unmarshal ¶
func (m *TraceSpanRequest) Unmarshal(dAtA []byte) error
func (*TraceSpanRequest) XXX_DiscardUnknown ¶
func (m *TraceSpanRequest) XXX_DiscardUnknown()
func (*TraceSpanRequest) XXX_Marshal ¶
func (m *TraceSpanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TraceSpanRequest) XXX_Merge ¶
func (m *TraceSpanRequest) XXX_Merge(src proto.Message)
func (*TraceSpanRequest) XXX_Size ¶
func (m *TraceSpanRequest) XXX_Size() int
func (*TraceSpanRequest) XXX_Unmarshal ¶
func (m *TraceSpanRequest) XXX_Unmarshal(b []byte) error
type TraceSpanResponse ¶
type TraceSpanResponse struct { Resp string `protobuf:"bytes,1,opt,name=Resp,proto3" json:"Resp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TraceSpanResponse) Descriptor ¶
func (*TraceSpanResponse) Descriptor() ([]byte, []int)
func (*TraceSpanResponse) GetResp ¶
func (m *TraceSpanResponse) GetResp() string
func (*TraceSpanResponse) Marshal ¶
func (m *TraceSpanResponse) Marshal() (dAtA []byte, err error)
func (*TraceSpanResponse) MarshalTo ¶
func (m *TraceSpanResponse) MarshalTo(dAtA []byte) (int, error)
func (*TraceSpanResponse) MarshalToSizedBuffer ¶
func (m *TraceSpanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TraceSpanResponse) ProtoMessage ¶
func (*TraceSpanResponse) ProtoMessage()
func (*TraceSpanResponse) Reset ¶
func (m *TraceSpanResponse) Reset()
func (*TraceSpanResponse) Size ¶
func (m *TraceSpanResponse) Size() (n int)
func (*TraceSpanResponse) String ¶
func (m *TraceSpanResponse) String() string
func (*TraceSpanResponse) Unmarshal ¶
func (m *TraceSpanResponse) Unmarshal(dAtA []byte) error
func (*TraceSpanResponse) XXX_DiscardUnknown ¶
func (m *TraceSpanResponse) XXX_DiscardUnknown()
func (*TraceSpanResponse) XXX_Marshal ¶
func (m *TraceSpanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TraceSpanResponse) XXX_Merge ¶
func (m *TraceSpanResponse) XXX_Merge(src proto.Message)
func (*TraceSpanResponse) XXX_Size ¶
func (m *TraceSpanResponse) XXX_Size() int
func (*TraceSpanResponse) XXX_Unmarshal ¶
func (m *TraceSpanResponse) XXX_Unmarshal(b []byte) error
type TxnInfo ¶ added in v1.1.0
type TxnInfo struct { // CreateAt is the create time of the txn CreateAt time.Time `protobuf:"bytes,1,opt,name=CreateAt,proto3,stdtime" json:"CreateAt"` Meta *txn.TxnMeta `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"` // UserTxn denotes it is the user txn or not UserTxn bool `protobuf:"varint,3,opt,name=UserTxn,proto3" json:"UserTxn,omitempty"` // WaitLocks denotes the locks that the txn is waiting on WaitLocks []*TxnLockInfo `protobuf:"bytes,4,rep,name=WaitLocks,proto3" json:"WaitLocks,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TxnInfo) Descriptor ¶ added in v1.1.0
func (*TxnInfo) GetCreateAt ¶ added in v1.1.0
func (*TxnInfo) GetUserTxn ¶ added in v1.1.0
func (*TxnInfo) GetWaitLocks ¶ added in v1.1.0
func (m *TxnInfo) GetWaitLocks() []*TxnLockInfo
func (*TxnInfo) MarshalToSizedBuffer ¶ added in v1.1.0
func (*TxnInfo) ProtoMessage ¶ added in v1.1.0
func (*TxnInfo) ProtoMessage()
func (*TxnInfo) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *TxnInfo) XXX_DiscardUnknown()
func (*TxnInfo) XXX_Marshal ¶ added in v1.1.0
func (*TxnInfo) XXX_Unmarshal ¶ added in v1.1.0
type TxnLockInfo ¶ added in v1.1.0
type TxnLockInfo struct { // TableId is the id of the table TableId uint64 `protobuf:"varint,1,opt,name=TableId,proto3" json:"TableId,omitempty"` // Rows // - point/row lock : all point lock keys // - rang lock : start,end,start,end Rows [][]byte `protobuf:"bytes,2,rep,name=Rows,proto3" json:"Rows,omitempty"` // Options // - type : point or range // - mode : shared or exclusive Options *lock.LockOptions `protobuf:"bytes,3,opt,name=Options,proto3" json:"Options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TxnLockInfo) Descriptor ¶ added in v1.1.0
func (*TxnLockInfo) Descriptor() ([]byte, []int)
func (*TxnLockInfo) GetOptions ¶ added in v1.1.0
func (m *TxnLockInfo) GetOptions() *lock.LockOptions
func (*TxnLockInfo) GetRows ¶ added in v1.1.0
func (m *TxnLockInfo) GetRows() [][]byte
func (*TxnLockInfo) GetTableId ¶ added in v1.1.0
func (m *TxnLockInfo) GetTableId() uint64
func (*TxnLockInfo) Marshal ¶ added in v1.1.0
func (m *TxnLockInfo) Marshal() (dAtA []byte, err error)
func (*TxnLockInfo) MarshalTo ¶ added in v1.1.0
func (m *TxnLockInfo) MarshalTo(dAtA []byte) (int, error)
func (*TxnLockInfo) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *TxnLockInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TxnLockInfo) ProtoMessage ¶ added in v1.1.0
func (*TxnLockInfo) ProtoMessage()
func (*TxnLockInfo) Reset ¶ added in v1.1.0
func (m *TxnLockInfo) Reset()
func (*TxnLockInfo) Size ¶ added in v1.1.0
func (m *TxnLockInfo) Size() (n int)
func (*TxnLockInfo) String ¶ added in v1.1.0
func (m *TxnLockInfo) String() string
func (*TxnLockInfo) Unmarshal ¶ added in v1.1.0
func (m *TxnLockInfo) Unmarshal(dAtA []byte) error
func (*TxnLockInfo) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *TxnLockInfo) XXX_DiscardUnknown()
func (*TxnLockInfo) XXX_Marshal ¶ added in v1.1.0
func (m *TxnLockInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TxnLockInfo) XXX_Merge ¶ added in v1.1.0
func (m *TxnLockInfo) XXX_Merge(src proto.Message)
func (*TxnLockInfo) XXX_Size ¶ added in v1.1.0
func (m *TxnLockInfo) XXX_Size() int
func (*TxnLockInfo) XXX_Unmarshal ¶ added in v1.1.0
func (m *TxnLockInfo) XXX_Unmarshal(b []byte) error
type UnsubscribeTableRequest ¶ added in v1.1.2
type UnsubscribeTableRequest struct { // DatabaseID is the ID of the database. DatabaseID uint64 `protobuf:"varint,1,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"` // TableID is the ID of the table. TableID uint64 `protobuf:"varint,2,opt,name=TableID,proto3" json:"TableID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
UnsubscribeTableRequest is the request that unsubscribe a table from logtail client.
func (*UnsubscribeTableRequest) Descriptor ¶ added in v1.1.2
func (*UnsubscribeTableRequest) Descriptor() ([]byte, []int)
func (*UnsubscribeTableRequest) GetDatabaseID ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) GetDatabaseID() uint64
func (*UnsubscribeTableRequest) GetTableID ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) GetTableID() uint64
func (*UnsubscribeTableRequest) Marshal ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) Marshal() (dAtA []byte, err error)
func (*UnsubscribeTableRequest) MarshalTo ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) MarshalTo(dAtA []byte) (int, error)
func (*UnsubscribeTableRequest) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnsubscribeTableRequest) ProtoMessage ¶ added in v1.1.2
func (*UnsubscribeTableRequest) ProtoMessage()
func (*UnsubscribeTableRequest) Reset ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) Reset()
func (*UnsubscribeTableRequest) Size ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) Size() (n int)
func (*UnsubscribeTableRequest) String ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) String() string
func (*UnsubscribeTableRequest) Unmarshal ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) Unmarshal(dAtA []byte) error
func (*UnsubscribeTableRequest) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) XXX_DiscardUnknown()
func (*UnsubscribeTableRequest) XXX_Marshal ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnsubscribeTableRequest) XXX_Merge ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) XXX_Merge(src proto.Message)
func (*UnsubscribeTableRequest) XXX_Size ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) XXX_Size() int
func (*UnsubscribeTableRequest) XXX_Unmarshal ¶ added in v1.1.2
func (m *UnsubscribeTableRequest) XXX_Unmarshal(b []byte) error
type UnsubscribeTableResponse ¶ added in v1.1.2
type UnsubscribeTableResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
UnsubscribeTableResponse is the response of unsubscribe table request.
func (*UnsubscribeTableResponse) Descriptor ¶ added in v1.1.2
func (*UnsubscribeTableResponse) Descriptor() ([]byte, []int)
func (*UnsubscribeTableResponse) GetSuccess ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) GetSuccess() bool
func (*UnsubscribeTableResponse) Marshal ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) Marshal() (dAtA []byte, err error)
func (*UnsubscribeTableResponse) MarshalTo ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) MarshalTo(dAtA []byte) (int, error)
func (*UnsubscribeTableResponse) MarshalToSizedBuffer ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnsubscribeTableResponse) ProtoMessage ¶ added in v1.1.2
func (*UnsubscribeTableResponse) ProtoMessage()
func (*UnsubscribeTableResponse) Reset ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) Reset()
func (*UnsubscribeTableResponse) Size ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) Size() (n int)
func (*UnsubscribeTableResponse) String ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) String() string
func (*UnsubscribeTableResponse) Unmarshal ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) Unmarshal(dAtA []byte) error
func (*UnsubscribeTableResponse) XXX_DiscardUnknown ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) XXX_DiscardUnknown()
func (*UnsubscribeTableResponse) XXX_Marshal ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnsubscribeTableResponse) XXX_Merge ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) XXX_Merge(src proto.Message)
func (*UnsubscribeTableResponse) XXX_Size ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) XXX_Size() int
func (*UnsubscribeTableResponse) XXX_Unmarshal ¶ added in v1.1.2
func (m *UnsubscribeTableResponse) XXX_Unmarshal(b []byte) error