network

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Feb 5, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultAddress string = "(Description=(Address=(Protocol=tcp)(IP=loopback)(port=1521))(CONNECT_DATA=(SID="
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AcceptPacket

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

type AcceptPacket Packet

type AddressResolution

type AddressResolution struct {
	InstanceName string
	TNSAddress   string
}

type BindError

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

type ClientData

type ClientData struct {
	ProgramPath string
	ProgramName string
	UserName    string
	HostName    string
	DriverName  string
	PID         int
}

type ConnectPacket

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

type ConnectPacket Packet

type ConnectionOption

type ConnectionOption struct {
	Port                  int
	TransportConnectTo    int
	SSLVersion            string
	WalletDict            string
	TransportDataUnitSize uint16
	SessionDataUnitSize   uint16
	Protocol              string
	Host                  string
	UserID                string
	//IP string
	SID string
	//Addr string
	//Server string
	ServiceName  string
	InstanceName string
	DomainName   string
	DBName       string
	ClientData   ClientData
	//InAddrAny bool
	Tracer trace.Tracer
	// contains filtered or unexported fields
}

func (*ConnectionOption) ConnectionData

func (op *ConnectionOption) ConnectionData() string

type Data

type Data interface {
	Write(session *Session) error
	Read(session *Session) error
}

type DataPacket

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

type MarkerPacket

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

type Packet

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

type PacketInterface

type PacketInterface interface {
	// contains filtered or unexported methods
}

type PacketType

type PacketType uint8
const (
	CONNECT  PacketType = 1
	ACCEPT   PacketType = 2
	ACK      PacketType = 3
	REFUSE   PacketType = 4
	REDIRECT PacketType = 5
	DATA     PacketType = 6
	NULL     PacketType = 7
	ABORT    PacketType = 9
	RESEND   PacketType = 11
	MARKER   PacketType = 12
	ATTN     PacketType = 13
	CTRL     PacketType = 14
	HIGHEST  PacketType = 19
)

type RedirectPacket

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

type RefusePacket

type RefusePacket struct {

	//dataOffset uint16
	//Len uint16
	//packetType PacketType
	//Flag uint8
	SystemReason uint8
	UserReason   uint8
	// contains filtered or unexported fields
}

type Session

type Session struct {
	Context *SessionContext

	TimeZone          []byte
	TTCVersion        uint8
	HasEOSCapability  bool
	HasFSAPCapability bool
	Summary           *SummaryObject

	StrConv *converters.StringConverter
	// contains filtered or unexported fields
}

func NewSession

func NewSession(connOption ConnectionOption) *Session

func (*Session) Connect

func (session *Session) Connect() error

func (*Session) Debug

func (session *Session) Debug()

func (*Session) Disconnect

func (session *Session) Disconnect()

func (*Session) DumpIn

func (session *Session) DumpIn()

func (*Session) DumpOut

func (session *Session) DumpOut()

func (*Session) GetByte

func (session *Session) GetByte() (uint8, error)

func (*Session) GetBytes

func (session *Session) GetBytes(length int) ([]byte, error)

func (*Session) GetClr

func (session *Session) GetClr() (output []byte, err error)

func (*Session) GetData

func (session *Session) GetData(data Data) error

func (*Session) GetDlc

func (session *Session) GetDlc() (output []byte, err error)

func (*Session) GetError

func (session *Session) GetError() string

func (*Session) GetInt

func (session *Session) GetInt(size int, compress bool, bigEndian bool) (int, error)

func (*Session) GetInt64

func (session *Session) GetInt64(size int, compress bool, bigEndian bool) (int64, error)

func (*Session) GetKeyVal

func (session *Session) GetKeyVal() (key []byte, val []byte, num int, err error)

return key, val, int and error

func (*Session) GetNullTermString

func (session *Session) GetNullTermString(maxSize int) (result string, err error)

func (*Session) HasError

func (session *Session) HasError() bool

func (*Session) LoadState

func (session *Session) LoadState()

func (*Session) PutBytes

func (session *Session) PutBytes(data ...byte)

func (*Session) PutClr

func (session *Session) PutClr(data []byte)

func (*Session) PutData

func (session *Session) PutData(data Data) error

func (*Session) PutInt

func (session *Session) PutInt(number interface{}, size uint8, bigEndian bool, compress bool)

func (*Session) PutKeyVal

func (session *Session) PutKeyVal(key []byte, val []byte, num uint8)

func (*Session) PutKeyValString

func (session *Session) PutKeyValString(key string, val string, num uint8)

func (*Session) PutUint

func (session *Session) PutUint(number interface{}, size uint8, bigEndian bool, compress bool)

func (*Session) ResetBuffer

func (session *Session) ResetBuffer()

func (*Session) SaveState

func (session *Session) SaveState()

func (*Session) Write

func (session *Session) Write() error

type SessionContext

type SessionContext struct {

	//PortNo int
	//InstanceName string
	//HostName string
	//IPAddress string
	//Protocol string
	//ServiceName string
	SID []byte
	//internal Stream m_socketStream;
	//internal Socket m_socket;
	//internal ReaderStream m_readerStream;
	//internal WriterStream m_writerStream;
	//internal ITransportAdapter m_transportAdapter;
	//ConnectData string
	Version           uint16
	LoVersion         uint16
	Options           uint16
	NegotiatedOptions uint16
	OurOne            uint16
	Histone           uint16
	ReconAddr         string
	//internal Ano m_ano;
	//internal bool m_bAnoEnabled;
	ACFL0               uint8
	ACFL1               uint8
	SessionDataUnit     uint16
	TransportDataUnit   uint16
	UsingAsyncReceivers bool
	IsNTConnected       bool
	OnBreakReset        bool
	GotReset            bool
	// contains filtered or unexported fields
}

func NewSessionContext

func NewSessionContext(connOption ConnectionOption) *SessionContext

type SummaryObject

type SummaryObject struct {
	EndOfCallStatus      int // uint32
	EndToEndECIDSequence int // uint16
	CurRowNumber         int // uint32
	RetCode              int // uint16

	CursorID int // uint16

	Flags int // uint16

	ErrorMessage []byte
	// contains filtered or unexported fields
}

func NewSummary

func NewSummary(session *Session) (*SummaryObject, error)

type WarningObject

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

func NewWarningObject

func NewWarningObject(session *Session) (*WarningObject, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL