adabas

package

Go to main page

Versions in this module

v1

v1.6.26

Dec 19, 2024

v1.6.25

Nov 28, 2024

v1.6.24

Oct 16, 2023

v1.6.23

Oct 13, 2023

v1.6.22

Apr 12, 2023

v1.6.21

Oct 20, 2022

v1.6.20

Jul 28, 2022

v1.6.19

Jul 28, 2022

Changes in this version

type Adabas

+ func (adabas *Adabas) CreateFdtDefintion() *adatypes.Definition

+ func (adabas *Adabas) CreateFieldDefinitionTable(fdtDef *adatypes.Definition) (definition *adatypes.Definition, err error)

+ type FieldQuery struct

+ MultipleIndex uint32

+ Name string

+ PeriodicIndex uint32

+ Prefix rune

+ func NewFieldQuery(field string) (fq *FieldQuery, err error)

type Record

+ func (record *Record) SelectValue(definition *adatypes.Definition) []adatypes.IAdaValue

v1.6.18

May 5, 2022

v1.6.17

Apr 6, 2022

v1.6.16

Feb 9, 2022

v1.6.15

Feb 2, 2022

Changes in this version

type Buffer

+ func NewRcvBuffer(id byte, size uint32) *Buffer

+ func NewSendBuffer(id byte, buffer []byte) *Buffer

v1.6.14

Jan 14, 2022

Changes in this version

type Connection

+ func (connection *Connection) GetAdabasInformation() string

v1.6.13

Nov 16, 2021

Changes in this version

type Adabas

+ func (adabas *Adabas) Platform() string

+ func (adabas *Adabas) Version() string

v1.6.12

Nov 13, 2021

Changes in this version

type Buffer

+ func (adabasBuffer *Buffer) Position(pos int) int

+ func (adabasBuffer *Buffer) Read(p []byte) (n int, err error)

+ func (adabasBuffer *Buffer) Write(p []byte) (n int, err error)

v1.6.11

Nov 2, 2021

Changes in this version

type ID

+ func (adaid *ID) Clone() *ID

v1.6.10

Oct 24, 2021

v1.6.9

Oct 21, 2021

v1.6.8

Oct 19, 2021

Changes in this version

+ type AdaIPC struct — windows/amd64

+ func (ipc *AdaIPC) Connect(adabas *Adabas) (err error)

+ func (ipc *AdaIPC) Disconnect() (err error)

+ func (ipc *AdaIPC) Send(adabas *Adabas) (err error)

v1.6.7

Aug 2, 2021

v1.6.6

Jul 31, 2021

v1.6.5

Jul 27, 2021

Changes in this version

type StoreRequest

+ func (request *StoreRequest) UpdateLOBRecord(isn adatypes.Isn, field string, offset uint64, data []byte) (err error)

v1.6.4

Jul 24, 2021

Changes in this version

type ReadRequest

+ PartialRead bool

+ func (request *ReadRequest) ReadLOBRecord(isn adatypes.Isn, field string, blocksize uint64) (result *Response, err error)

+ func (request *ReadRequest) ReadLOBSegment(isn adatypes.Isn, field string, blocksize uint64) (segment []byte, err error)

+ func (request *ReadRequest) ReadLogicalByCursoring(descriptor string) (cursor *Cursoring, err error)

v1.6.3

Jun 28, 2021

Changes in this version

type Cursoring

+ func (cursor *Cursoring) Error() (err error)

type ReadRequest

+ func (request *ReadRequest) ReadPhysicalWithCursoring() (cursor *Cursoring, err error)

type URL

+ Options string

+ func (URL *URL) GetOption(option string) string

v1.6.2

May 28, 2021

v1.6.1

May 28, 2021

v1.6.0

May 23, 2021

v1.5.10

May 23, 2021

Changes in this version

+ func RegisterExternalDriver(driver ExternalDriver)

type AdaTCP

+ func (connection *AdaTCP) Send(adabas *Adabas) (err error)

+ type Driver interface

+ Connect func(adabas *Adabas) error

+ Disconnect func() error

+ Send func(adabas *Adabas) error

+ func NewAdaIPC(URL *URL, ID *ID) Driver

+ type ExternalDriver interface

+ Driver func() string

+ NewInstance func(URL *URL, ID *ID) Driver

type URL

+ func (URL URL) Instance(id *ID) Driver

v1.5.9

May 7, 2021

v1.5.8

Apr 28, 2021

Changes in this version

type Connection

+ func (connection *Connection) ReadRequest(p ...interface{}) (request *ReadRequest, err error)

v1.5.7

Apr 27, 2021

Changes in this version

type DatabaseURL

+ func (repURL *DatabaseURL) MarshalJSON() ([]byte, error)

type Repository

+ func (repository *Repository) ExportMapRepository(ada *Adabas, filter string, fileName string) (err error)

v1.5.6

Apr 20, 2021

Changes in this version

