query

package
v1.2.3-hotfix-20241101 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2024 License: Apache-2.0 Imports: 18 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CmdMethod_name = map[int32]string{
	0:  "Query",
	1:  "ShowProcessList",
	2:  "AlterAccount",
	3:  "KillConn",
	4:  "TraceSpan",
	5:  "GetLockInfo",
	6:  "GetTxnInfo",
	7:  "GetCacheInfo",
	8:  "SyncCommit",
	9:  "GetCommit",
	10: "GetProtocolVersion",
	11: "SetProtocolVersion",
	12: "CoreDumpConfig",
	13: "RunTask",
	14: "RemoveRemoteLockTable",
	15: "GetLatestBind",
	16: "UnsubscribeTable",
	17: "GetCacheData",
	18: "GetStatsInfo",
	19: "GetPipelineInfo",
	20: "MigrateConnFrom",
	21: "MigrateConnTo",
	22: "ReloadAutoIncrementCache",
	23: "CtlReader",
	24: "GetReplicaCount",
	25: "ResetSession",
	26: "GOMAXPROCS",
	27: "GOMEMLIMIT",
	28: "FileServiceCache",
	29: "FileServiceCacheEvict",
}
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,
	"GetProtocolVersion":       10,
	"SetProtocolVersion":       11,
	"CoreDumpConfig":           12,
	"RunTask":                  13,
	"RemoveRemoteLockTable":    14,
	"GetLatestBind":            15,
	"UnsubscribeTable":         16,
	"GetCacheData":             17,
	"GetStatsInfo":             18,
	"GetPipelineInfo":          19,
	"MigrateConnFrom":          20,
	"MigrateConnTo":            21,
	"ReloadAutoIncrementCache": 22,
	"CtlReader":                23,
	"GetReplicaCount":          24,
	"ResetSession":             25,
	"GOMAXPROCS":               26,
	"GOMEMLIMIT":               27,
	"FileServiceCache":         28,
	"FileServiceCacheEvict":    29,
}
View Source 
var FileServiceCacheType_name = map[int32]string{
	0: "Memory",
	1: "Disk",
}
View Source 
var FileServiceCacheType_value = map[string]int32{
	"Memory": 0,
	"Disk":   1,
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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_GetProtocolVersion CmdMethod = 10
	CmdMethod_SetProtocolVersion CmdMethod = 11
	CmdMethod_CoreDumpConfig     CmdMethod = 12
	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
	// ReloadAutoIncrementCache is the method to reload auto increment cache.
	CmdMethod_ReloadAutoIncrementCache CmdMethod = 22
	CmdMethod_CtlReader                CmdMethod = 23
	// GetReplicaCount get the replica count on specified cn node.
	CmdMethod_GetReplicaCount CmdMethod = 24
	// ResetSession resets the session information in routine to make
	// sure that the session could be reused by other connections.
	CmdMethod_ResetSession CmdMethod = 25
	// GOMAXPROCS get/set the golang runtime.GOMAXPROCS()
	CmdMethod_GOMAXPROCS CmdMethod = 26
	CmdMethod_GOMEMLIMIT CmdMethod = 27
	// FileServiceCache handle mem/disk cache query and reset action.
	CmdMethod_FileServiceCache      CmdMethod = 28
	CmdMethod_FileServiceCacheEvict CmdMethod = 29
)

func (CmdMethod) EnumDescriptor 

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

func (CmdMethod) String 

func (x CmdMethod) String() string

type CoreDumpConfigRequest added in v1.2.0 

type CoreDumpConfigRequest struct {
	// enable or disable
	Action string `protobuf:"bytes,1,opt,name=Action,proto3" json:"Action,omitempty"`
}

func (*CoreDumpConfigRequest) Descriptor added in v1.2.0 

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

func (*CoreDumpConfigRequest) GetAction added in v1.2.0 

func (m *CoreDumpConfigRequest) GetAction() string

func (*CoreDumpConfigRequest) Marshal added in v1.2.0 

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

func (*CoreDumpConfigRequest) MarshalTo added in v1.2.0 

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

func (*CoreDumpConfigRequest) MarshalToSizedBuffer added in v1.2.0 

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

func (*CoreDumpConfigRequest) ProtoMessage added in v1.2.0 

func (*CoreDumpConfigRequest) ProtoMessage()

func (*CoreDumpConfigRequest) Reset added in v1.2.0 

func (m *CoreDumpConfigRequest) Reset()

func (*CoreDumpConfigRequest) Size added in v1.2.0 

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

func (*CoreDumpConfigRequest) String added in v1.2.0 

func (m *CoreDumpConfigRequest) String() string

func (*CoreDumpConfigRequest) Unmarshal added in v1.2.0 

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

func (*CoreDumpConfigRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *CoreDumpConfigRequest) XXX_DiscardUnknown()

func (*CoreDumpConfigRequest) XXX_Marshal added in v1.2.0 

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

func (*CoreDumpConfigRequest) XXX_Merge added in v1.2.0 

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

func (*CoreDumpConfigRequest) XXX_Size added in v1.2.0 

func (m *CoreDumpConfigRequest) XXX_Size() int

func (*CoreDumpConfigRequest) XXX_Unmarshal added in v1.2.0 

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

type CoreDumpConfigResponse added in v1.2.0 

type CoreDumpConfigResponse struct {
}

func (*CoreDumpConfigResponse) Descriptor added in v1.2.0 

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

func (*CoreDumpConfigResponse) Marshal added in v1.2.0 

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

func (*CoreDumpConfigResponse) MarshalTo added in v1.2.0 

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

func (*CoreDumpConfigResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*CoreDumpConfigResponse) ProtoMessage added in v1.2.0 

func (*CoreDumpConfigResponse) ProtoMessage()

func (*CoreDumpConfigResponse) Reset added in v1.2.0 

func (m *CoreDumpConfigResponse) Reset()

func (*CoreDumpConfigResponse) Size added in v1.2.0 

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

func (*CoreDumpConfigResponse) String added in v1.2.0 

func (m *CoreDumpConfigResponse) String() string

func (*CoreDumpConfigResponse) Unmarshal added in v1.2.0 

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

func (*CoreDumpConfigResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *CoreDumpConfigResponse) XXX_DiscardUnknown()

func (*CoreDumpConfigResponse) XXX_Marshal added in v1.2.0 

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

func (*CoreDumpConfigResponse) XXX_Merge added in v1.2.0 

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

func (*CoreDumpConfigResponse) XXX_Size added in v1.2.0 

func (m *CoreDumpConfigResponse) XXX_Size() int

