query

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2024 License: Apache-2.0 Imports: 17 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
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",
}
View Source 
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,
}

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) Descriptor() ([]byte, []int)

func (*CacheInfo) GetCacheType added in v1.1.0 

func (m *CacheInfo) GetCacheType() string

func (*CacheInfo) GetFree added in v1.1.0 

func (m *CacheInfo) GetFree() uint64

func (*CacheInfo) GetHitRatio added in v1.1.0 

func (m *CacheInfo) GetHitRatio() float32

func (*CacheInfo) GetNodeId added in v1.1.0 

func (m *CacheInfo) GetNodeId() string

func (*CacheInfo) GetNodeType added in v1.1.0 

func (m *CacheInfo) GetNodeType() string

func (*CacheInfo) GetUsed added in v1.1.0 

func (m *CacheInfo) GetUsed() uint64

func (*CacheInfo) Marshal added in v1.1.0 

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

func (*CacheInfo) MarshalTo added in v1.1.0 

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

func (*CacheInfo) MarshalToSizedBuffer added in v1.1.0 

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

func (*CacheInfo) ProtoMessage added in v1.1.0 

func (*CacheInfo) ProtoMessage()

func (*CacheInfo) Reset added in v1.1.0 

func (m *CacheInfo) Reset()

func (*CacheInfo) Size added in v1.1.0 

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

func (*CacheInfo) String added in v1.1.0 

func (m *CacheInfo) String() string

func (*CacheInfo) Unmarshal added in v1.1.0 

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

func (*CacheInfo) XXX_DiscardUnknown added in v1.1.0 

func (m *CacheInfo) XXX_DiscardUnknown()

func (*CacheInfo) XXX_Marshal added in v1.1.0 

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

func (*CacheInfo) XXX_Merge added in v1.1.0 

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

func (*CacheInfo) XXX_Size added in v1.1.0 

func (m *CacheInfo) XXX_Size() int

func (*CacheInfo) XXX_Unmarshal added in v1.1.0 

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

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
)

func (CmdMethod) EnumDescriptor 

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

func (CmdMethod) String 

func (x CmdMethod) String() string

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 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) MarshalTo 

func (m *KillConnRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *KillConnResponse) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*LockInfo) GetHolders added in v1.1.0 

func (m *LockInfo) GetHolders() []*lock.WaitTxn

func (*LockInfo) GetIsRangeLock added in v1.1.0 

func (m *LockInfo) GetIsRangeLock() bool

func (*LockInfo) GetKeys added in v1.1.0 

func (m *LockInfo) GetKeys() [][]byte

func (*LockInfo) GetLockMode added in v1.1.0 

func (m *LockInfo) GetLockMode() lock.LockMode

func (*LockInfo) GetTableId added in v1.1.0 

func (m *LockInfo) GetTableId() uint64

func (*LockInfo) GetWaiters added in v1.1.0 

func (m *LockInfo) GetWaiters() []*lock.WaitTxn

func (*LockInfo) Marshal added in v1.1.0 

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

func (*LockInfo) MarshalTo added in v1.1.0 

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

func (*LockInfo) MarshalToSizedBuffer added in v1.1.0 

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

func (*LockInfo) ProtoMessage added in v1.1.0 

func (*LockInfo) ProtoMessage()

func (*LockInfo) Reset added in v1.1.0 

func (m *LockInfo) Reset()

func (*LockInfo) Size added in v1.1.0 

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

func (*LockInfo) String added in v1.1.0 

func (m *LockInfo) String() string

func (*LockInfo) Unmarshal added in v1.1.0 

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

func (*LockInfo) XXX_DiscardUnknown added in v1.1.0 

func (m *LockInfo) XXX_DiscardUnknown()

func (*LockInfo) XXX_Marshal added in v1.1.0 

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

func (*LockInfo) XXX_Merge added in v1.1.0 

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

func (*LockInfo) XXX_Size added in v1.1.0 

func (m *LockInfo) XXX_Size() int

func (*LockInfo) XXX_Unmarshal added in v1.1.0 

func (m *LockInfo) 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) MarshalTo 

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, 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"`
	XXX_NoUnkeyedLiteral  struct{}                      `json:"-"`
	XXX_unrecognized      []byte                        `json:"-"`
	XXX_sizecache         int32                         `json:"-"`
}

Request is the query request.

func (*Request) DebugString 

func (m *Request) DebugString() string

DebugString implements the morpc.Message interface.

func (*Request) Descriptor 

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

func (*Request) GetAlterAccountRequest 

func (m *Request) GetAlterAccountRequest() *AlterAccountRequest

func (*Request) GetCmdMethod 