type Connection

+ func (connection *Connection) GetClusterNodes() []*URL

+ func (connection *Connection) IsCluster() bool

type Map

+ func (adabasMap *Map) Delete() error

type Repository

+ func (repository *Repository) DeleteMap(adabas *Adabas, mapName string) (err error)

v1.5.5

Apr 7, 2021

v1.5.4

Apr 2, 2021

Changes in this version

type AdaTCPHeader

+ DatabaseType byte

+ func (header AdaTCPHeader) Valid() bool

+ type TransferDataType uint32

v1.5.3

Feb 26, 2021

v1.5.2

Jan 24, 2021

Changes in this version

type Error

+ URL URL

+ func (e Error) Translate(lang string) string

v1.5.1

Jan 1, 2021

v1.5.0

Jan 1, 2021

Changes in this version

type Adabas

+ func (adabas *Adabas) DumpStatistics()

+ type CallStatistic struct

type Connection

+ func (connection *Connection) BackoutTransaction() error

type Cursoring

+ func (cursor *Cursoring) NextData() (record interface{}, err error)

type DeleteRequest

+ func NewDeleteRequestDeprecated(url string, fnr Fnr) (*DeleteRequest, error)

type ID

+ func (adaid *ID) Close()

+ type Statistics struct

v1.4.9

Dec 18, 2020

Changes in this version

type DeleteRequest

+ func (deleteRequest *DeleteRequest) DeleteList(isnList []adatypes.Isn) (err error)

type ReadRequest

+ func (request *ReadRequest) SearchAndOrderWithCursoring(search, descriptors string) (cursor *Cursoring, err error)

v1.4.8

Dec 10, 2020

v1.4.7

Nov 18, 2020

v1.4.6

Nov 16, 2020

v1.4.5

Jun 30, 2020

Changes in this version

type Adabas

+ func (adabas *Adabas) OpenUser(user string) (err error)

type ReadRequest

+ func (request *ReadRequest) SearchAndOrder(search, descriptors string) (result *Response, err error)

+ func (request *ReadRequest) SearchAndOrderWithParser(search, descriptors string, resultParser adatypes.RequestParser, x interface{}) (err error)

v1.4.4

Apr 12, 2020

Changes in this version

type Map

+ DefaultCharset string

type Repository

+ func (repository *Repository) AddMapToCache(name string, adabasMap *Map)

+ func (repository *Repository) GetMapFromCache(name string) (*Map, bool)

v1.4.3

Mar 8, 2020

v1.4.2

Mar 6, 2020

v1.4.1

Feb 21, 2020

Changes in this version

+ func TimeTrack(start time.Time, name string, acbx *Acbx)

type Record

+ LobEndTransaction bool

v1.4.0

Feb 16, 2020

Changes in this version

type Adabas

+ func (adabas *Adabas) ReadStream(adabasRequest *adatypes.Request, offset uint64, x interface{}) (err error)

+ func (adabas *Adabas) SendSecondCall(adabasRequest *adatypes.Request, x interface{}) (err error)

type Connection

+ func (connection *Connection) ReflectSearch(mapName string, t reflect.Type, search string) ([]interface{}, error)

+ func (connection *Connection) ReflectStore(entries interface{}, mapName string) error

type Cursoring

+ FieldLength uint32

type ReadRequest

+ BlockSize uint32

+ func (request *ReadRequest) ReadFieldStream(search string) (result *Response, err error)

+ func (request *ReadRequest) ReadLobStream(search, field string) (cursor *Cursoring, err error)

type Record

+ func (record *Record) Bytes(parameter ...interface{}) []byte

+ func (record *Record) SetPartialValue(name string, offset uint32, data []byte) (err error)

+ func (record *Record) TrimString(parameter ...interface{}) string

v1.3.10

Jan 27, 2020

v1.3.9

Jan 18, 2020

v1.3.8

Dec 1, 2019

Changes in this version

type Connection

+ func (connection *Connection) CreateMapWithInterface(mapName string, fieldList string) (request *ReadRequest, err error)

v1.3.7

Oct 25, 2019

Changes in this version

type Record

+ func (record *Record) Traverse(t adatypes.TraverserValuesMethods, x interface{}) (ret adatypes.TraverseResult, err error)

v1.3.6

Oct 18, 2019

v1.3.5

Oct 16, 2019

Changes in this version

+ const AdaALLOC

+ const AdaALOCK

+ const AdaBLOST

+ const AdaBPLOCK

+ const AdaBPMFU

+ const AdaBPOLL

+ const AdaBSPEC

+ const AdaCALLINV

+ const AdaCancel

+ const AdaCmdInvalid

+ const AdaCompressTooLong

+ const AdaDARAB

+ const AdaDDLCommandFailed

+ const AdaDSpec

+ const AdaDescrLong

+ const AdaERSBU

+ const AdaETDAT

+ const AdaEXOVFCB