func (*CoreDumpConfigResponse) XXX_Unmarshal added in v1.2.0 

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

type CtlReaderRequest added in v1.2.3 

type CtlReaderRequest struct {
	Cmd   string `protobuf:"bytes,1,opt,name=Cmd,proto3" json:"Cmd,omitempty"`
	Cfg   string `protobuf:"bytes,2,opt,name=Cfg,proto3" json:"Cfg,omitempty"`
	Extra []byte `protobuf:"bytes,3,opt,name=Extra,proto3" json:"Extra,omitempty"`
}

func (*CtlReaderRequest) Descriptor added in v1.2.3 

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

func (*CtlReaderRequest) GetCfg added in v1.2.3 

func (m *CtlReaderRequest) GetCfg() string

func (*CtlReaderRequest) GetCmd added in v1.2.3 

func (m *CtlReaderRequest) GetCmd() string

func (*CtlReaderRequest) GetExtra added in v1.2.3 

func (m *CtlReaderRequest) GetExtra() []byte

func (*CtlReaderRequest) Marshal added in v1.2.3 

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

func (*CtlReaderRequest) MarshalTo added in v1.2.3 

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

func (*CtlReaderRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*CtlReaderRequest) ProtoMessage added in v1.2.3 

func (*CtlReaderRequest) ProtoMessage()

func (*CtlReaderRequest) Reset added in v1.2.3 

func (m *CtlReaderRequest) Reset()

func (*CtlReaderRequest) Size added in v1.2.3 

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

func (*CtlReaderRequest) String added in v1.2.3 

func (m *CtlReaderRequest) String() string

func (*CtlReaderRequest) Unmarshal added in v1.2.3 

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

func (*CtlReaderRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *CtlReaderRequest) XXX_DiscardUnknown()

func (*CtlReaderRequest) XXX_Marshal added in v1.2.3 

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

func (*CtlReaderRequest) XXX_Merge added in v1.2.3 

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

func (*CtlReaderRequest) XXX_Size added in v1.2.3 

func (m *CtlReaderRequest) XXX_Size() int

func (*CtlReaderRequest) XXX_Unmarshal added in v1.2.3 

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

type CtlReaderResponse added in v1.2.3 

type CtlReaderResponse struct {
	Resp string `protobuf:"bytes,1,opt,name=Resp,proto3" json:"Resp,omitempty"`
}

func (*CtlReaderResponse) Descriptor added in v1.2.3 

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

func (*CtlReaderResponse) GetResp added in v1.2.3 

func (m *CtlReaderResponse) GetResp() string

func (*CtlReaderResponse) Marshal added in v1.2.3 

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

func (*CtlReaderResponse) MarshalTo added in v1.2.3 

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

func (*CtlReaderResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*CtlReaderResponse) ProtoMessage added in v1.2.3 

func (*CtlReaderResponse) ProtoMessage()

func (*CtlReaderResponse) Reset added in v1.2.3 

func (m *CtlReaderResponse) Reset()

func (*CtlReaderResponse) Size added in v1.2.3 

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

func (*CtlReaderResponse) String added in v1.2.3 

func (m *CtlReaderResponse) String() string

func (*CtlReaderResponse) Unmarshal added in v1.2.3 

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

func (*CtlReaderResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *CtlReaderResponse) XXX_DiscardUnknown()

func (*CtlReaderResponse) XXX_Marshal added in v1.2.3 

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

func (*CtlReaderResponse) XXX_Merge added in v1.2.3 

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

func (*CtlReaderResponse) XXX_Size added in v1.2.3 

func (m *CtlReaderResponse) XXX_Size() int

func (*CtlReaderResponse) XXX_Unmarshal added in v1.2.3 

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

type FileServiceCacheEvictRequest added in v1.2.3 

type FileServiceCacheEvictRequest struct {
	Type FileServiceCacheType `protobuf:"varint,1,opt,name=Type,proto3,enum=query.FileServiceCacheType" json:"Type,omitempty"`
}

func (*FileServiceCacheEvictRequest) Descriptor added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) GetType added in v1.2.3 

func (m *FileServiceCacheEvictRequest) GetType() FileServiceCacheType

func (*FileServiceCacheEvictRequest) Marshal added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) MarshalTo added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) ProtoMessage added in v1.2.3 

func (*FileServiceCacheEvictRequest) ProtoMessage()

func (*FileServiceCacheEvictRequest) Reset added in v1.2.3 

func (m *FileServiceCacheEvictRequest) Reset()

func (*FileServiceCacheEvictRequest) Size added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) String added in v1.2.3 

func (m *FileServiceCacheEvictRequest) String() string

func (*FileServiceCacheEvictRequest) Unmarshal added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *FileServiceCacheEvictRequest) XXX_DiscardUnknown()

func (*FileServiceCacheEvictRequest) XXX_Marshal added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) XXX_Merge added in v1.2.3 

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

func (*FileServiceCacheEvictRequest) XXX_Size added in v1.2.3 

func (m *FileServiceCacheEvictRequest) XXX_Size() int

func (*FileServiceCacheEvictRequest) XXX_Unmarshal added in v1.2.3 

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

type FileServiceCacheEvictResponse added in v1.2.3 

