mysqlProxy

type AuthorizationPacket struct {
	PacketPart1 []byte
	Username    []byte
	Password    []byte
	CapData     []byte
	CapData2    []byte
	PacketPart2 []byte
	// contains filtered or unexported fields
}

type CapabilityFlag uint32

type Connection struct {
	JmsService *service.JMService
	FakeServer *FakeServer
	Finished   *chan struct{}
	// contains filtered or unexported fields
}

type CurrSession struct {
	CreateSessionCallback    func() error
	ConnectedSuccessCallback func() error
	ConnectedFailedCallback  func(err error) error
	DisConnectedCallback     func() error
	SwSess                   *proxy.SwitchSession
	// contains filtered or unexported fields
}

type FakeHandshakePacket struct {
	Protocol                   byte
	Version                    []byte
	ThreadId                   []byte
	Salt                       []byte
	ServerCapabilities         []byte
	ServerLanguage             byte
	ServerStatus               []byte
	ExtendedServerCapabilities []byte
	AuthenticationPluginLength byte
	Unused                     []byte
	Salt2                      []byte
	AuthenticationPlugin       []byte
	// contains filtered or unexported fields
}

type FakeServer struct {
	Conn        net.Conn
	JmsService  *service.JMService
	Host        string
	Port        int
	Username    string
	Password    string
	CurrSession *CurrSession
	Token       *service.TokenAuthInfoResponse
}

type InitialHandshakePacket struct {
	ProtocolVersion   uint8
	ServerVersion     []byte
	ConnectionId      uint32
	AuthPluginData    []byte
	Filler            byte
	CapabilitiesFlags CapabilityFlag
	CharacterSet      uint8
	StatusFlags       uint16
	AuthPluginDataLen uint8
	AuthPluginName    []byte
	// contains filtered or unexported fields
}

type PacketHeader struct {
	Length     uint32
	SequenceId uint8
}

type Proxy struct {
	// contains filtered or unexported fields
}

type Request struct {
	// contains filtered or unexported fields
}

type Response struct {
	// contains filtered or unexported fields
}