+ const AdaErrorFB

+ const AdaFBNotUsableUpdate

+ const AdaFCONVSUB

+ const AdaFCTNY

+ const AdaFNFCR

+ const AdaFUNotAvaiable

+ const AdaFieldCountOverflow

+ const AdaFileChanged

+ const AdaFuncMP

+ const AdaGCBEX

+ const AdaHYISN

+ const AdaHYISNMF

+ const AdaHYPERR

+ const AdaHYXNA

+ const AdaHoldIsnOverflow

+ const AdaICNF

+ const AdaIDUCB

+ const AdaIEDEC

+ const AdaIFBSmall

+ const AdaINMEM

+ const AdaINRAB

+ const AdaINVIS

+ const AdaINVLIST

+ const AdaINVPWD

+ const AdaINVRF

+ const AdaINVUSR

+ const AdaIOERR

+ const AdaISNLL

+ const AdaISNNotSorted

+ const AdaISNVAL

+ const AdaIUBSZ

+ const AdaIUCAL

+ const AdaIncompFCTE

+ const AdaInconsistentCmd

+ const AdaIncosistentDE

+ const AdaInvalidADD1

+ const AdaInvalidCID

+ const AdaInvalidCOP

+ const AdaInvalidFileNumber

+ const AdaInvalidISNBufferLength

+ const AdaInvalidIsnBuf

+ const AdaInvalidRBOpen

+ const AdaInvalidRBVB

+ const AdaInvalidStartISN

+ const AdaLNKERR

+ const AdaLOBERR

+ const AdaLODUEX

+ const AdaLPWSmall

+ const AdaLSPEC

+ const AdaMISAC

+ const AdaMismatchFB

+ const AdaMissingVOPT

+ const AdaNDSOFF

+ const AdaNFPWD

+ const AdaNLOCK

+ const AdaNODESC

+ const AdaNODV

+ const AdaNOTYET

+ const AdaNSAAD

+ const AdaNSACQ

+ const AdaNSSC

+ const AdaNSSR

+ const AdaNSUQU

+ const AdaNSWRK

+ const AdaNTWRK

+ const AdaNUCLI

+ const AdaOVDVT

+ const AdaOVFST

+ const AdaOVIDX

+ const AdaOVUCB

+ const AdaPWDINU

+ const AdaPending

+ const AdaRMUTI

+ const AdaRbtl

+ const AdaSAF

+ const AdaSCALERR

+ const AdaSECUR

+ const AdaSExpandedFiles

+ const AdaSXInterrupted

+ const AdaSYLOD

+ const AdaSYRBO

+ const AdaSYSBU

+ const AdaSubCommandFailed

+ const AdaSyntax

+ const AdaTIMEOUT

+ const AdaTooManyOccurrencesPeriod

+ const AdaTransactionAborted

+ const AdaUAOS

+ const AdaUBNAC

+ const AdaUCIDS

+ const AdaUNIQD

+ const AdaUQDV

+ const AdaUTUCB

+ const AdaVCompression

+ const AdaWOSUB

+ const AdaXAProtocol

+ const AddACCCNotAllowed

+ func CleanGlobalMapRepository()

type Buffer

+ func (adabasBuffer *Buffer) ID() rune

+ func (adabasBuffer *Buffer) Size() uint64

type Error

+ Acbx Acbx

v1.3.4

Sep 16, 2019

Changes in this version

type AdaTCP

+ URL *URL

+ func (connection *AdaTCP) Connect() (err error)

v1.3.3

Sep 14, 2019

v1.3.2

Sep 13, 2019

Changes in this version

+ type AdaTCP struct

+ func NewAdaTCP(URL *URL, order binary.ByteOrder, user [8]byte, node [8]byte, pid uint32, ...) (connection *AdaTCP, err error)

+ func (connection *AdaTCP) Disconnect() (err error)

+ func (connection *AdaTCP) ReceiveData(buffer *bytes.Buffer) (nrAbdBuffers uint32, err error)

+ func (connection *AdaTCP) SendData(buffer bytes.Buffer, nrAbdBuffers uint32) (err error)

v1.3.1

Sep 12, 2019

Changes in this version

type ReadRequest

+ func (request *ReadRequest) ReadPhysicalInterface(interfaceFunction InterfaceFunction, x interface{}) (result *Response, err error)

v1.3.0

Sep 10, 2019

Changes in this version

type Adabas

+ func (adabas *Adabas) ReleaseCmdID() (err error)

+ func (adabas *Adabas) ReleaseHold(fileNr Fnr) (err error)

+ func (adabas *Adabas) SetURL(URL *URL)

type Connection

+ func (connection *Connection) ReleaseCID() error

+ type InterfaceFunction func(data interface{}, x interface{}) error

type ReadRequest

+ func (request *ReadRequest) ReadLogicalWithInterface(search string, interfaceFunction InterfaceFunction, x interface{}) (result *Response, err error)