type FileServiceCacheEvictResponse struct {
	CacheSize     int64  `protobuf:"varint,1,opt,name=CacheSize,proto3" json:"CacheSize,omitempty"`
	CacheCapacity int64  `protobuf:"varint,2,opt,name=CacheCapacity,proto3" json:"CacheCapacity,omitempty"`
	Message       string `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
}

func (*FileServiceCacheEvictResponse) Descriptor added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) GetCacheCapacity added in v1.2.3 

func (m *FileServiceCacheEvictResponse) GetCacheCapacity() int64

func (*FileServiceCacheEvictResponse) GetCacheSize added in v1.2.3 

func (m *FileServiceCacheEvictResponse) GetCacheSize() int64

func (*FileServiceCacheEvictResponse) GetMessage added in v1.2.3 

func (m *FileServiceCacheEvictResponse) GetMessage() string

func (*FileServiceCacheEvictResponse) Marshal added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) MarshalTo added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) ProtoMessage added in v1.2.3 

func (*FileServiceCacheEvictResponse) ProtoMessage()

func (*FileServiceCacheEvictResponse) Reset added in v1.2.3 

func (m *FileServiceCacheEvictResponse) Reset()

func (*FileServiceCacheEvictResponse) Size added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) String added in v1.2.3 

func (m *FileServiceCacheEvictResponse) String() string

func (*FileServiceCacheEvictResponse) Unmarshal added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *FileServiceCacheEvictResponse) XXX_DiscardUnknown()

func (*FileServiceCacheEvictResponse) XXX_Marshal added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) XXX_Merge added in v1.2.3 

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

func (*FileServiceCacheEvictResponse) XXX_Size added in v1.2.3 

func (m *FileServiceCacheEvictResponse) XXX_Size() int

func (*FileServiceCacheEvictResponse) XXX_Unmarshal added in v1.2.3 

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

type FileServiceCacheRequest added in v1.2.3 

type FileServiceCacheRequest struct {
	Type      FileServiceCacheType `protobuf:"varint,1,opt,name=Type,proto3,enum=query.FileServiceCacheType" json:"Type,omitempty"`
	CacheSize int64                `protobuf:"varint,2,opt,name=CacheSize,proto3" json:"CacheSize,omitempty"`
}

FileServiceCacheRequest handle cache getter and setter request. If @Size is zero, do the getter action, otherwise do the setter action.

func (*FileServiceCacheRequest) Descriptor added in v1.2.3 

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

func (*FileServiceCacheRequest) GetCacheSize added in v1.2.3 

func (m *FileServiceCacheRequest) GetCacheSize() int64

func (*FileServiceCacheRequest) GetType added in v1.2.3 

func (m *FileServiceCacheRequest) GetType() FileServiceCacheType

func (*FileServiceCacheRequest) Marshal added in v1.2.3 

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

func (*FileServiceCacheRequest) MarshalTo added in v1.2.3 

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

func (*FileServiceCacheRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*FileServiceCacheRequest) ProtoMessage added in v1.2.3 

func (*FileServiceCacheRequest) ProtoMessage()

func (*FileServiceCacheRequest) Reset added in v1.2.3 

func (m *FileServiceCacheRequest) Reset()

func (*FileServiceCacheRequest) Size added in v1.2.3 

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

func (*FileServiceCacheRequest) String added in v1.2.3 

func (m *FileServiceCacheRequest) String() string

func (*FileServiceCacheRequest) Unmarshal added in v1.2.3 

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

func (*FileServiceCacheRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *FileServiceCacheRequest) XXX_DiscardUnknown()

func (*FileServiceCacheRequest) XXX_Marshal added in v1.2.3 

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

func (*FileServiceCacheRequest) XXX_Merge added in v1.2.3 

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

func (*FileServiceCacheRequest) XXX_Size added in v1.2.3 

func (m *FileServiceCacheRequest) XXX_Size() int

func (*FileServiceCacheRequest) XXX_Unmarshal added in v1.2.3 

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

type FileServiceCacheResponse added in v1.2.3 

type FileServiceCacheResponse struct {
	CacheSize     int64  `protobuf:"varint,1,opt,name=CacheSize,proto3" json:"CacheSize,omitempty"`
	CacheCapacity int64  `protobuf:"varint,2,opt,name=CacheCapacity,proto3" json:"CacheCapacity,omitempty"`
	Message       string `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
}

FileServiceCacheResponse

func (*FileServiceCacheResponse) Descriptor added in v1.2.3 

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

func (*FileServiceCacheResponse) GetCacheCapacity added in v1.2.3 

func (m *FileServiceCacheResponse) GetCacheCapacity() int64

func (*FileServiceCacheResponse) GetCacheSize added in v1.2.3 

func (m *FileServiceCacheResponse) GetCacheSize() int64

func (*FileServiceCacheResponse) GetMessage added in v1.2.3 

func (m *FileServiceCacheResponse) GetMessage() string

func (*FileServiceCacheResponse) Marshal added in v1.2.3 

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

func (*FileServiceCacheResponse) MarshalTo added in v1.2.3 

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

func (*FileServiceCacheResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*FileServiceCacheResponse) ProtoMessage added in v1.2.3 

func (*FileServiceCacheResponse) ProtoMessage()

func (*FileServiceCacheResponse) Reset added in v1.2.3 

func (m *FileServiceCacheResponse) Reset()

func (*FileServiceCacheResponse) Size added in v1.2.3 

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

func (*FileServiceCacheResponse) String added in v1.2.3 

func (m *FileServiceCacheResponse) String() string

func (*FileServiceCacheResponse) Unmarshal added in v1.2.3 

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

func (*FileServiceCacheResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *FileServiceCacheResponse) XXX_DiscardUnknown()

func (*FileServiceCacheResponse) XXX_Marshal added in v1.2.3 

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

func (*FileServiceCacheResponse) XXX_Merge added in v1.2.3 

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

func (*FileServiceCacheResponse) XXX_Size added in v1.2.3 

func (m *FileServiceCacheResponse) XXX_Size() int

func (*FileServiceCacheResponse) XXX_Unmarshal added in v1.2.3 

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

type FileServiceCacheType added in v1.2.3 

type FileServiceCacheType int32
const (
	FileServiceCacheType_Memory FileServiceCacheType = 0
	FileServiceCacheType_Disk   FileServiceCacheType = 1
)

func (FileServiceCacheType) EnumDescriptor added in v1.2.3 

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

func (FileServiceCacheType) String added in v1.2.3 

func (x FileServiceCacheType) 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"`
}

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"`
}

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

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"`
}

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

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"`
}

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 {
	GroupID uint32 `protobuf:"varint,1,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	TableID uint64 `protobuf:"varint,2,opt,name=TableID,proto3" json:"TableID,omitempty"`
}

func (*GetLatestBindRequest) Descriptor added in v1.1.1 

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

func (*GetLatestBindRequest) GetGroupID added in v1.2.0 

func (m *GetLatestBindRequest) GetGroupID() uint32

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"`
}

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

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"`
}

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

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"`
}

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

type GetProtocolVersionRequest struct {
}

func (*GetProtocolVersionRequest) Descriptor added in v1.1.0 

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

func (*GetProtocolVersionRequest) Marshal added in v1.1.0 

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

func (*GetProtocolVersionRequest) MarshalTo added in v1.1.0 

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

func (*GetProtocolVersionRequest) MarshalToSizedBuffer added in v1.1.0 

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

func (*GetProtocolVersionRequest) ProtoMessage added in v1.1.0 

func (*GetProtocolVersionRequest) ProtoMessage()

func (*GetProtocolVersionRequest) Reset added in v1.1.0 

func (m *GetProtocolVersionRequest) Reset()

func (*GetProtocolVersionRequest) Size added in v1.1.0 

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

func (*GetProtocolVersionRequest) String added in v1.1.0 

func (m *GetProtocolVersionRequest) String() string

