network

package
v2.1.27 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2021 License: MIT Imports: 11 Imported by: 7

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 uint32
	SessionDataUnitSize   uint32
	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

	SNOConfig    map[string]string
	PrefetchRows int
	// 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 {
	Packet
	// 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.IStringConverter
	UseBigClrChunks bool
	ClrChunkSize    int
	// 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) GetString 

func (session *Session) GetString(length int) (string, 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) PutString 

func (session *Session) PutString(data string)

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 {
	//conn net.Conn
	ConnOption *ConnectionOption
	//PortNo int
	//InstanceName string
	//HostName string
	//IPAddress string
	//Protocol string
	//ServiceName string
	SID []byte
	//ConnectData string
	Version           uint16
	LoVersion         uint16
	Options           uint16
	NegotiatedOptions uint16
	OurOne            uint16
	Histone           uint16
	ReconAddr         string

	ACFL0               uint8
	ACFL1               uint8
	SessionDataUnit     uint32
	TransportDataUnit   uint32
	UsingAsyncReceivers bool
	IsNTConnected       bool
	OnBreakReset        bool
	GotReset            bool
	AdvancedService     struct {
		CryptAlgo  security.OracleNetworkEncryption
		HashAlgo   security.OracleNetworkDataIntegrity
		SessionKey []byte
		IV         []byte
	}
	// 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

Directories

Path Synopsis

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.