type Repository

+ func (repository *Repository) ClearCache(maxTime time.Time)

type Response

+ Data []interface{}

+ func (Response *Response) DumpData() (err error)

type StoreRequest

+ func (request *StoreRequest) StoreData(data interface{}) error

+ func (request *StoreRequest) UpdateData(data interface{}) error

v1.2.8

Aug 12, 2019

Changes in this version

+ func EndAsynchronousMapCache()

+ func PeriodGroup(v adatypes.IAdaValue) adatypes.IAdaValue

+ func StartAsynchronousMapCache()

type Adabas

+ func (adabas *Adabas) SecondCall(adabasRequest *adatypes.Request, x interface{}) (err error)

type Record

+ func (record *Record) ValueQuantity(param ...interface{}) int32

v1.2.7

Jul 27, 2019

v1.2.6

Jul 18, 2019

Changes in this version

type Map

+ RedefinitionFields []*MapField

+ Version string

v1.2.5

Jul 10, 2019

v1.2.4

Jul 1, 2019

v1.2.3

Jun 10, 2019

v1.2.2

May 27, 2019

Changes in this version

type Repository

+ func (repository *Repository) RemoveMap(mapName string) (err error)

v1.2.1

May 13, 2019

Changes in this version

+ var BuildDate string

+ var BuildVersion string

+ func AddGlobalMapRepositoryReference(reference string) error

+ func AllGlobalMapNames(adabas *Adabas) (maps []string, err error)

+ func DelGlobalMapRepositoryReference(reference string) error

type Adabas

+ func (adabas *Adabas) ReadISNOrder(fileNr Fnr, adabasRequest *adatypes.Request, x interface{}) (err error)

type DeleteRequest

+ func (request *DeleteRequest) TraverseFields(t adatypes.TraverserMethods, p interface{}) error

type Map

+ Generated uint64

+ func AllGlobalMaps(adabas *Adabas) (maps []*Map, err error)

+ func (adabasMap *Map) FieldNames() []string

+ func (adabasMap *Map) FieldShortNames() []string

type MapField

+ Charset string

+ FieldType string

+ File uint32

type ReadRequest

+ Start uint64

+ func NewReadRequest(param ...interface{}) (request *ReadRequest, err error)

+ func (request *ReadRequest) ReadByISN() (result *Response, err error)

+ func (request *ReadRequest) TraverseFields(t adatypes.TraverserMethods, p interface{}) error

type StoreRequest

+ func (request *StoreRequest) TraverseFields(t adatypes.TraverserMethods, p interface{}) error

v1.1.2

Mar 20, 2019

Changes in this version

type Connection

+ func (connection *Connection) AddCredential(user string, pwd string)

type ID

+ func (adaid *ID) AddCredential(user string, pwd string)

type Map

+ func GloablMaps(adabas *Adabas) (maps []*Map, err error)

type ReadRequest

+ HoldRecords adatypes.HoldType

+ func (request *ReadRequest) HistogramByCursoring(descriptor string) (cursor *Cursoring, err error)

+ func (request *ReadRequest) HistogramWithCursoring(search string) (cursor *Cursoring, err error)

+ func (request *ReadRequest) Scan(dest ...interface{}) error

+ func (request *ReadRequest) SetHoldRecords(hold adatypes.HoldType)

type Record

+ func (record *Record) Scan(dest ...interface{}) (err error)

v1.1.1

Feb 23, 2019

Changes in this version

+ const MaxDatabasesID

+ func AddGlobalMapRepository(adabas *Adabas, fnr Fnr)

+ func DelGlobalMapRepository(adabas *Adabas, fnr Fnr)

+ func DumpGlobalMapRepositories()

type Buffer

+ func NewBufferWithSize(id byte, size uint32) *Buffer

+ func SearchAdabasBuffer(tree *adatypes.SearchTree) *Buffer

+ func ValueAdabasBuffer(tree *adatypes.SearchTree) *Buffer

type Connection

+ func (connection *Connection) CreateFileReadRequest(fnr Fnr) (*ReadRequest, error)

+ type Cursoring struct

+ func (cursor *Cursoring) HasNextRecord() (hasNext bool)

+ func (cursor *Cursoring) NextRecord() (record *Record, err error)

type DeleteRequest

+ func NewMapNameDeleteRequestRepo(mapName string, adabas *Adabas, mapRepository *Repository) (request *DeleteRequest, err error)

+ func (request *DeleteRequest) BackoutTransaction() error

+ type Fnr uint32

type ID

+ AdaID *AID

+ func (adaid *ID) SetHost(Host string)

+ func (adaid *ID) SetID(pid uint32)

+ func (adaid *ID) SetUser(User string)

type Map

+ func LoadJSONMap(file string) (maps []*Map, err error)

type ReadRequest

+ func NewMapReadRequest(adabas *Adabas, mapName string) (request *ReadRequest, err error)