func (*GetProtocolVersionRequest) Unmarshal added in v1.1.0 

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

func (*GetProtocolVersionRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *GetProtocolVersionRequest) XXX_DiscardUnknown()

func (*GetProtocolVersionRequest) XXX_Marshal added in v1.1.0 

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

func (*GetProtocolVersionRequest) XXX_Merge added in v1.1.0 

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

func (*GetProtocolVersionRequest) XXX_Size added in v1.1.0 

func (m *GetProtocolVersionRequest) XXX_Size() int

func (*GetProtocolVersionRequest) XXX_Unmarshal added in v1.1.0 

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

type GetProtocolVersionResponse added in v1.1.0 

type GetProtocolVersionResponse struct {
	// ProtocolVersion is the version of the protocol
	Version int64 `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
}

func (*GetProtocolVersionResponse) Descriptor added in v1.1.0 

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

func (*GetProtocolVersionResponse) GetVersion added in v1.1.0 

func (m *GetProtocolVersionResponse) GetVersion() int64

func (*GetProtocolVersionResponse) Marshal added in v1.1.0 

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

func (*GetProtocolVersionResponse) MarshalTo added in v1.1.0 

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

func (*GetProtocolVersionResponse) MarshalToSizedBuffer added in v1.1.0 

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

func (*GetProtocolVersionResponse) ProtoMessage added in v1.1.0 

func (*GetProtocolVersionResponse) ProtoMessage()

func (*GetProtocolVersionResponse) Reset added in v1.1.0 

func (m *GetProtocolVersionResponse) Reset()

func (*GetProtocolVersionResponse) Size added in v1.1.0 

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

func (*GetProtocolVersionResponse) String added in v1.1.0 

func (m *GetProtocolVersionResponse) String() string

func (*GetProtocolVersionResponse) Unmarshal added in v1.1.0 

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

func (*GetProtocolVersionResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *GetProtocolVersionResponse) XXX_DiscardUnknown()

func (*GetProtocolVersionResponse) XXX_Marshal added in v1.1.0 

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

func (*GetProtocolVersionResponse) XXX_Merge added in v1.1.0 

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

func (*GetProtocolVersionResponse) XXX_Size added in v1.1.0 

func (m *GetProtocolVersionResponse) XXX_Size() int

func (*GetProtocolVersionResponse) XXX_Unmarshal added in v1.1.0 

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

type GetReplicaCountRequest added in v1.2.3 

type GetReplicaCountRequest struct {
	CN string `protobuf:"bytes,1,opt,name=CN,proto3" json:"CN,omitempty"`
}

func (*GetReplicaCountRequest) Descriptor added in v1.2.3 

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

func (*GetReplicaCountRequest) GetCN added in v1.2.3 

func (m *GetReplicaCountRequest) GetCN() string

func (*GetReplicaCountRequest) Marshal added in v1.2.3 

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

func (*GetReplicaCountRequest) MarshalTo added in v1.2.3 

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

func (*GetReplicaCountRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*GetReplicaCountRequest) ProtoMessage added in v1.2.3 

func (*GetReplicaCountRequest) ProtoMessage()

func (*GetReplicaCountRequest) Reset added in v1.2.3 

func (m *GetReplicaCountRequest) Reset()

func (*GetReplicaCountRequest) Size added in v1.2.3 

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

func (*GetReplicaCountRequest) String added in v1.2.3 

func (m *GetReplicaCountRequest) String() string

func (*GetReplicaCountRequest) Unmarshal added in v1.2.3 

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

func (*GetReplicaCountRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *GetReplicaCountRequest) XXX_DiscardUnknown()

func (*GetReplicaCountRequest) XXX_Marshal added in v1.2.3 

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

func (*GetReplicaCountRequest) XXX_Merge added in v1.2.3 

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

func (*GetReplicaCountRequest) XXX_Size added in v1.2.3 

func (m *GetReplicaCountRequest) XXX_Size() int

func (*GetReplicaCountRequest) XXX_Unmarshal added in v1.2.3 

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

type GetReplicaCountResponse added in v1.2.3 

type GetReplicaCountResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
}

func (*GetReplicaCountResponse) Descriptor added in v1.2.3 

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

func (*GetReplicaCountResponse) GetCount added in v1.2.3 

func (m *GetReplicaCountResponse) GetCount() int64

func (*GetReplicaCountResponse) Marshal added in v1.2.3 

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

func (*GetReplicaCountResponse) MarshalTo added in v1.2.3 

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

func (*GetReplicaCountResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*GetReplicaCountResponse) ProtoMessage added in v1.2.3 

func (*GetReplicaCountResponse) ProtoMessage()

func (*GetReplicaCountResponse) Reset added in v1.2.3 

func (m *GetReplicaCountResponse) Reset()

func (*GetReplicaCountResponse) Size added in v1.2.3 

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

func (*GetReplicaCountResponse) String added in v1.2.3 

func (m *GetReplicaCountResponse) String() string

func (*GetReplicaCountResponse) Unmarshal added in v1.2.3 

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

func (*GetReplicaCountResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *GetReplicaCountResponse) XXX_DiscardUnknown()

func (*GetReplicaCountResponse) XXX_Marshal added in v1.2.3 

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

func (*GetReplicaCountResponse) XXX_Merge added in v1.2.3 

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

func (*GetReplicaCountResponse) XXX_Size added in v1.2.3 

func (m *GetReplicaCountResponse) XXX_Size() int

func (*GetReplicaCountResponse) XXX_Unmarshal added in v1.2.3 

func (m *GetReplicaCountResponse) 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"`
}

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"`
}

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

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"`
}

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 GoMaxProcsRequest added in v1.2.3 

type GoMaxProcsRequest struct {
	MaxProcs int32 `protobuf:"varint,1,opt,name=MaxProcs,proto3" json:"MaxProcs,omitempty"`
}

GoMaxProcsRequest is request to get/set the proc runtime.GOMAXPROCS() If MaxProcs is 0, then return current value of runtime.GOMAXPROCS(0), Otherwise, do the set op runtime.GOMAXPROCS({MaxProcs})

func (*GoMaxProcsRequest) Descriptor added in v1.2.3 

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

func (*GoMaxProcsRequest) GetMaxProcs added in v1.2.3 

func (m *GoMaxProcsRequest) GetMaxProcs() int32

func (*GoMaxProcsRequest) Marshal added in v1.2.3 

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

func (*GoMaxProcsRequest) MarshalTo added in v1.2.3 

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

func (*GoMaxProcsRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*GoMaxProcsRequest) ProtoMessage added in v1.2.3 

