Documentation ¶
Index ¶
- Variables
- type AlterAccountRequest
- func (*AlterAccountRequest) Descriptor() ([]byte, []int)
- func (m *AlterAccountRequest) GetStatus() string
- func (m *AlterAccountRequest) GetTenantId() int64
- func (m *AlterAccountRequest) Marshal() (dAtA []byte, err error)
- func (m *AlterAccountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AlterAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AlterAccountRequest) ProtoMessage()
- func (m *AlterAccountRequest) Reset()
- func (m *AlterAccountRequest) Size() (n int)
- func (m *AlterAccountRequest) String() string
- func (m *AlterAccountRequest) Unmarshal(dAtA []byte) error
- func (m *AlterAccountRequest) XXX_DiscardUnknown()
- func (m *AlterAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AlterAccountRequest) XXX_Merge(src proto.Message)
- func (m *AlterAccountRequest) XXX_Size() int
- func (m *AlterAccountRequest) XXX_Unmarshal(b []byte) error
- type AlterAccountResponse
- func (*AlterAccountResponse) Descriptor() ([]byte, []int)
- func (m *AlterAccountResponse) GetAlterSuccess() bool
- func (m *AlterAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *AlterAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AlterAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AlterAccountResponse) ProtoMessage()
- func (m *AlterAccountResponse) Reset()
- func (m *AlterAccountResponse) Size() (n int)
- func (m *AlterAccountResponse) String() string
- func (m *AlterAccountResponse) Unmarshal(dAtA []byte) error
- func (m *AlterAccountResponse) XXX_DiscardUnknown()
- func (m *AlterAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AlterAccountResponse) XXX_Merge(src proto.Message)
- func (m *AlterAccountResponse) XXX_Size() int
- func (m *AlterAccountResponse) XXX_Unmarshal(b []byte) error
- type CmdMethod
- type KillConnRequest
- func (*KillConnRequest) Descriptor() ([]byte, []int)
- func (m *KillConnRequest) GetAccountID() int64
- func (m *KillConnRequest) GetVersion() uint64
- func (m *KillConnRequest) Marshal() (dAtA []byte, err error)
- func (m *KillConnRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *KillConnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KillConnRequest) ProtoMessage()
- func (m *KillConnRequest) Reset()
- func (m *KillConnRequest) Size() (n int)
- func (m *KillConnRequest) String() string
- func (m *KillConnRequest) Unmarshal(dAtA []byte) error
- func (m *KillConnRequest) XXX_DiscardUnknown()
- func (m *KillConnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KillConnRequest) XXX_Merge(src proto.Message)
- func (m *KillConnRequest) XXX_Size() int
- func (m *KillConnRequest) XXX_Unmarshal(b []byte) error
- type KillConnResponse
- func (*KillConnResponse) Descriptor() ([]byte, []int)
- func (m *KillConnResponse) GetSuccess() bool
- func (m *KillConnResponse) Marshal() (dAtA []byte, err error)
- func (m *KillConnResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *KillConnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KillConnResponse) ProtoMessage()
- func (m *KillConnResponse) Reset()
- func (m *KillConnResponse) Size() (n int)
- func (m *KillConnResponse) String() string
- func (m *KillConnResponse) Unmarshal(dAtA []byte) error
- func (m *KillConnResponse) XXX_DiscardUnknown()
- func (m *KillConnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KillConnResponse) XXX_Merge(src proto.Message)
- func (m *KillConnResponse) XXX_Size() int
- func (m *KillConnResponse) XXX_Unmarshal(b []byte) error
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (m *QueryRequest) GetQuery() string
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- func (m *QueryRequest) XXX_DiscardUnknown()
- func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryRequest) XXX_Merge(src proto.Message)
- func (m *QueryRequest) XXX_Size() int
- func (m *QueryRequest) XXX_Unmarshal(b []byte) error
- type Request
- func (m *Request) DebugString() string
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetAlterAccountRequest() *AlterAccountRequest
- func (m *Request) GetCmdMethod() CmdMethod
- func (m *Request) GetID() uint64
- func (m *Request) GetKillConnRequest() *KillConnRequest
- func (m *Request) GetQueryRequest() *QueryRequest
- func (m *Request) GetRequestID() uint64
- func (m *Request) GetShowProcessListRequest() *ShowProcessListRequest
- func (m *Request) Marshal() (dAtA []byte, err error)
- func (m *Request) MarshalTo(dAtA []byte) (int, error)
- func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Request) Method() uint32
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) SetID(id uint64)
- func (m *Request) SetMethod(v uint32)
- func (m *Request) Size() (n int)
- func (m *Request) String() string
- func (m *Request) Unmarshal(dAtA []byte) error
- func (m *Request) UnwrapError() error
- func (m *Request) WrapError(err error)
- func (m *Request) XXX_DiscardUnknown()
- func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Request) XXX_Merge(src proto.Message)
- func (m *Request) XXX_Size() int
- func (m *Request) XXX_Unmarshal(b []byte) error
- type Response
- func (m *Response) DebugString() string
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetAlterAccountResponse() *AlterAccountResponse
- func (m *Response) GetCmdMethod() CmdMethod
- func (m *Response) GetError() []byte
- func (m *Response) GetID() uint64
- func (m *Response) GetKillConnResponse() *KillConnResponse
- func (m *Response) GetRequestID() uint64
- func (m *Response) GetShowProcessListResponse() *ShowProcessListResponse
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Response) Method() uint32
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) SetID(id uint64)
- func (m *Response) SetMethod(v uint32)
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- func (m *Response) UnwrapError() error
- func (m *Response) WrapError(err error)
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type ShowProcessListRequest
- func (*ShowProcessListRequest) Descriptor() ([]byte, []int)
- func (m *ShowProcessListRequest) GetSysTenant() bool
- func (m *ShowProcessListRequest) GetTenant() string
- func (m *ShowProcessListRequest) Marshal() (dAtA []byte, err error)
- func (m *ShowProcessListRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ShowProcessListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShowProcessListRequest) ProtoMessage()
- func (m *ShowProcessListRequest) Reset()
- func (m *ShowProcessListRequest) Size() (n int)
- func (m *ShowProcessListRequest) String() string
- func (m *ShowProcessListRequest) Unmarshal(dAtA []byte) error
- func (m *ShowProcessListRequest) XXX_DiscardUnknown()
- func (m *ShowProcessListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowProcessListRequest) XXX_Merge(src proto.Message)
- func (m *ShowProcessListRequest) XXX_Size() int
- func (m *ShowProcessListRequest) XXX_Unmarshal(b []byte) error
- type ShowProcessListResponse
- func (*ShowProcessListResponse) Descriptor() ([]byte, []int)
- func (m *ShowProcessListResponse) GetSessions() []*status.Session
- func (m *ShowProcessListResponse) Marshal() (dAtA []byte, err error)
- func (m *ShowProcessListResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ShowProcessListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShowProcessListResponse) ProtoMessage()
- func (m *ShowProcessListResponse) Reset()
- func (m *ShowProcessListResponse) Size() (n int)
- func (m *ShowProcessListResponse) String() string
- func (m *ShowProcessListResponse) Unmarshal(dAtA []byte) error
- func (m *ShowProcessListResponse) XXX_DiscardUnknown()
- func (m *ShowProcessListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowProcessListResponse) XXX_Merge(src proto.Message)
- func (m *ShowProcessListResponse) XXX_Size() int
- func (m *ShowProcessListResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var CmdMethod_name = map[int32]string{
0: "Query",
1: "ShowProcessList",
2: "AlterAccount",
3: "KillConn",
}
var CmdMethod_value = map[string]int32{
"Query": 0,
"ShowProcessList": 1,
"AlterAccount": 2,
"KillConn": 3,
}
Functions ¶
This section is empty.
Types ¶
type AlterAccountRequest ¶
type AlterAccountRequest struct { // Tenant is the tenant which to alter. TenantId int64 `protobuf:"varint,1,opt,name=TenantId,proto3" json:"TenantId,omitempty"` // Status is the tenant which will be alter to. Status string `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AlterAccountRequest is the "alter account restricted" query request.
func (*AlterAccountRequest) Descriptor ¶
func (*AlterAccountRequest) Descriptor() ([]byte, []int)
func (*AlterAccountRequest) GetStatus ¶
func (m *AlterAccountRequest) GetStatus() string
func (*AlterAccountRequest) GetTenantId ¶
func (m *AlterAccountRequest) GetTenantId() int64
func (*AlterAccountRequest) Marshal ¶
func (m *AlterAccountRequest) Marshal() (dAtA []byte, err error)
func (*AlterAccountRequest) MarshalTo ¶
func (m *AlterAccountRequest) MarshalTo(dAtA []byte) (int, error)
func (*AlterAccountRequest) MarshalToSizedBuffer ¶
func (m *AlterAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AlterAccountRequest) ProtoMessage ¶
func (*AlterAccountRequest) ProtoMessage()
func (*AlterAccountRequest) Reset ¶
func (m *AlterAccountRequest) Reset()
func (*AlterAccountRequest) Size ¶
func (m *AlterAccountRequest) Size() (n int)
func (*AlterAccountRequest) String ¶
func (m *AlterAccountRequest) String() string
func (*AlterAccountRequest) Unmarshal ¶
func (m *AlterAccountRequest) Unmarshal(dAtA []byte) error
func (*AlterAccountRequest) XXX_DiscardUnknown ¶
func (m *AlterAccountRequest) XXX_DiscardUnknown()
func (*AlterAccountRequest) XXX_Marshal ¶
func (m *AlterAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterAccountRequest) XXX_Merge ¶
func (m *AlterAccountRequest) XXX_Merge(src proto.Message)
func (*AlterAccountRequest) XXX_Size ¶
func (m *AlterAccountRequest) XXX_Size() int
func (*AlterAccountRequest) XXX_Unmarshal ¶
func (m *AlterAccountRequest) XXX_Unmarshal(b []byte) error
type AlterAccountResponse ¶
type AlterAccountResponse struct { AlterSuccess bool `protobuf:"varint,1,opt,name=alterSuccess,proto3" json:"alterSuccess,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AlterAccountResponse is the response of command AlterAccount.
func (*AlterAccountResponse) Descriptor ¶
func (*AlterAccountResponse) Descriptor() ([]byte, []int)
func (*AlterAccountResponse) GetAlterSuccess ¶
func (m *AlterAccountResponse) GetAlterSuccess() bool
func (*AlterAccountResponse) Marshal ¶
func (m *AlterAccountResponse) Marshal() (dAtA []byte, err error)
func (*AlterAccountResponse) MarshalTo ¶
func (m *AlterAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*AlterAccountResponse) MarshalToSizedBuffer ¶
func (m *AlterAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AlterAccountResponse) ProtoMessage ¶
func (*AlterAccountResponse) ProtoMessage()
func (*AlterAccountResponse) Reset ¶
func (m *AlterAccountResponse) Reset()
func (*AlterAccountResponse) Size ¶
func (m *AlterAccountResponse) Size() (n int)
func (*AlterAccountResponse) String ¶
func (m *AlterAccountResponse) String() string
func (*AlterAccountResponse) Unmarshal ¶
func (m *AlterAccountResponse) Unmarshal(dAtA []byte) error
func (*AlterAccountResponse) XXX_DiscardUnknown ¶
func (m *AlterAccountResponse) XXX_DiscardUnknown()
func (*AlterAccountResponse) XXX_Marshal ¶
func (m *AlterAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterAccountResponse) XXX_Merge ¶
func (m *AlterAccountResponse) XXX_Merge(src proto.Message)
func (*AlterAccountResponse) XXX_Size ¶
func (m *AlterAccountResponse) XXX_Size() int
func (*AlterAccountResponse) XXX_Unmarshal ¶
func (m *AlterAccountResponse) XXX_Unmarshal(b []byte) error
type 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 )
func (CmdMethod) EnumDescriptor ¶
type KillConnRequest ¶
type KillConnRequest struct { AccountID int64 `protobuf:"varint,1,opt,name=AccountID,proto3" json:"AccountID,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=Version,proto3" json:"Version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KillConnRequest is the request that kill the connections belongs to the account.
func (*KillConnRequest) Descriptor ¶
func (*KillConnRequest) Descriptor() ([]byte, []int)
func (*KillConnRequest) GetAccountID ¶
func (m *KillConnRequest) GetAccountID() int64
func (*KillConnRequest) GetVersion ¶
func (m *KillConnRequest) GetVersion() uint64
func (*KillConnRequest) Marshal ¶
func (m *KillConnRequest) Marshal() (dAtA []byte, err error)
func (*KillConnRequest) MarshalToSizedBuffer ¶
func (m *KillConnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KillConnRequest) ProtoMessage ¶
func (*KillConnRequest) ProtoMessage()
func (*KillConnRequest) Reset ¶
func (m *KillConnRequest) Reset()
func (*KillConnRequest) Size ¶
func (m *KillConnRequest) Size() (n int)
func (*KillConnRequest) String ¶
func (m *KillConnRequest) String() string
func (*KillConnRequest) Unmarshal ¶
func (m *KillConnRequest) Unmarshal(dAtA []byte) error
func (*KillConnRequest) XXX_DiscardUnknown ¶
func (m *KillConnRequest) XXX_DiscardUnknown()
func (*KillConnRequest) XXX_Marshal ¶
func (m *KillConnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KillConnRequest) XXX_Merge ¶
func (m *KillConnRequest) XXX_Merge(src proto.Message)
func (*KillConnRequest) XXX_Size ¶
func (m *KillConnRequest) XXX_Size() int
func (*KillConnRequest) XXX_Unmarshal ¶
func (m *KillConnRequest) XXX_Unmarshal(b []byte) error
type KillConnResponse ¶
type KillConnResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KillConnResponse is the response to the kill connection request.
func (*KillConnResponse) Descriptor ¶
func (*KillConnResponse) Descriptor() ([]byte, []int)
func (*KillConnResponse) GetSuccess ¶
func (m *KillConnResponse) GetSuccess() bool
func (*KillConnResponse) Marshal ¶
func (m *KillConnResponse) Marshal() (dAtA []byte, err error)
func (*KillConnResponse) MarshalToSizedBuffer ¶
func (m *KillConnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KillConnResponse) ProtoMessage ¶
func (*KillConnResponse) ProtoMessage()
func (*KillConnResponse) Reset ¶
func (m *KillConnResponse) Reset()
func (*KillConnResponse) Size ¶
func (m *KillConnResponse) Size() (n int)
func (*KillConnResponse) String ¶
func (m *KillConnResponse) String() string
func (*KillConnResponse) Unmarshal ¶
func (m *KillConnResponse) Unmarshal(dAtA []byte) error
func (*KillConnResponse) XXX_DiscardUnknown ¶
func (m *KillConnResponse) XXX_DiscardUnknown()
func (*KillConnResponse) XXX_Marshal ¶
func (m *KillConnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KillConnResponse) XXX_Merge ¶
func (m *KillConnResponse) XXX_Merge(src proto.Message)
func (*KillConnResponse) XXX_Size ¶
func (m *KillConnResponse) XXX_Size() int
func (*KillConnResponse) XXX_Unmarshal ¶
func (m *KillConnResponse) XXX_Unmarshal(b []byte) error
type QueryRequest ¶
type QueryRequest struct { // Query is the query statement. Query string `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
QueryRequest is the common query request. It contains the query statement that need to be executed on the specified CN node.
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) GetQuery ¶
func (m *QueryRequest) GetQuery() string
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) MarshalToSizedBuffer ¶
func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
func (*QueryRequest) XXX_DiscardUnknown ¶
func (m *QueryRequest) XXX_DiscardUnknown()
func (*QueryRequest) XXX_Marshal ¶
func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryRequest) XXX_Merge ¶
func (m *QueryRequest) XXX_Merge(src proto.Message)
func (*QueryRequest) XXX_Size ¶
func (m *QueryRequest) XXX_Size() int
func (*QueryRequest) XXX_Unmarshal ¶
func (m *QueryRequest) XXX_Unmarshal(b []byte) error
type 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request is the query request.
func (*Request) DebugString ¶
DebugString implements the morpc.Message interface.
func (*Request) Descriptor ¶
func (*Request) GetAlterAccountRequest ¶
func (m *Request) GetAlterAccountRequest() *AlterAccountRequest
func (*Request) GetCmdMethod ¶
func (*Request) GetKillConnRequest ¶
func (m *Request) GetKillConnRequest() *KillConnRequest
func (*Request) GetQueryRequest ¶
func (m *Request) GetQueryRequest() *QueryRequest
func (*Request) GetRequestID ¶
func (*Request) GetShowProcessListRequest ¶
func (m *Request) GetShowProcessListRequest() *ShowProcessListRequest
func (*Request) MarshalToSizedBuffer ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) UnwrapError ¶
UnwrapError implements the morpc.MethodBasedMessage interface.
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response is the response to query request.
func (*Response) DebugString ¶
DebugString implements the morpc.Message interface.
func (*Response) Descriptor ¶
func (*Response) GetAlterAccountResponse ¶
func (m *Response) GetAlterAccountResponse() *AlterAccountResponse
func (*Response) GetCmdMethod ¶
func (*Response) GetKillConnResponse ¶
func (m *Response) GetKillConnResponse() *KillConnResponse
func (*Response) GetRequestID ¶
func (*Response) GetShowProcessListResponse ¶
func (m *Response) GetShowProcessListResponse() *ShowProcessListResponse
func (*Response) MarshalToSizedBuffer ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) UnwrapError ¶
UnwrapError implements the morpc.MethodBasedMessage interface.
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_Unmarshal ¶
type ShowProcessListRequest ¶
type ShowProcessListRequest struct { // Tenant is the tenant which the processes belong to. Tenant string `protobuf:"bytes,1,opt,name=Tenant,proto3" json:"Tenant,omitempty"` // SysTenet is true if the tenant is a system tenant. SysTenant bool `protobuf:"varint,2,opt,name=SysTenant,proto3" json:"SysTenant,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShowProcessListRequest is the "show process list" query request.
func (*ShowProcessListRequest) Descriptor ¶
func (*ShowProcessListRequest) Descriptor() ([]byte, []int)
func (*ShowProcessListRequest) GetSysTenant ¶
func (m *ShowProcessListRequest) GetSysTenant() bool
func (*ShowProcessListRequest) GetTenant ¶
func (m *ShowProcessListRequest) GetTenant() string
func (*ShowProcessListRequest) Marshal ¶
func (m *ShowProcessListRequest) Marshal() (dAtA []byte, err error)
func (*ShowProcessListRequest) MarshalTo ¶
func (m *ShowProcessListRequest) MarshalTo(dAtA []byte) (int, error)
func (*ShowProcessListRequest) MarshalToSizedBuffer ¶
func (m *ShowProcessListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShowProcessListRequest) ProtoMessage ¶
func (*ShowProcessListRequest) ProtoMessage()
func (*ShowProcessListRequest) Reset ¶
func (m *ShowProcessListRequest) Reset()
func (*ShowProcessListRequest) Size ¶
func (m *ShowProcessListRequest) Size() (n int)
func (*ShowProcessListRequest) String ¶
func (m *ShowProcessListRequest) String() string
func (*ShowProcessListRequest) Unmarshal ¶
func (m *ShowProcessListRequest) Unmarshal(dAtA []byte) error
func (*ShowProcessListRequest) XXX_DiscardUnknown ¶
func (m *ShowProcessListRequest) XXX_DiscardUnknown()
func (*ShowProcessListRequest) XXX_Marshal ¶
func (m *ShowProcessListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowProcessListRequest) XXX_Merge ¶
func (m *ShowProcessListRequest) XXX_Merge(src proto.Message)
func (*ShowProcessListRequest) XXX_Size ¶
func (m *ShowProcessListRequest) XXX_Size() int
func (*ShowProcessListRequest) XXX_Unmarshal ¶
func (m *ShowProcessListRequest) XXX_Unmarshal(b []byte) error
type ShowProcessListResponse ¶
type ShowProcessListResponse struct { Sessions []*status.Session `protobuf:"bytes,1,rep,name=Sessions,proto3" json:"Sessions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShowProcessListResponse is the response of command ShowProcessList.
func (*ShowProcessListResponse) Descriptor ¶
func (*ShowProcessListResponse) Descriptor() ([]byte, []int)
func (*ShowProcessListResponse) GetSessions ¶
func (m *ShowProcessListResponse) GetSessions() []*status.Session
func (*ShowProcessListResponse) Marshal ¶
func (m *ShowProcessListResponse) Marshal() (dAtA []byte, err error)
func (*ShowProcessListResponse) MarshalTo ¶
func (m *ShowProcessListResponse) MarshalTo(dAtA []byte) (int, error)
func (*ShowProcessListResponse) MarshalToSizedBuffer ¶
func (m *ShowProcessListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShowProcessListResponse) ProtoMessage ¶
func (*ShowProcessListResponse) ProtoMessage()
func (*ShowProcessListResponse) Reset ¶
func (m *ShowProcessListResponse) Reset()
func (*ShowProcessListResponse) Size ¶
func (m *ShowProcessListResponse) Size() (n int)
func (*ShowProcessListResponse) String ¶
func (m *ShowProcessListResponse) String() string
func (*ShowProcessListResponse) Unmarshal ¶
func (m *ShowProcessListResponse) Unmarshal(dAtA []byte) error
func (*ShowProcessListResponse) XXX_DiscardUnknown ¶
func (m *ShowProcessListResponse) XXX_DiscardUnknown()
func (*ShowProcessListResponse) XXX_Marshal ¶
func (m *ShowProcessListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowProcessListResponse) XXX_Merge ¶
func (m *ShowProcessListResponse) XXX_Merge(src proto.Message)
func (*ShowProcessListResponse) XXX_Size ¶
func (m *ShowProcessListResponse) XXX_Size() int
func (*ShowProcessListResponse) XXX_Unmarshal ¶
func (m *ShowProcessListResponse) XXX_Unmarshal(b []byte) error