+ func NewMapReadRequestByMap(adabas *Adabas, adabasMap *Map) (request *ReadRequest, err error)

+ func NewMapReadRequestRepo(mapName string, adabas *Adabas, repository *Repository) (request *ReadRequest, err error)

+ func NewReadRequestAdabas(adabas *Adabas, fnr Fnr) *ReadRequest

+ func (request *ReadRequest) BackoutTransaction() error

+ func (request *ReadRequest) HistogramWithStream(search string, streamFunction StreamFunction, x interface{}) (result *Response, err error)

+ func (request *ReadRequest) ReadLogicalByStream(descriptor string, streamFunction StreamFunction, x interface{}) (result *Response, err error)

+ func (request *ReadRequest) ReadLogicalWithCursoring(search string) (cursor *Cursoring, err error)

+ func (request *ReadRequest) ReadLogicalWithStream(search string, streamFunction StreamFunction, x interface{}) (result *Response, err error)

+ func (request *ReadRequest) ReadPhysicalSequenceStream(streamFunction StreamFunction, x interface{}) (result *Response, err error)

+ type Record struct

+ HashFields map[string]adatypes.IAdaValue

+ Isn adatypes.Isn

+ Quantity uint64

+ Value []adatypes.IAdaValue

+ func NewRecord(definition *adatypes.Definition) (*Record, error)

+ func NewRecordIsn(isn adatypes.Isn, isnQuantity uint64, definition *adatypes.Definition) (*Record, error)

+ func (record *Record) DumpValues()

+ func (record *Record) MarshalJSON() ([]byte, error)

+ func (record *Record) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ func (record *Record) SearchValue(name string) (adatypes.IAdaValue, error)

+ func (record *Record) SearchValueIndex(name string, index []uint32) (adatypes.IAdaValue, error)

+ func (record *Record) SetValue(field string, value interface{}) (err error)

+ func (record *Record) SetValueWithIndex(name string, index []uint32, x interface{}) error

+ func (record *Record) String() string

type Repository

+ func NewMapRepositoryWithURL(url DatabaseURL) *Repository

+ type Response struct

+ Definition *adatypes.Definition

+ Values []*Record

+ XMLName xml.Name

+ func (Response *Response) DumpValues() (err error)

+ func (Response *Response) Isn(isn adatypes.Isn) *Record

+ func (Response *Response) MarshalJSON() ([]byte, error)

+ func (Response *Response) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ func (Response *Response) NrRecords() int

+ func (Response *Response) String() string

+ func (Response *Response) TraverseValues(t adatypes.TraverserValuesMethods, x interface{}) (ret adatypes.TraverseResult, err error)

type StoreRequest

+ func (request *StoreRequest) BackoutTransaction() error

+ type StreamFunction func(record *Record, x interface{}) error

type URL

+ func NewURL(url string) (*URL, error)

+ func NewURLWithDbid(dbid Dbid) *URL

v1.0.1

Jan 11, 2019

Changes in this version

+ const ABdEQXb

+ const AbdAQFb

+ const AbdAQIb

+ const AbdAQMb

+ const AbdAQOb

+ const AbdAQPb

+ const AbdAQRb

+ const AbdAQSb

+ const AbdAQUi

+ const AbdAQVb

+ const AbdAQXb

+ const AbdAQZb

+ const AbdEQFb

+ const AbdEQIb

+ const AbdEQMb

+ const AbdEQOb

+ const AbdEQPb

+ const AbdEQRb

+ const AbdEQSb

+ const AbdEQUi

+ const AbdEQVb

+ const AbdEQZb

+ const AdaAnact

+ const AdaEOF

+ const AdaNormal

+ const AdaRbts

+ const AdaSysCe

+ const AdaTCPConnectPayloadLength

+ const AdaTCPDataHeaderLength

+ const AdaTCPHeaderLength

+ const ConnectError

+ const ConnectReply

+ const ConnectRequest

+ const DataError

+ const DataReply

+ const DataRequest

+ const DisconnectError

+ const DisconnectRequest

+ const DisconnetReply

+ func AddMapRepository(adabas *Adabas, fnr uint32)

+ func DelMapRepository(adabas *Adabas, fnr uint32)

+ func Endian() binary.ByteOrder

+ func ReflectSearch(mapName string, t reflect.Type, connection *Connection, search string) ([]interface{}, error)

+ func ReflectStore(entries interface{}, connection *Connection, mapName string) error

+ type ADATCP struct

+ func Connect(url string, order binary.ByteOrder, user [8]byte, node [8]byte, pid uint32, ...) (connection *ADATCP, err error)

+ func (connection *ADATCP) Disconnect() (err error)

+ func (connection *ADATCP) ReceiveData(buffer *bytes.Buffer) (nrAbdBuffers uint32, err error)

+ func (connection *ADATCP) SendData(buffer bytes.Buffer, nrAbdBuffers uint32) (err error)

