goxstream

package module
v0.0.0-...-fd3b81d Latest Latest
Warning

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

Go to latest
Published: May 22, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

README

goxstream

go binding for oracle xstream api, using cgo and OCI

Documentation

Index

Constants

View Source
const (
	V1 = 1
	V2 = 2
)

Variables

This section is empty.

Functions

func ToCUCharString

func ToCUCharString(str string) (*C.uchar, C.ushort, func())

Types

type Commit

type Commit struct {
	SCN scn.SCN
}

func (*Commit) Scn

func (c *Commit) Scn() scn.SCN

func (*Commit) String

func (c *Commit) String() string

type Delete

type Delete struct {
	SCN       scn.SCN
	OldColumn []string
	OldRow    []interface{}
	Table     string
	Owner     string
}

func (*Delete) Scn

func (c *Delete) Scn() scn.SCN

func (*Delete) String

func (c *Delete) String() string

type HeartBeat

type HeartBeat struct {
	SCN scn.SCN
}

func (*HeartBeat) Scn

func (h *HeartBeat) Scn() scn.SCN

func (*HeartBeat) String

func (h *HeartBeat) String() string

type Insert

type Insert struct {
	SCN       scn.SCN
	NewColumn []string
	NewRow    []interface{}
	Table     string
	Owner     string
}

func (*Insert) Scn

func (c *Insert) Scn() scn.SCN

func (*Insert) String

func (c *Insert) String() string

type Message

type Message interface {
	Scn() scn.SCN
	String() string
}

type OCI_LCRID_VERSION

type OCI_LCRID_VERSION int

type Update

type Update struct {
	SCN       scn.SCN
	NewColumn []string
	NewRow    []interface{}
	OldColumn []string
	OldRow    []interface{}
	Table     string
	Owner     string
}

func (*Update) Scn

func (c *Update) Scn() scn.SCN

func (*Update) String

func (c *Update) String() string

type XStreamConn

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

func Open

func Open(username, password, dbname, servername string, oracleVer int) (*XStreamConn, error)

func (*XStreamConn) Close

func (x *XStreamConn) Close() error

func (*XStreamConn) GetRecord

func (x *XStreamConn) GetRecord() (Message, error)

func (*XStreamConn) SetSCNLwm

func (x *XStreamConn) SetSCNLwm(s scn.SCN) error

Directories

Path Synopsis
ported from https://github.com/felipenoris/Oracle.jl/blob/master/src/oranumbers/encoding.jl
ported from https://github.com/felipenoris/Oracle.jl/blob/master/src/oranumbers/encoding.jl

Jump to

Keyboard shortcuts

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