query

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 18 Imported by: 1

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",
	16: "UnsubscribeTable",
	17: "GetCacheData",
	18: "GetStatsInfo",
	19: "GetPipelineInfo",
	20: "MigrateConnFrom",
	21: "MigrateConnTo",
}
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,
	"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) 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 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) Descriptor() ([]byte, []int)

func (*CacheKey) GetOffset added in v1.1.2 

func (m *CacheKey) GetOffset() int64

func (*CacheKey) GetPath added in v1.1.2 

func (m *CacheKey) GetPath() string

func (*CacheKey) GetSz added in v1.1.2 

func (m *CacheKey) GetSz() int64

func (*CacheKey) Marshal added in v1.1.2 

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

func (*CacheKey) MarshalTo added in v1.1.2 

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

func (*CacheKey) MarshalToSizedBuffer added in v1.1.2 

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

func (*CacheKey) ProtoMessage added in v1.1.2 

func (*CacheKey) ProtoMessage()

func (*CacheKey) Reset added in v1.1.2 

func (m *CacheKey) Reset()

func (*CacheKey) Size added in v1.1.2 

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

func (*CacheKey) String added in v1.1.2 

func (m *CacheKey) String() string

func (*CacheKey) Unmarshal added in v1.1.2 

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

func (*CacheKey) XXX_DiscardUnknown added in v1.1.2 

func (m *CacheKey) XXX_DiscardUnknown()

func (*CacheKey) XXX_Marshal added in v1.1.2 

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

func (*CacheKey) XXX_Merge added in v1.1.2 

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

func (*CacheKey) XXX_Size added in v1.1.2 

func (m *CacheKey) XXX_Size() int

func (*CacheKey) XXX_Unmarshal added in v1.1.2 

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

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

func (*CacheKeys) GetKeys added in v1.1.2 

func (m *CacheKeys) GetKeys() []CacheKey

func (*CacheKeys) Marshal added in v1.1.2 

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

func (*CacheKeys) MarshalTo added in v1.1.2 

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

func (*CacheKeys) MarshalToSizedBuffer added in v1.1.2 

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

func (*CacheKeys) ProtoMessage added in v1.1.2 

func (*CacheKeys) ProtoMessage()

func (*CacheKeys) Reset added in v1.1.2 

func (m *CacheKeys) Reset()

func (*CacheKeys) Size added in v1.1.2 

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

func (*CacheKeys) String added in v1.1.2 

func (m *CacheKeys) String() string

func (*CacheKeys) Unmarshal added in v1.1.2 

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

func (*CacheKeys) XXX_DiscardUnknown added in v1.1.2 

func (m *CacheKeys) XXX_DiscardUnknown()

func (*CacheKeys) XXX_Marshal added in v1.1.2 

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

func (*CacheKeys) XXX_Merge added in v1.1.2 

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

func (*CacheKeys) XXX_Size added in v1.1.2 

func (m *CacheKeys) XXX_Size() int

func (*CacheKeys) XXX_Unmarshal added in v1.1.2 

func (m *CacheKeys) 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
	// 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 

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

func (CmdMethod) String 

func (x CmdMethod) String() string

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) 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 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) 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"`
	// 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 

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

func (m *Request) GetID() uint64

GetID implements the morpc.Message interface.

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 (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) GetUnsubscribeTable added in v1.1.2 

func (m *Request) GetUnsubscribeTable() *UnsubscribeTableRequest

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

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

func (m *Response) GetID() uint64

GetID implements the morpc.Message interface.

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 (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) GetUnsubscribeTable added in v1.1.2 

func (m *Response) GetUnsubscribeTable() *UnsubscribeTableResponse

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

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

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.