+ type AID struct

+ Node [8]byte

+ Pid uint32

+ Timestamp uint64

+ User [8]byte

+ type Abd struct

+ Abdaddr uint64

+ Abdid byte

+ Abdlen uint16

+ Abdloc byte

+ Abdrecv uint64

+ Abdrsv1 byte

+ Abdrsv2 [9]byte

+ Abdsend uint64

+ Abdsize uint64

+ Abdver [2]byte

+ type Acbx struct

+ Acbxadd1 [8]byte

+ Acbxadd2 [4]byte

+ Acbxadd3 [8]byte

+ Acbxadd4 [8]byte

+ Acbxadd5 [8]byte

+ Acbxadd6 [8]byte

+ Acbxcid [4]byte

+ Acbxcmd [2]byte

+ Acbxcmdt uint64

+ Acbxcop [8]byte

+ Acbxdbid Dbid

+ Acbxerra uint64

+ Acbxerrb [2]byte

+ Acbxerrc uint16

+ Acbxerrd byte

+ Acbxerre byte

+ Acbxerrf uint16

+ Acbxfnr uint32

+ Acbxisl uint64

+ Acbxisn adatypes.Isn

+ Acbxisq uint64

+ Acbxlcmp uint64

+ Acbxldec uint64

+ Acbxlen uint16

+ Acbxrsp uint16

+ Acbxrsv1 byte

+ Acbxrsv2 uint16

+ Acbxrsv3 [4]byte

+ Acbxrsv4 [16]byte

+ Acbxsesstime uint64

+ Acbxsubr uint16

+ Acbxsubs uint16

+ Acbxsubt [4]byte

+ Acbxtyp byte

+ Acbxuser [16]byte

+ Acbxver [2]byte

+ func (acbx *Acbx) String() string

+ type AdaTCPConnectPayload struct

+ Charset byte

+ DatabaseID uint32

+ DatabaseName [16]byte

+ DatabaseVersion [16]byte

+ Endianness byte

+ Filler [5]byte

+ Floatingpoint byte

+ Nodeid [8]byte

+ ProcessID uint32

+ TimeStamp uint64

+ Userid [8]byte

+ type AdaTCPDataHeader struct

+ DataType uint32

+ ErrorCode uint32

+ Eyecatcher [4]byte

+ Length uint32

+ NumberOfBuffers uint32

+ Version [4]byte

+ type AdaTCPHeader struct

+ BufferType BufferType

+ ErrorCode uint32

+ Eyecatcher [6]byte

+ Identification adaUUID

+ Length uint32

+ Reserved uint32

+ Version [2]byte

+ func NewAdatcpHeader(bufferType BufferType) AdaTCPHeader

+ type Adabas struct

+ Acbx *Acbx

+ AdabasBuffers []*Buffer

+ ID *ID

+ URL *URL

+ func NewAdabas(dbid Dbid) *Adabas

+ func NewAdabasWithID(target string, ID *ID) (*Adabas, error)

+ func NewAdabasWithURL(URL *URL, ID *ID) *Adabas

+ func NewAdabass(target string) (*Adabas, error)

+ func NewClonedAdabas(clone *Adabas) *Adabas

+ func (adabas *Adabas) ACBX() *Acbx

+ func (adabas *Adabas) BackoutTransaction() (err error)

+ func (adabas *Adabas) CallAdabas() (err error)

+ func (adabas *Adabas) Close()

+ func (adabas *Adabas) DeleteIsn(fileNr uint32, isn adatypes.Isn) (err error)

+ func (adabas *Adabas) EndTransaction() (err error)

+ func (adabas *Adabas) Histogram(fileNr uint32, adabasRequest *adatypes.AdabasRequest, x interface{}) (err error)

+ func (adabas *Adabas) IsRemote() bool

+ func (adabas *Adabas) Open() (err error)

+ func (adabas *Adabas) ReadBuffer(buffer *bytes.Buffer, order binary.ByteOrder, nCalBuf uint32, serverMode bool) (err error)

+ func (adabas *Adabas) ReadFileDefinition(fileNr uint32) (definition *adatypes.Definition, err error)

+ func (adabas *Adabas) ReadLogicalWith(fileNr uint32, adabasRequest *adatypes.AdabasRequest, x interface{}) (err error)

+ func (adabas *Adabas) ReadPhysical(fileNr uint32, adabasRequest *adatypes.AdabasRequest, x interface{}) (err error)

+ func (adabas *Adabas) Release() (err error)

+ func (adabas *Adabas) SearchLogicalWith(fileNr uint32, adabasRequest *adatypes.AdabasRequest, x interface{}) (err error)

+ func (adabas *Adabas) SetAbd(abd []*Buffer)

+ func (adabas *Adabas) SetDbid(dbid Dbid)

+ func (adabas *Adabas) Store(fileNr uint32, adabasRequest *adatypes.AdabasRequest) (err error)

