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)

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.