status

package
v1.2.4 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStatus        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatus          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStatus = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SessionField_name = map[int32]string{
	0:  "NODE_ID",
	1:  "CONN_ID",
	2:  "SESSION_ID",
	3:  "ACCOUNT",
	4:  "USER",
	5:  "HOST",
	6:  "DB",
	7:  "SESSION_START",
	8:  "COMMAND",
	9:  "INFO",
	10: "TXN_ID",
	11: "STATEMENT_ID",
	12: "STATEMENT_TYPE",
	13: "QUERY_TYPE",
	14: "SQL_SOURCE_TYPE",
	15: "QUERY_START",
	16: "CLIENT_HOST",
	17: "ROLE",
	18: "PROXY_HOST",
}
View Source 
var SessionField_value = map[string]int32{
	"NODE_ID":         0,
	"CONN_ID":         1,
	"SESSION_ID":      2,
	"ACCOUNT":         3,
	"USER":            4,
	"HOST":            5,
	"DB":              6,
	"SESSION_START":   7,
	"COMMAND":         8,
	"INFO":            9,
	"TXN_ID":          10,
	"STATEMENT_ID":    11,
	"STATEMENT_TYPE":  12,
	"QUERY_TYPE":      13,
	"SQL_SOURCE_TYPE": 14,
	"QUERY_START":     15,
	"CLIENT_HOST":     16,
	"ROLE":            17,
	"PROXY_HOST":      18,
}

Functions

This section is empty.

Types

type Session 

type Session struct {
	// NodeID is the ID of CN node/service.
	NodeID string `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	// ConnID is the connection ID of backend server.
	ConnID uint32 `protobuf:"varint,2,opt,name=ConnID,proto3" json:"ConnID,omitempty"`
	// SessionID is the session ID.
	SessionID string `protobuf:"bytes,3,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	// Account is the tenant name.
	Account string `protobuf:"bytes,4,opt,name=Account,proto3" json:"Account,omitempty"`
	// User is the username.
	User string `protobuf:"bytes,5,opt,name=User,proto3" json:"User,omitempty"`
	// Host is the host name/address and port.
	Host string `protobuf:"bytes,6,opt,name=Host,proto3" json:"Host,omitempty"`
	// DB is the database name.
	DB string `protobuf:"bytes,7,opt,name=DB,proto3" json:"DB,omitempty"`
	// SessionStart is the start time of this session.
	SessionStart time.Time `protobuf:"bytes,8,opt,name=SessionStart,proto3,stdtime" json:"SessionStart"`
	// Command is the command type.
	Command string `protobuf:"bytes,9,opt,name=Command,proto3" json:"Command,omitempty"`
	// Info is the current SQL statement.
	Info string `protobuf:"bytes,10,opt,name=Info,proto3" json:"Info,omitempty"`
	// TxnID is the current transaction ID of the session.
	TxnID string `protobuf:"bytes,11,opt,name=TxnID,proto3" json:"TxnID,omitempty"`
	// StatementID is the last statement ID of the session.
	StatementID string `protobuf:"bytes,12,opt,name=StatementID,proto3" json:"StatementID,omitempty"`
	// StatementType is the type of the statement: Insert, Update, Delete, Execute, Select.
	StatementType string `protobuf:"bytes,13,opt,name=StatementType,proto3" json:"StatementType,omitempty"`
	// QueryType is the type of the query: DDL, DML, DQL ...
	QueryType string `protobuf:"bytes,14,opt,name=QueryType,proto3" json:"QueryType,omitempty"`
	// SQLSourceType is the SQL source type: internal_sql, cloud_nonuser_sql, external_sql, cloud_user_sql.
	SQLSourceType string `protobuf:"bytes,15,opt,name=SQLSourceType,proto3" json:"SQLSourceType,omitempty"`
	// QueryStart is the start time of query.
	QueryStart time.Time `protobuf:"bytes,16,opt,name=QueryStart,proto3,stdtime" json:"QueryStart"`
	// ClientHost is the ip:port of client.
	ClientHost string `protobuf:"bytes,17,opt,name=ClientHost,proto3" json:"ClientHost,omitempty"`
	// Role of the user
	Role string `protobuf:"bytes,18,opt,name=Role,proto3" json:"Role,omitempty"`
	// FromProxy denotes whether the session is dispatched from proxy
	FromProxy bool `protobuf:"varint,19,opt,name=FromProxy,proto3" json:"FromProxy,omitempty"`
	// ProxyHost is the host address of proxy connection.
	ProxyHost            string   `protobuf:"bytes,20,opt,name=ProxyHost,proto3" json:"ProxyHost,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Session is the information of a session.

func (*Session) Descriptor 

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

func (*Session) GetAccount 

func (m *Session) GetAccount() string

func (*Session) GetClientHost 

func (m *Session) GetClientHost() string

func (*Session) GetCommand 

func (m *Session) GetCommand() string

func (*Session) GetConnID 

func (m *Session) GetConnID() uint32

func (*Session) GetDB 

func (m *Session) GetDB() string

func (*Session) GetFromProxy added in v1.1.2 

func (m *Session) GetFromProxy() bool

func (*Session) GetHost 

func (m *Session) GetHost() string

func (*Session) GetInfo 

func (m *Session) GetInfo() string

func (*Session) GetNodeID 

func (m *Session) GetNodeID() string

func (*Session) GetProxyHost added in v1.1.3 

func (m *Session) GetProxyHost() string

func (*Session) GetQueryStart 

func (m *Session) GetQueryStart() time.Time

func (*Session) GetQueryType 

func (m *Session) GetQueryType() string

func (*Session) GetRole 

func (m *Session) GetRole() string

func (*Session) GetSQLSourceType 

func (m *Session) GetSQLSourceType() string

func (*Session) GetSessionID 

func (m *Session) GetSessionID() string

func (*Session) GetSessionStart 

func (m *Session) GetSessionStart() time.Time

func (*Session) GetStatementID 

func (m *Session) GetStatementID() string

func (*Session) GetStatementType 

func (m *Session) GetStatementType() string

func (*Session) GetTxnID 

func (m *Session) GetTxnID() string

func (*Session) GetUser 

func (m *Session) GetUser() string

func (*Session) Marshal 

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

func (*Session) MarshalTo 

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

func (*Session) MarshalToSizedBuffer 

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

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) Size 

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

func (*Session) String 

func (m *Session) String() string

func (*Session) Unmarshal 

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

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type SessionField 

type SessionField int32
const (
	SessionField_NODE_ID         SessionField = 0
	SessionField_CONN_ID         SessionField = 1
	SessionField_SESSION_ID      SessionField = 2
	SessionField_ACCOUNT         SessionField = 3
	SessionField_USER            SessionField = 4
	SessionField_HOST            SessionField = 5
	SessionField_DB              SessionField = 6
	SessionField_SESSION_START   SessionField = 7
	SessionField_COMMAND         SessionField = 8
	SessionField_INFO            SessionField = 9
	SessionField_TXN_ID          SessionField = 10
	SessionField_STATEMENT_ID    SessionField = 11
	SessionField_STATEMENT_TYPE  SessionField = 12
	SessionField_QUERY_TYPE      SessionField = 13
	SessionField_SQL_SOURCE_TYPE SessionField = 14
	SessionField_QUERY_START     SessionField = 15
	SessionField_CLIENT_HOST     SessionField = 16
	SessionField_ROLE            SessionField = 17
	SessionField_PROXY_HOST      SessionField = 18
)

func (SessionField) EnumDescriptor 

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

func (SessionField) String 

func (x SessionField) String() string

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.