+ func (adabas *Adabas) String() string

+ func (adabas *Adabas) Update(fileNr uint32, adabasRequest *adatypes.AdabasRequest) (err error)

+ func (adabas *Adabas) WriteBuffer(buffer *bytes.Buffer, order binary.ByteOrder, serverMode bool) (err error)

+ type Buffer struct

+ func NewBuffer(id byte) *Buffer

+ func (adabasBuffer *Buffer) Allocate(size uint32)

+ func (adabasBuffer *Buffer) Bytes() []byte

+ func (adabasBuffer *Buffer) Clear()

+ func (adabasBuffer *Buffer) Received() uint64

+ func (adabasBuffer *Buffer) String() string

+ func (adabasBuffer *Buffer) WriteBinary(content []byte)

+ func (adabasBuffer *Buffer) WriteString(content string)

+ type BufferType uint32

+ type Connection struct

+ ID ID

+ func NewConnection(connectionString string) (*Connection, error)

+ func NewConnectionID(connectionString string, adabasID *ID) (connection *Connection, err error)

+ func (connection *Connection) Close()

+ func (connection *Connection) CreateDeleteRequest(fnr uint32) (*DeleteRequest, error)

+ func (connection *Connection) CreateMapDeleteRequest(mapName string) (request *DeleteRequest, err error)

+ func (connection *Connection) CreateMapReadRequest(mapName string) (request *ReadRequest, err error)

+ func (connection *Connection) CreateMapStoreRequest(mapName string) (request *StoreRequest, err error)

+ func (connection *Connection) CreateReadRequest(fnr uint32) (*ReadRequest, error)

+ func (connection *Connection) CreateStoreRequest(fnr uint32) (*StoreRequest, error)

+ func (connection *Connection) EndTransaction() error

+ func (connection *Connection) Open() error

+ func (connection *Connection) Release() error

+ func (connection *Connection) String() string

+ type DatabaseURL struct

+ Fnr uint32

+ URL URL

+ type Dbid uint32

+ type DeleteRequest struct

+ func NewDeleteRequest(url string, fnr uint32) *DeleteRequest

+ func NewDeleteRequestAdabas(adabas *Adabas, fnr uint32) *DeleteRequest

+ func NewMapDeleteRequest(adabas *Adabas, adabasMap *Map) (request *DeleteRequest, err error)

+ func NewMapNameDeleteRequest(adabas *Adabas, mapName string) (request *DeleteRequest, err error)

+ func (deleteRequest *DeleteRequest) Delete(isn adatypes.Isn) (err error)

+ func (deleteRequest *DeleteRequest) Open() (err error)

+ func (request *DeleteRequest) Close()

+ func (request *DeleteRequest) EndTransaction() error

+ func (request *DeleteRequest) IsOpen() bool

+ type Error struct

+ Addition2 [4]byte

+ Code string

+ Message string

+ Response uint16

+ SubResponse uint16

+ When time.Time

+ func NewError(adbas *Adabas) *Error

+ func (e Error) Error() string

+ type ID struct

+ func NewAdabasID() *ID

+ func (adaid *ID) String() string

+ type Map struct

+ Data *DatabaseURL

+ Fields []*MapField

+ Isn adatypes.Isn

+ ModificationTime []uint64

+ Name string

+ Repository *DatabaseURL

+ func NewAdabasMap(name string, repository *DatabaseURL) *Map

+ func ParseJSONFileForFields(file *os.File) (mapList []*Map, err error)

+ func SearchMapRepository(adabas *Adabas, mapName string) (adabasMap *Map, err error)

+ func (adabasMap *Map) Store() error

+ func (adabasMap *Map) String() string

+ func (adabasMap *Map) URL() *URL

+ type MapField struct

+ ContentType string

+ FormatType string

+ Length int32

+ LongName string

+ Remarks string

+ ShortName string

+ type MapFile struct

+ Maps []*Map

+ type ReadRequest struct

+ Limit uint64

+ Multifetch uint32

+ RecordBufferShift uint32

+ func NewAdabasMapNameRequest(adabas *Adabas, adabasMap *Map) (request *ReadRequest, err error)

+ func NewMapNameRequest(adabas *Adabas, mapName string) (request *ReadRequest, err error)

+ func NewMapNameRequestRepo(mapName string, repository *Repository) (request *ReadRequest, err error)

+ func NewReadRequestCommon(commonRequest *commonRequest) *ReadRequest

+ func NewRequest(url string, fnr uint32) *ReadRequest

+ func NewRequestAdabas(adabas *Adabas, fnr uint32) *ReadRequest

+ func (request *ReadRequest) Close()

+ func (request *ReadRequest) EndTransaction() error

+ func (request *ReadRequest) HistogramBy(descriptor string) (result *RequestResult, err error)

+ func (request *ReadRequest) HistogramWith(search string) (result *RequestResult, err error)

+ func (request *ReadRequest) IsOpen() bool

