bindings

Documentation

Index

• Constants
• func NewError(text string, code int) error
• func RegisterBinding(name string, binding RawBinding)
• type Error
  • func (e Error) Code() int
  • func (e Error) Error() string
• type FetchMore
• type IndexDef
• type Logger
• type NamespaceDef
• type OptionBuiltinWithServer
• type OptionCgoLimit
• type OptionConnPoolSize
• type OptionReindexerInstance
• type OptionRetryAttempts
• type RawBinding
  • func GetBinding(name string) RawBinding
• type RawBindingChanging
• type RawBuffer
• type Stats
• type Status
• type StatusBuiltin
• type StatusCProto
• type StorageOptions
  • func (so *StorageOptions) DropOnFileFormatError(value bool) *StorageOptions
  • func (so *StorageOptions) Enabled(value bool) *StorageOptions
• type StorageOpts
• type TxCtx

Constants

const (
	ANY    = 0
	EQ     = 1
	LT     = 2
	LE     = 3
	GT     = 4
	GE     = 5
	RANGE  = 6
	SET    = 7
	ALLSET = 8
	EMPTY  = 9
	LIKE   = 10

	ERROR   = 1
	WARNING = 2
	INFO    = 3
	TRACE   = 4

	AggSum   = 0
	AggAvg   = 1
	AggFacet = 2
	AggMin   = 3
	AggMax   = 4

	CollateNone    = 0
	CollateASCII   = 1
	CollateUTF8    = 2
	CollateNumeric = 3
	CollateCustom  = 4
)

public go consts from type_consts.h and reindexer_ctypes.h

const (
	OpOr  = 1
	OpAnd = 2
	OpNot = 3

	ValueInt64     = 0
	ValueDouble    = 1
	ValueString    = 2
	ValueBool      = 3
	ValueNull      = 4
	ValueInt       = 8
	ValueUndefined = 9
	ValueComposite = 10
	ValueTuple     = 11

	QueryCondition         = 0
	QueryDistinct          = 1
	QuerySortIndex         = 2
	QueryJoinOn            = 3
	QueryLimit             = 4
	QueryOffset            = 5
	QueryReqTotal          = 6
	QueryDebugLevel        = 7
	QueryAggregation       = 8
	QuerySelectFilter      = 9
	QuerySelectFunction    = 10
	QueryEnd               = 11
	QueryExplain           = 12
	QueryEqualPosition     = 13
	QueryUpdateField       = 14
	QueryAggregationLimit  = 15
	QueryAggregationOffset = 16
	QueryAggregationSort   = 17

	LeftJoin    = 0
	InnerJoin   = 1
	OrInnerJoin = 2
	Merge       = 3

	CacheModeOn         = 0
	CacheModeAggressive = 1
	CacheModeOff        = 2

	FormatJson  = 0
	FormatCJson = 1

	ModeUpdate = 0
	ModeInsert = 1
	ModeUpsert = 2
	ModeDelete = 3

	ModeNoCalc        = 0
	ModeCachedTotal   = 1
	ModeAccurateTotal = 2

	QueryResultEnd         = 0
	QueryResultAggregation = 1
	QueryResultExplain     = 2

	ResultsFormatMask = 0xF
	ResultsPure       = 0x0
	ResultsPtrs       = 0x1
	ResultsCJson      = 0x2
	ResultsJson       = 0x3

	ResultsWithPayloadTypes = 0x10
	ResultsWithItemID       = 0x20
	ResultsWithPercents     = 0x40
	ResultsWithNsID         = 0x80
	ResultsWithJoined       = 0x100

	IndexOptPK         = 1 << 7
	IndexOptArray      = 1 << 6
	IndexOptDense      = 1 << 5
	IndexOptAppendable = 1 << 4
	IndexOptSparse     = 1 << 3

	StorageOptEnabled               = 1
	StorageOptDropOnFileFormatError = 1 << 1
	StorageOptCreateIfMissing       = 1 << 2

	ErrOK               = 0
	ErrParseSQL         = 1
	ErrQueryExec        = 2
	ErrParams           = 3
	ErrLogic            = 4
	ErrParseJson        = 5
	ErrParseDSL         = 6
	ErrConflict         = 7
	ErrParseBin         = 8
	ErrForbidden        = 9
	ErrWasRelock        = 10
	ErrNotValid         = 11
	ErrNetwork          = 12
	ErrNotFound         = 13
	ErrStateInvalidated = 14
)

private go consts from type_consts.h and reindexer_ctypes.h

const CInt32Max = int(^uint32(0) >> 1)

Functions

func NewError

func NewError(text string, code int) error

func RegisterBinding

func RegisterBinding(name string, binding RawBinding)

Types

type Error

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

func (Error) Code

func (e Error) Code() int

func (Error) Error

func (e Error) Error() string

type FetchMore

type FetchMore interface {
	Fetch(offset, limit int, withItems bool) (err error)
}

