dbapiclient

Documentation

Index

• func CloseDbAPIHdl(dbAPIHdl *DbAPIHdl)
• func SetDebug(dbgFlag bool)
• type DbAPIHdl
  • func GetDbAPIHdl(callingGrpcCtx context.Context, ctx *pb.ContextData) *DbAPIHdl
  • func (dbAPIHdl *DbAPIHdl) Begin(ctx *pb.ContextData, dbName string, ttxName string, exclusif bool) (uint32, uint32)
  • func (dbAPIHdl *DbAPIHdl) Commit(ctx *pb.ContextData, hdl uint32) uint32
  • func (dbAPIHdl *DbAPIHdl) GetMany(ctx *pb.ContextData, hdl uint32, eCN uint64, options string) ([]*pb.DbDocumentBytes, uint32)
  • func (dbAPIHdl *DbAPIHdl) GetManyMap(ctx *pb.ContextData, hdl uint32, eCN uint64, options string) ([]t.JDbDocumentMap, uint32)
  • func (dbAPIHdl *DbAPIHdl) Rollback(ctx *pb.ContextData, hdl uint32) uint32
• type IDbAPIClient

Functions

func CloseDbAPIHdl

func CloseDbAPIHdl(dbAPIHdl *DbAPIHdl)

CloseDbAPIHdl ... Close the cxion to DbApi service

func SetDebug

func SetDebug(dbgFlag bool)

SetDebug ...

Types

type DbAPIHdl

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

DbAPIHdl ..

func GetDbAPIHdl

func GetDbAPIHdl(callingGrpcCtx context.Context, ctx *pb.ContextData) *DbAPIHdl

GetDbAPIHdl ... Get a DbApi allowing to call remote service

func (*DbAPIHdl) Begin

func (dbAPIHdl *DbAPIHdl) Begin(ctx *pb.ContextData, dbName string, ttxName string, exclusif bool) (uint32, uint32)

Begin ..

func (*DbAPIHdl) Commit

func (dbAPIHdl *DbAPIHdl) Commit(ctx *pb.ContextData, hdl uint32) uint32

Commit ..

func (*DbAPIHdl) GetMany

func (dbAPIHdl *DbAPIHdl) GetMany(ctx *pb.ContextData, hdl uint32, eCN uint64, options string) ([]*pb.DbDocumentBytes, uint32)

GetMany ..

func (*DbAPIHdl) GetManyMap

func (dbAPIHdl *DbAPIHdl) GetManyMap(ctx *pb.ContextData, hdl uint32, eCN uint64, options string) ([]t.JDbDocumentMap, uint32)

GetManyMap ..

func (*DbAPIHdl) Rollback

func (dbAPIHdl *DbAPIHdl) Rollback(ctx *pb.ContextData, hdl uint32) uint32

Rollback ..

type IDbAPIClient

type IDbAPIClient interface {
	Begin(ctx *pb.ContextData, dbName string, ttxName string, exclusif bool) (uint32, uint32)
	Rollback(ctx *pb.ContextData, hdl uint32) uint32
	Commit(ctx *pb.ContextData, hdl uint32) uint32
	GetMany(ctx *pb.ContextData, hdl uint32, eCN uint64, options string) ([]*pb.DbDocumentBytes, uint32)
	GetManyMap(ctx *pb.ContextData, hdl uint32, eCN uint64, options string) ([]t.JDbDocumentMap, uint32)
}

IDbAPIClient ...