func (*GoMaxProcsRequest) ProtoMessage()

func (*GoMaxProcsRequest) Reset added in v1.2.3 

func (m *GoMaxProcsRequest) Reset()

func (*GoMaxProcsRequest) Size added in v1.2.3 

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

func (*GoMaxProcsRequest) String added in v1.2.3 

func (m *GoMaxProcsRequest) String() string

func (*GoMaxProcsRequest) Unmarshal added in v1.2.3 

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

func (*GoMaxProcsRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *GoMaxProcsRequest) XXX_DiscardUnknown()

func (*GoMaxProcsRequest) XXX_Marshal added in v1.2.3 

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

func (*GoMaxProcsRequest) XXX_Merge added in v1.2.3 

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

func (*GoMaxProcsRequest) XXX_Size added in v1.2.3 

func (m *GoMaxProcsRequest) XXX_Size() int

func (*GoMaxProcsRequest) XXX_Unmarshal added in v1.2.3 

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

type GoMaxProcsResponse added in v1.2.3 

type GoMaxProcsResponse struct {
	MaxProcs int32 `protobuf:"varint,1,opt,name=MaxProcs,proto3" json:"MaxProcs,omitempty"`
}

GoMaxProcsResponse is the response of calling runtime.GOMAXPROCS(req.MaxProcs) The MaxProcs is current value, or previous value. Same meaning as calling runtime.GOMAXPROCS(req.MaxProcs).

func (*GoMaxProcsResponse) Descriptor added in v1.2.3 

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

func (*GoMaxProcsResponse) GetMaxProcs added in v1.2.3 

func (m *GoMaxProcsResponse) GetMaxProcs() int32

func (*GoMaxProcsResponse) Marshal added in v1.2.3 

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

func (*GoMaxProcsResponse) MarshalTo added in v1.2.3 

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

func (*GoMaxProcsResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*GoMaxProcsResponse) ProtoMessage added in v1.2.3 

func (*GoMaxProcsResponse) ProtoMessage()

func (*GoMaxProcsResponse) Reset added in v1.2.3 

func (m *GoMaxProcsResponse) Reset()

func (*GoMaxProcsResponse) Size added in v1.2.3 

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

func (*GoMaxProcsResponse) String added in v1.2.3 

func (m *GoMaxProcsResponse) String() string

func (*GoMaxProcsResponse) Unmarshal added in v1.2.3 

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

func (*GoMaxProcsResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *GoMaxProcsResponse) XXX_DiscardUnknown()

func (*GoMaxProcsResponse) XXX_Marshal added in v1.2.3 

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

func (*GoMaxProcsResponse) XXX_Merge added in v1.2.3 

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

func (*GoMaxProcsResponse) XXX_Size added in v1.2.3 

func (m *GoMaxProcsResponse) XXX_Size() int

func (*GoMaxProcsResponse) XXX_Unmarshal added in v1.2.3 

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

type GoMemLimitRequest added in v1.2.3 

type GoMemLimitRequest struct {
	MemLimitBytes int64 `protobuf:"varint,1,opt,name=MemLimitBytes,proto3" json:"MemLimitBytes,omitempty"`
}

func (*GoMemLimitRequest) Descriptor added in v1.2.3 

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

func (*GoMemLimitRequest) GetMemLimitBytes added in v1.2.3 

func (m *GoMemLimitRequest) GetMemLimitBytes() int64

func (*GoMemLimitRequest) Marshal added in v1.2.3 

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

func (*GoMemLimitRequest) MarshalTo added in v1.2.3 

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

func (*GoMemLimitRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*GoMemLimitRequest) ProtoMessage added in v1.2.3 

func (*GoMemLimitRequest) ProtoMessage()

func (*GoMemLimitRequest) Reset added in v1.2.3 

func (m *GoMemLimitRequest) Reset()

func (*GoMemLimitRequest) Size added in v1.2.3 

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

func (*GoMemLimitRequest) String added in v1.2.3 

func (m *GoMemLimitRequest) String() string

func (*GoMemLimitRequest) Unmarshal added in v1.2.3 

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

func (*GoMemLimitRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *GoMemLimitRequest) XXX_DiscardUnknown()

func (*GoMemLimitRequest) XXX_Marshal added in v1.2.3 

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

func (*GoMemLimitRequest) XXX_Merge added in v1.2.3 

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

func (*GoMemLimitRequest) XXX_Size added in v1.2.3 

func (m *GoMemLimitRequest) XXX_Size() int

func (*GoMemLimitRequest) XXX_Unmarshal added in v1.2.3 

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

type GoMemLimitResponse added in v1.2.3 

type GoMemLimitResponse struct {
	MemLimitBytes int64 `protobuf:"varint,1,opt,name=MemLimitBytes,proto3" json:"MemLimitBytes,omitempty"`
}

GoMemLimitResponse is the response of calling runtime/debug.SetMemoryLimit(req.MemLimitBytes) The MemLimitBytes is previous value. Same meaning as calling runtime/debug.SetMemoryLimit(req.MemLimitBytes).

func (*GoMemLimitResponse) Descriptor added in v1.2.3 

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

func (*GoMemLimitResponse) GetMemLimitBytes added in v1.2.3 

func (m *GoMemLimitResponse) GetMemLimitBytes() int64

func (*GoMemLimitResponse) Marshal added in v1.2.3 

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

func (*GoMemLimitResponse) MarshalTo added in v1.2.3 

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

func (*GoMemLimitResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*GoMemLimitResponse) ProtoMessage added in v1.2.3 

func (*GoMemLimitResponse) ProtoMessage()

func (*GoMemLimitResponse) Reset added in v1.2.3 

func (m *GoMemLimitResponse) Reset()

func (*GoMemLimitResponse) Size added in v1.2.3 

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

func (*GoMemLimitResponse) String added in v1.2.3 

func (m *GoMemLimitResponse) String() string

func (*GoMemLimitResponse) Unmarshal added in v1.2.3 

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

func (*GoMemLimitResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *GoMemLimitResponse) XXX_DiscardUnknown()

func (*GoMemLimitResponse) XXX_Marshal added in v1.2.3 

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

func (*GoMemLimitResponse) XXX_Merge added in v1.2.3 

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

func (*GoMemLimitResponse) XXX_Size added in v1.2.3 

func (m *GoMemLimitResponse) XXX_Size() int

func (*GoMemLimitResponse) XXX_Unmarshal added in v1.2.3 

func (m *GoMemLimitResponse) 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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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 ReloadAutoIncrementCacheRequest added in v1.2.2 