+ func (request *ReadRequest) Open() (err error)

+ func (request *ReadRequest) QueryFields(fields string) (err error)

+ func (request *ReadRequest) ReadISN(isn adatypes.Isn) (result *RequestResult, err error)

+ func (request *ReadRequest) ReadISNWithParser(isn adatypes.Isn, resultParser adatypes.RequestParser, x interface{}) (err error)

+ func (request *ReadRequest) ReadLogicalBy(descriptors string) (result *RequestResult, err error)

+ func (request *ReadRequest) ReadLogicalByWithParser(descriptors string, resultParser adatypes.RequestParser, x interface{}) (err error)

+ func (request *ReadRequest) ReadLogicalWith(search string) (result *RequestResult, err error)

+ func (request *ReadRequest) ReadLogicalWithWithParser(search string, resultParser adatypes.RequestParser, x interface{}) (err error)

+ func (request *ReadRequest) ReadPhysicalSequence() (result *RequestResult, err error)

+ func (request *ReadRequest) ReadPhysicalSequenceWithParser(resultParser adatypes.RequestParser, x interface{}) (err error)

+ type Repository struct

+ CachedMaps map[string]*Map

+ MapNames map[string]adatypes.Isn

+ func NewMapRepository(adabas *Adabas, fnr uint32) *Repository

+ func (repository *Repository) ImportMapRepository(adabas *Adabas, filter string, fileName string, mapURL *DatabaseURL) (maps []*Map, err error)

+ func (repository *Repository) LoadAllMaps(adabas *Adabas) (adabasMaps []*Map, err error)

+ func (repository *Repository) LoadMapRepository(adabas *Adabas) (err error)

+ func (repository *Repository) LoadMaps() error

+ func (repository *Repository) LoadRepositoryMapsWithAdabas(adabas *Adabas) (err error)

+ func (repository *Repository) SearchMap(adabas *Adabas, mapName string) (adabasMap *Map, err error)

+ func (repository *Repository) SearchMapInRepository(adabas *Adabas, mapName string) (adabasMap *Map, err error)

+ type RequestResult struct

+ Values []*ResultRecord

+ XMLName xml.Name

+ func (requestResult *RequestResult) DumpValues() (err error)

+ func (requestResult *RequestResult) Isn(isn adatypes.Isn) *ResultRecord

+ func (requestResult *RequestResult) MarshalJSON() ([]byte, error)

+ func (requestResult *RequestResult) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ func (requestResult *RequestResult) NrRecords() int

+ func (requestResult *RequestResult) String() string

+ func (requestResult *RequestResult) TraverseValues(t adatypes.TraverserValuesMethods, x interface{}) (ret adatypes.TraverseResult, err error)

+ type ResultRecord struct

+ HashFields map[string]adatypes.IAdaValue

+ Isn adatypes.Isn

+ Value []adatypes.IAdaValue

+ func NewResultRecord(definition *adatypes.Definition) (*ResultRecord, error)

+ func NewResultRecordIsn(isn adatypes.Isn, isnQuantity uint64, definition *adatypes.Definition) (*ResultRecord, error)

+ func (record *ResultRecord) DumpValues()

+ func (record *ResultRecord) MarshalJSON() ([]byte, error)

+ func (record *ResultRecord) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ func (record *ResultRecord) SearchValue(name string) (adatypes.IAdaValue, error)

+ func (record *ResultRecord) SearchValueIndex(name string, index []uint32) (adatypes.IAdaValue, error)

+ func (record *ResultRecord) SetValue(field string, value interface{}) (err error)

+ func (record *ResultRecord) SetValueWithIndex(name string, index []uint32, x interface{}) error

+ func (record *ResultRecord) String() string

+ type Status struct

+ type StoreRequest struct

+ func NewAdabasMapNameStoreRequest(adabas *Adabas, adabasMap *Map) (request *StoreRequest, err error)

+ func NewStoreRequest(url string, fnr uint32) *StoreRequest

+ func NewStoreRequestAdabas(adabas *Adabas, fnr uint32) *StoreRequest

+ func (request *StoreRequest) Close()

+ func (request *StoreRequest) CreateRecord() (record *ResultRecord, err error)

+ func (request *StoreRequest) EndTransaction() error

+ func (request *StoreRequest) Exchange(storeRecord *ResultRecord) error

+ func (request *StoreRequest) IsOpen() bool

+ func (request *StoreRequest) Open() (err error)

+ func (request *StoreRequest) Store(storeRecord *ResultRecord) error

+ func (request *StoreRequest) StoreFields(fields string) (err error)

+ func (request *StoreRequest) Update(storeRecord *ResultRecord) error

+ type URL struct

+ Dbid Dbid

+ Driver string

+ Host string

+ Port uint32

+ func (URL *URL) UnmarshalJSON(data []byte) error

+ func (URL URL) String() string

+ func (URL URL) URL() string

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