FetchMore interface for partial loading results (used in cproto)

type IndexDef

type IndexDef struct {
	Name        string      `json:"name"`
	JSONPaths   []string    `json:"json_paths"`
	IndexType   string      `json:"index_type"`
	FieldType   string      `json:"field_type"`
	IsPK        bool        `json:"is_pk"`
	IsArray     bool        `json:"is_array"`
	IsDense     bool        `json:"is_dense"`
	IsSparse    bool        `json:"is_sparse"`
	CollateMode string      `json:"collate_mode"`
	SortOrder   string      `json:"sort_order_letters"`
	ExpireAfter int         `json:"expire_after"`
	Config      interface{} `json:"config"`
}

type Logger

type Logger interface {
	Printf(level int, fmt string, msg ...interface{})
}

Logger interface for reindexer

type NamespaceDef

type NamespaceDef struct {
	Namespace   string      `json:"name"`
	StorageOpts StorageOpts `json:"storage"`
}

type OptionBuiltinWithServer

type OptionBuiltinWithServer struct {
	StartupTimeout  time.Duration
	ShutdownTimeout time.Duration
	ServerConfig    *config.ServerConfig
}

type OptionCgoLimit

type OptionCgoLimit struct {
	CgoLimit int
}

type OptionConnPoolSize

type OptionConnPoolSize struct {
	ConnPoolSize int
}

type OptionReindexerInstance

type OptionReindexerInstance struct {
	Instance uintptr
}

type OptionRetryAttempts

type OptionRetryAttempts struct {
	Read  int
	Write int
}

type RawBinding

type RawBinding interface {
	Init(u *url.URL, options ...interface{}) error
	Clone() RawBinding
	OpenNamespace(namespace string, enableStorage, dropOnFileFormatError bool) error
	CloseNamespace(namespace string) error
	DropNamespace(namespace string) error
	EnableStorage(namespace string) error
	AddIndex(namespace string, indexDef IndexDef) error
	UpdateIndex(namespace string, indexDef IndexDef) error
	DropIndex(namespace, index string) error
	BeginTx(namespace string) (TxCtx, error)
	CommitTx(*TxCtx) (RawBuffer, error)
	RollbackTx(*TxCtx) error
	ModifyItemTx(txCtx *TxCtx, format int, data []byte, mode int, percepts []string, stateToken int) error

	PutMeta(namespace, key, data string) error
	GetMeta(namespace, key string) (RawBuffer, error)
	ModifyItem(nsHash int, namespace string, format int, data []byte, mode int, percepts []string, stateToken int) (RawBuffer, error)
	Select(query string, withItems bool, ptVersions []int32, fetchCount int) (RawBuffer, error)
	SelectQuery(rawQuery []byte, withItems bool, ptVersions []int32, fetchCount int) (RawBuffer, error)
	DeleteQuery(nsHash int, rawQuery []byte) (RawBuffer, error)
	UpdateQuery(nsHash int, rawQuery []byte) (RawBuffer, error)
	Commit(namespace string) error
	EnableLogger(logger Logger)
	DisableLogger()
	Ping() error
	Finalize() error
	Status() Status
}

Raw binding to reindexer

func GetBinding

func GetBinding(name string) RawBinding

type RawBindingChanging

type RawBindingChanging interface {
	OnChangeCallback(f func())
}

type RawBuffer

type RawBuffer interface {
	GetBuf() []byte
	Free()
}

go interface to reindexer_c.h interface

type Stats

type Stats struct {
	CountGetItem int
	TimeGetItem  time.Duration
	CountSelect  int
	TimeSelect   time.Duration
	CountInsert  int
	TimeInsert   time.Duration
	CountUpdate  int
	TimeUpdate   time.Duration
	CountUpsert  int
	TimeUpsert   time.Duration
	CountDelete  int
	TimeDelete   time.Duration
	CountJoin    int
	TimeJoin     time.Duration
}

type Status

type Status struct {
	Err     error
	CProto  StatusCProto
	Builtin StatusBuiltin
}

type StatusBuiltin

type StatusBuiltin struct {
	CGOLimit int
	CGOUsage int
}

type StatusCProto

type StatusCProto struct {
	ConnPoolSize   int
	ConnPoolUsage  int
	ConnQueueSize  int
	ConnQueueUsage int
}

type StorageOptions

type StorageOptions uint16

func (*StorageOptions) DropOnFileFormatError

func (so *StorageOptions) DropOnFileFormatError(value bool) *StorageOptions

func (*StorageOptions) Enabled

func (so *StorageOptions) Enabled(value bool) *StorageOptions

type StorageOpts

type StorageOpts struct {
	EnableStorage     bool `json:"enabled"`
	DropOnFormatError bool `json:"drop_on_file_format_error"`
	CreateIfMissing   bool `json:"create_if_missing"`
}

type TxCtx

type TxCtx struct {
	Result RawBuffer
	Id     uint64
}

go transanction context