type ReloadAutoIncrementCacheRequest struct {
	TableID uint64 `protobuf:"varint,1,opt,name=TableID,proto3" json:"TableID,omitempty"`
}

ReloadAutoIncrementCacheRequest reload auto increment cache request

func (*ReloadAutoIncrementCacheRequest) Descriptor added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) GetTableID added in v1.2.2 

func (m *ReloadAutoIncrementCacheRequest) GetTableID() uint64

func (*ReloadAutoIncrementCacheRequest) Marshal added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) MarshalTo added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) MarshalToSizedBuffer added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) ProtoMessage added in v1.2.2 

func (*ReloadAutoIncrementCacheRequest) ProtoMessage()

func (*ReloadAutoIncrementCacheRequest) Reset added in v1.2.2 

func (m *ReloadAutoIncrementCacheRequest) Reset()

func (*ReloadAutoIncrementCacheRequest) Size added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) String added in v1.2.2 

func (m *ReloadAutoIncrementCacheRequest) String() string

func (*ReloadAutoIncrementCacheRequest) Unmarshal added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) XXX_DiscardUnknown added in v1.2.2 

func (m *ReloadAutoIncrementCacheRequest) XXX_DiscardUnknown()

func (*ReloadAutoIncrementCacheRequest) XXX_Marshal added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) XXX_Merge added in v1.2.2 

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

func (*ReloadAutoIncrementCacheRequest) XXX_Size added in v1.2.2 

func (m *ReloadAutoIncrementCacheRequest) XXX_Size() int

func (*ReloadAutoIncrementCacheRequest) XXX_Unmarshal added in v1.2.2 

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

type ReloadAutoIncrementCacheResponse added in v1.2.2 

type ReloadAutoIncrementCacheResponse struct {
}

ReloadAutoIncrementCacheResponse reload auto increment cache response

func (*ReloadAutoIncrementCacheResponse) Descriptor added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) Marshal added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) MarshalTo added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) MarshalToSizedBuffer added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) ProtoMessage added in v1.2.2 

func (*ReloadAutoIncrementCacheResponse) ProtoMessage()

func (*ReloadAutoIncrementCacheResponse) Reset added in v1.2.2 

func (m *ReloadAutoIncrementCacheResponse) Reset()

func (*ReloadAutoIncrementCacheResponse) Size added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) String added in v1.2.2 

func (m *ReloadAutoIncrementCacheResponse) String() string

func (*ReloadAutoIncrementCacheResponse) Unmarshal added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) XXX_DiscardUnknown added in v1.2.2 

func (m *ReloadAutoIncrementCacheResponse) XXX_DiscardUnknown()

func (*ReloadAutoIncrementCacheResponse) XXX_Marshal added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) XXX_Merge added in v1.2.2 

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

func (*ReloadAutoIncrementCacheResponse) XXX_Size added in v1.2.2 

func (m *ReloadAutoIncrementCacheResponse) XXX_Size() int

func (*ReloadAutoIncrementCacheResponse) XXX_Unmarshal added in v1.2.2 

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

type RemoveRemoteLockTableRequest added in v1.1.1 

type RemoveRemoteLockTableRequest struct {
	GroupID uint32 `protobuf:"varint,1,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	TableID uint64 `protobuf:"varint,2,opt,name=TableID,proto3" json:"TableID,omitempty"`
	Version uint64 `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
}

func (*RemoveRemoteLockTableRequest) Descriptor added in v1.1.1 

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

func (*RemoveRemoteLockTableRequest) GetGroupID added in v1.2.0 

func (m *RemoveRemoteLockTableRequest) GetGroupID() uint32

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"`
}

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"`
	GetProtocolVersion    *GetProtocolVersionRequest    `protobuf:"bytes,13,opt,name=GetProtocolVersion,proto3" json:"GetProtocolVersion,omitempty"`
	SetProtocolVersion    *SetProtocolVersionRequest    `protobuf:"bytes,14,opt,name=SetProtocolVersion,proto3" json:"SetProtocolVersion,omitempty"`
	CoreDumpConfig        *CoreDumpConfigRequest        `protobuf:"bytes,15,opt,name=CoreDumpConfig,proto3" json:"CoreDumpConfig,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"`
	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"`
	ReloadAutoIncrementCache *ReloadAutoIncrementCacheRequest `protobuf:"bytes,25,opt,name=ReloadAutoIncrementCache,proto3" json:"ReloadAutoIncrementCache,omitempty"`
	CtlReaderRequest         *CtlReaderRequest                `protobuf:"bytes,26,opt,name=CtlReaderRequest,proto3" json:"CtlReaderRequest,omitempty"`
	GetReplicaCount          GetReplicaCountRequest           `protobuf:"bytes,27,opt,name=GetReplicaCount,proto3" json:"GetReplicaCount"`
	// ResetSessionRequest is the request that resets the session information.
	ResetSessionRequest          *ResetSessionRequest         `protobuf:"bytes,28,opt,name=ResetSessionRequest,proto3" json:"ResetSessionRequest,omitempty"`
	GoMaxProcsRequest            GoMaxProcsRequest            `protobuf:"bytes,29,opt,name=GoMaxProcsRequest,proto3" json:"GoMaxProcsRequest"`
	GoMemLimitRequest            GoMemLimitRequest            `protobuf:"bytes,30,opt,name=GoMemLimitRequest,proto3" json:"GoMemLimitRequest"`
	FileServiceCacheRequest      FileServiceCacheRequest      `protobuf:"bytes,31,opt,name=FileServiceCacheRequest,proto3" json:"FileServiceCacheRequest"`
	FileServiceCacheEvictRequest FileServiceCacheEvictRequest `protobuf:"bytes,32,opt,name=FileServiceCacheEvictRequest,proto3" json:"FileServiceCacheEvictRequest"`
}

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) GetCoreDumpConfig added in v1.2.0 

func (m *Request) GetCoreDumpConfig() *CoreDumpConfigRequest

func (*Request) GetCtlReaderRequest added in v1.2.3 

func (m *Request) GetCtlReaderRequest() *CtlReaderRequest

func (*Request) GetFileServiceCacheEvictRequest added in v1.2.3 

func (m *Request) GetFileServiceCacheEvictRequest() FileServiceCacheEvictRequest

func (*Request) GetFileServiceCacheRequest added in v1.2.3 

func (m *Request) GetFileServiceCacheRequest() FileServiceCacheRequest

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

func (m *Request) GetGetProtocolVersion() *GetProtocolVersionRequest

func (*Request) GetGetReplicaCount added in v1.2.3 