func (m *Request) GetCmdMethod() CmdMethod

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) GetGetTxnInfoRequest added in v1.1.0 

func (m *Request) GetGetTxnInfoRequest() *GetTxnInfoRequest

func (*Request) GetID 

func (m *Request) GetID() uint64

GetID implements the morpc.Message interface.

func (*Request) GetKillConnRequest 

func (m *Request) GetKillConnRequest() *KillConnRequest

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 (m *Request) GetRequestID() uint64

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) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) Method 

func (m *Request) Method() uint32

Method implements the morpc.MethodBasedMessage interface.

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) SetID 

func (m *Request) SetID(id uint64)

SetID implements the morpc.Message interface.

func (*Request) SetMethod 

func (m *Request) SetMethod(v uint32)

SetMethod implements the morpc.MethodBasedMessage interface.

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) UnwrapError 

func (m *Request) UnwrapError() error

UnwrapError implements the morpc.MethodBasedMessage interface.

func (*Request) WrapError 

func (m *Request) WrapError(err error)

WrapError implements the morpc.MethodBasedMessage interface.

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) 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"`
	XXX_NoUnkeyedLiteral  struct{}                       `json:"-"`
	XXX_unrecognized      []byte                         `json:"-"`
	XXX_sizecache         int32                          `json:"-"`
}

Response is the response to query request.

func (*Response) DebugString 

func (m *Response) DebugString() string

DebugString implements the morpc.Message interface.

func (*Response) Descriptor 

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

func (*Response) GetAlterAccountResponse 

func (m *Response) GetAlterAccountResponse() *AlterAccountResponse

func (*Response) GetCmdMethod 

func (m *Response) GetCmdMethod() CmdMethod

func (*Response) GetError 

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

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) GetGetTxnInfoResponse added in v1.1.0 

func (m *Response) GetGetTxnInfoResponse() *GetTxnInfoResponse

func (*Response) GetID 

func (m *Response) GetID() uint64

GetID implements the morpc.Message interface.

func (*Response) GetKillConnResponse 

func (m *Response) GetKillConnResponse() *KillConnResponse

func (*Response) GetRemoveRemoteLockTable added in v1.1.1 

func (m *Response) GetRemoveRemoteLockTable() *RemoveRemoteLockTableResponse

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

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) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) Method 

func (m *Response) Method() uint32

Method implements the morpc.MethodBasedMessage interface.

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) SetID 

func (m *Response) SetID(id uint64)

SetID implements the morpc.Message interface.

func (*Response) SetMethod 

func (m *Response) SetMethod(v uint32)

SetMethod implements the morpc.MethodBasedMessage interface.

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) UnwrapError 

func (m *Response) UnwrapError() error

UnwrapError implements the morpc.MethodBasedMessage interface.

func (*Response) WrapError 

func (m *Response) WrapError(err error)

WrapError implements the morpc.MethodBasedMessage interface.

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) 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) MarshalTo 

func (m *TraceSpanRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*TxnInfo) GetCreateAt added in v1.1.0 

func (m *TxnInfo) GetCreateAt() time.Time

func (*TxnInfo) GetMeta added in v1.1.0 

func (m *TxnInfo) GetMeta() *txn.TxnMeta

func (*TxnInfo) GetUserTxn added in v1.1.0 

func (m *TxnInfo) GetUserTxn() bool

func (*TxnInfo) GetWaitLocks added in v1.1.0 

func (m *TxnInfo) GetWaitLocks() []*TxnLockInfo

func (*TxnInfo) Marshal added in v1.1.0 

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

func (*TxnInfo) MarshalTo added in v1.1.0 

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

func (*TxnInfo) MarshalToSizedBuffer added in v1.1.0 

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

func (*TxnInfo) ProtoMessage added in v1.1.0 

func (*TxnInfo) ProtoMessage()

func (*TxnInfo) Reset added in v1.1.0 

func (m *TxnInfo) Reset()

func (*TxnInfo) Size added in v1.1.0 

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

func (*TxnInfo) String added in v1.1.0 

func (m *TxnInfo) String() string

func (*TxnInfo) Unmarshal added in v1.1.0 

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

func (*TxnInfo) XXX_DiscardUnknown added in v1.1.0 

func (m *TxnInfo) XXX_DiscardUnknown()

func (*TxnInfo) XXX_Marshal added in v1.1.0 

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

func (*TxnInfo) XXX_Merge added in v1.1.0 

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

func (*TxnInfo) XXX_Size added in v1.1.0 

func (m *TxnInfo) XXX_Size() int

func (*TxnInfo) XXX_Unmarshal added in v1.1.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.