goxstream

README

goxstream

go binding for oracle xstream api, using cgo and OCI

Documentation

Index

• Constants
• func ToCUCharString(str string) (*C.uchar, C.ushort, func())
• type Commit
  • func (c *Commit) Scn() scn.SCN
  • func (c *Commit) String() string
• type Delete
  • func (c *Delete) Scn() scn.SCN
  • func (c *Delete) String() string
• type HeartBeat
  • func (h *HeartBeat) Scn() scn.SCN
  • func (h *HeartBeat) String() string
• type Insert
  • func (c *Insert) Scn() scn.SCN
  • func (c *Insert) String() string
• type Message
• type OCI_LCRID_VERSION
• type Update
  • func (c *Update) Scn() scn.SCN
  • func (c *Update) String() string
• type XStreamConn
  • func Open(username, password, dbname, servername string, oracleVer int) (*XStreamConn, error)
  • func (x *XStreamConn) Close() error
  • func (x *XStreamConn) GetRecord() (Message, error)
  • func (x *XStreamConn) SetSCNLwm(s scn.SCN) error

Constants

const (
	V1 = 1
	V2 = 2
)

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