func (m *Request) GetGetReplicaCount() GetReplicaCountRequest

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) GetGoMaxProcsRequest added in v1.2.3 

func (m *Request) GetGoMaxProcsRequest() GoMaxProcsRequest

func (*Request) GetGoMemLimitRequest added in v1.2.3 

func (m *Request) GetGoMemLimitRequest() GoMemLimitRequest

func (*Request) GetID 

func (m *Request) GetID() uint64

GetID implements the morpc.Message interface.

func (*Request) GetKillConnRequest 

func (m *Request) GetKillConnRequest() *KillConnRequest

func (*Request) GetMethod added in v1.1.0 

func (m *Request) GetMethod() CmdMethod

GetMethod implements the morpc.MethodBasedMessage interface.

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) GetReloadAutoIncrementCache added in v1.2.2 

func (m *Request) GetReloadAutoIncrementCache() *ReloadAutoIncrementCacheRequest

func (*Request) GetRemoveRemoteLockTable added in v1.1.1 

func (m *Request) GetRemoveRemoteLockTable() *RemoveRemoteLockTableRequest

func (*Request) GetRequestID 

func (m *Request) GetRequestID() uint64

func (*Request) GetResetSessionRequest added in v1.2.3 

func (m *Request) GetResetSessionRequest() *ResetSessionRequest

func (*Request) GetRunTask added in v1.1.1 

func (m *Request) GetRunTask() *RunTaskRequest

func (*Request) GetSetProtocolVersion added in v1.1.0 

func (m *Request) GetSetProtocolVersion() *SetProtocolVersionRequest

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"`
}

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 ResetSessionRequest added in v1.2.3 

type ResetSessionRequest struct {
	ConnID uint32 `protobuf:"varint,1,opt,name=ConnID,proto3" json:"ConnID,omitempty"`
}

ResetSessionRequest is the request to reset session before proxy cache the connection.

func (*ResetSessionRequest) Descriptor added in v1.2.3 

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

func (*ResetSessionRequest) GetConnID added in v1.2.3 

func (m *ResetSessionRequest) GetConnID() uint32

func (*ResetSessionRequest) Marshal added in v1.2.3 

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

func (*ResetSessionRequest) MarshalTo added in v1.2.3 

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

func (*ResetSessionRequest) MarshalToSizedBuffer added in v1.2.3 

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

func (*ResetSessionRequest) ProtoMessage added in v1.2.3 

func (*ResetSessionRequest) ProtoMessage()

func (*ResetSessionRequest) Reset added in v1.2.3 

func (m *ResetSessionRequest) Reset()

func (*ResetSessionRequest) Size added in v1.2.3 

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

func (*ResetSessionRequest) String added in v1.2.3 

func (m *ResetSessionRequest) String() string

func (*ResetSessionRequest) Unmarshal added in v1.2.3 

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

func (*ResetSessionRequest) XXX_DiscardUnknown added in v1.2.3 

func (m *ResetSessionRequest) XXX_DiscardUnknown()

func (*ResetSessionRequest) XXX_Marshal added in v1.2.3 

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

func (*ResetSessionRequest) XXX_Merge added in v1.2.3 

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

func (*ResetSessionRequest) XXX_Size added in v1.2.3 

func (m *ResetSessionRequest) XXX_Size() int

func (*ResetSessionRequest) XXX_Unmarshal added in v1.2.3 

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

type ResetSessionResponse added in v1.2.3 

type ResetSessionResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// AuthString is the authentication string which is encrypted.
	AuthString []byte `protobuf:"bytes,2,opt,name=AuthString,proto3" json:"AuthString,omitempty"`
}

ResetSessionResponse is the response which contains the password of the user on the session.

func (*ResetSessionResponse) Descriptor added in v1.2.3 

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

func (*ResetSessionResponse) GetAuthString added in v1.2.3 

func (m *ResetSessionResponse) GetAuthString() []byte

func (*ResetSessionResponse) GetSuccess added in v1.2.3 

func (m *ResetSessionResponse) GetSuccess() bool

func (*ResetSessionResponse) Marshal added in v1.2.3 

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

func (*ResetSessionResponse) MarshalTo added in v1.2.3 

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

func (*ResetSessionResponse) MarshalToSizedBuffer added in v1.2.3 

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

func (*ResetSessionResponse) ProtoMessage added in v1.2.3 

func (*ResetSessionResponse) ProtoMessage()

func (*ResetSessionResponse) Reset added in v1.2.3 

func (m *ResetSessionResponse) Reset()

func (*ResetSessionResponse) Size added in v1.2.3 

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

func (*ResetSessionResponse) String added in v1.2.3 

func (m *ResetSessionResponse) String() string

func (*ResetSessionResponse) Unmarshal added in v1.2.3 

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

func (*ResetSessionResponse) XXX_DiscardUnknown added in v1.2.3 

func (m *ResetSessionResponse) XXX_DiscardUnknown()

func (*ResetSessionResponse) XXX_Marshal added in v1.2.3 

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

func (*ResetSessionResponse) XXX_Merge added in v1.2.3 

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

func (*ResetSessionResponse) XXX_Size added in v1.2.3 

func (m *ResetSessionResponse) XXX_Size() int

func (*ResetSessionResponse) XXX_Unmarshal added in v1.2.3 

func (m *ResetSessionResponse) 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"`
	GetProtocolVersion    *GetProtocolVersionResponse    `protobuf:"bytes,13,opt,name=GetProtocolVersion,proto3" json:"GetProtocolVersion,omitempty"`
	SetProtocolVersion    *SetProtocolVersionResponse    `protobuf:"bytes,14,opt,name=SetProtocolVersion,proto3" json:"SetProtocolVersion,omitempty"`
	CoreDumpConfig        *CoreDumpConfigResponse        `protobuf:"bytes,15,opt,name=CoreDumpConfig,proto3" json:"CoreDumpConfig,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"`
	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"`
	ReloadAutoIncrementCache *ReloadAutoIncrementCacheResponse `protobuf:"bytes,25,opt,name=ReloadAutoIncrementCache,proto3" json:"ReloadAutoIncrementCache,omitempty"`
	CtlReaderResponse        *CtlReaderResponse                `protobuf:"bytes,26,opt,name=CtlReaderResponse,proto3" json:"CtlReaderResponse,omitempty"`
	GetReplicaCount          GetReplicaCountResponse           `protobuf:"bytes,27,opt,name=GetReplicaCount,proto3" json:"GetReplicaCount"`
	// ResetSessionResponse is the response of ResetSessionRequest.
	ResetSessionResponse          *ResetSessionResponse         `protobuf:"bytes,28,opt,name=ResetSessionResponse,proto3" json:"ResetSessionResponse,omitempty"`
	GoMaxProcsResponse            GoMaxProcsResponse            `protobuf:"bytes,29,opt,name=GoMaxProcsResponse,proto3" json:"GoMaxProcsResponse"`
	GoMemLimitResponse            GoMemLimitResponse            `protobuf:"bytes,30,opt,name=GoMemLimitResponse,proto3" json:"GoMemLimitResponse"`
	FileServiceCacheResponse      FileServiceCacheResponse      `protobuf:"bytes,31,opt,name=FileServiceCacheResponse,proto3" json:"FileServiceCacheResponse"`
	FileServiceCacheEvictResponse FileServiceCacheEvictResponse `protobuf:"bytes,32,opt,name=FileServiceCacheEvictResponse,proto3" json:"FileServiceCacheEvictResponse"`
}

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) GetCoreDumpConfig added in v1.2.0 

func (m *Response) GetCoreDumpConfig() *CoreDumpConfigResponse

func (*Response) GetCtlReaderResponse added in v1.2.3 

func (m *Response) GetCtlReaderResponse() *CtlReaderResponse

func (*Response) GetError 

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

func (*Response) GetFileServiceCacheEvictResponse added in v1.2.3 

func (m *Response) GetFileServiceCacheEvictResponse() FileServiceCacheEvictResponse

func (*Response) GetFileServiceCacheResponse added in v1.2.3 

func (m *Response) GetFileServiceCacheResponse() FileServiceCacheResponse

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

func (m *Response) GetGetProtocolVersion() *GetProtocolVersionResponse

func (*Response) GetGetReplicaCount added in v1.2.3 

func (m *Response) GetGetReplicaCount() GetReplicaCountResponse

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) GetGoMaxProcsResponse added in v1.2.3 

func (m *Response) GetGoMaxProcsResponse() GoMaxProcsResponse

func (*Response) GetGoMemLimitResponse added in v1.2.3 

func (m *Response) GetGoMemLimitResponse() GoMemLimitResponse

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) GetReloadAutoIncrementCache added in v1.2.2 

func (m *Response) GetReloadAutoIncrementCache() *ReloadAutoIncrementCacheResponse

func (*Response) GetRemoveRemoteLockTable added in v1.1.1 

func (m *Response) GetRemoveRemoteLockTable() *RemoveRemoteLockTableResponse

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

func (*Response) GetResetSessionResponse added in v1.2.3 

func (m *Response) GetResetSessionResponse() *ResetSessionResponse

func (*Response) GetRunTask added in v1.1.1 

func (m *Response) GetRunTask() *RunTaskResponse

func (*Response) GetSetProtocolVersion added in v1.1.0 

func (m *Response) GetSetProtocolVersion() *SetProtocolVersionResponse

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"`
}

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"`
}

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"`
}

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

type SetProtocolVersionRequest struct {
	// ProtocolVersion is the version of the protocol
	Version int64 `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
}

func (*SetProtocolVersionRequest) Descriptor added in v1.1.0 

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

func (*SetProtocolVersionRequest) GetVersion added in v1.1.0 

func (m *SetProtocolVersionRequest) GetVersion() int64

func (*SetProtocolVersionRequest) Marshal added in v1.1.0 

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

func (*SetProtocolVersionRequest) MarshalTo added in v1.1.0 

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

func (*SetProtocolVersionRequest) MarshalToSizedBuffer added in v1.1.0 

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

func (*SetProtocolVersionRequest) ProtoMessage added in v1.1.0 

func (*SetProtocolVersionRequest) ProtoMessage()

func (*SetProtocolVersionRequest) Reset added in v1.1.0 

func (m *SetProtocolVersionRequest) Reset()

func (*SetProtocolVersionRequest) Size added in v1.1.0 

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

func (*SetProtocolVersionRequest) String added in v1.1.0 

func (m *SetProtocolVersionRequest) String() string

func (*SetProtocolVersionRequest) Unmarshal added in v1.1.0 

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

func (*SetProtocolVersionRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *SetProtocolVersionRequest) XXX_DiscardUnknown()

func (*SetProtocolVersionRequest) XXX_Marshal added in v1.1.0 

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

func (*SetProtocolVersionRequest) XXX_Merge added in v1.1.0 

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

func (*SetProtocolVersionRequest) XXX_Size added in v1.1.0 

func (m *SetProtocolVersionRequest) XXX_Size() int

func (*SetProtocolVersionRequest) XXX_Unmarshal added in v1.1.0 

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

type SetProtocolVersionResponse added in v1.1.0 

type SetProtocolVersionResponse struct {
	// ProtocolVersion is the version of the protocol
	Version int64 `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
}

func (*SetProtocolVersionResponse) Descriptor added in v1.1.0 

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

func (*SetProtocolVersionResponse) GetVersion added in v1.1.0 

func (m *SetProtocolVersionResponse) GetVersion() int64

func (*SetProtocolVersionResponse) Marshal added in v1.1.0 

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

func (*SetProtocolVersionResponse) MarshalTo added in v1.1.0 

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

func (*SetProtocolVersionResponse) MarshalToSizedBuffer added in v1.1.0 

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

func (*SetProtocolVersionResponse) ProtoMessage added in v1.1.0 

func (*SetProtocolVersionResponse) ProtoMessage()

func (*SetProtocolVersionResponse) Reset added in v1.1.0 

func (m *SetProtocolVersionResponse) Reset()

func (*SetProtocolVersionResponse) Size added in v1.1.0 

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

func (*SetProtocolVersionResponse) String added in v1.1.0 

func (m *SetProtocolVersionResponse) String() string

func (*SetProtocolVersionResponse) Unmarshal added in v1.1.0 

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

func (*SetProtocolVersionResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *SetProtocolVersionResponse) XXX_DiscardUnknown()

func (*SetProtocolVersionResponse) XXX_Marshal added in v1.1.0 

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

func (*SetProtocolVersionResponse) XXX_Merge added in v1.1.0 

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

func (*SetProtocolVersionResponse) XXX_Size added in v1.1.0 

func (m *SetProtocolVersionResponse) XXX_Size() int

func (*SetProtocolVersionResponse) XXX_Unmarshal added in v1.1.0 

func (m *SetProtocolVersionResponse) 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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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

type WrappedResponse added in v1.2.0 

type WrappedResponse struct {
	*Response
	ReleaseFunc func()
}

func (*WrappedResponse) Reset added in v1.2.0 

func (r *WrappedResponse) Reset()

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.