kallax

package module

Go to main page

Versions in this module

v0

v0.13.0

Feb 16, 2017

Changes in this version

+ var ErrCantSetID = errors.New(...)

+ var ErrManyToManyNotSupported = errors.New("kallax: many to many relationships are not supported")

+ var ErrNotFound = errors.New("kallax: entity not found")

+ var ErrRawScanBatching = errors.New("kallax: cannot perform a raw scan on a batching result set")

+ func ApplyAfterEvents(r Record, wasPersisted bool) error

+ func ApplyBeforeEvents(r Record) error

+ type AfterDeleter interface

+ AfterDelete func() error

+ type AfterInserter interface

+ AfterInsert func() error

+ type AfterSaver interface

+ AfterSave func() error

+ type AfterUpdater interface

+ AfterUpdate func() error

+ type ArraySchemaField interface

+ type BeforeDeleter interface

+ BeforeDelete func() error

+ type BeforeInserter interface

+ BeforeInsert func() error

+ type BeforeSaver interface

+ BeforeSave func() error

+ type BeforeUpdater interface

+ BeforeUpdate func() error

type Condition

+ func JSONContainedBy(col SchemaField, elem interface{}) Condition

+ func JSONContains(col SchemaField, elem interface{}) Condition

+ func JSONContainsAllKeys(col SchemaField, keys ...string) Condition

+ func JSONContainsAny(col SchemaField, elems ...interface{}) Condition

+ func JSONContainsAnyKey(col SchemaField, keys ...string) Condition

+ func JSONIsArray(col SchemaField) Condition

+ func JSONIsObject(col SchemaField) Condition

+ type Identifier interface

+ Equals func(Identifier) bool

+ IsEmpty func() bool

+ Raw func() interface{}

+ type JSONKeyType string

+ const JSONAny

+ const JSONBool

+ const JSONFloat

+ const JSONInt

+ const JSONText

+ type JSONSchemaArray struct

+ func NewJSONSchemaArray(field string, paths ...string) *JSONSchemaArray

+ func (f *JSONSchemaArray) QualifiedName(schema Schema) string

+ func (f *JSONSchemaArray) String() string

+ type JSONSchemaKey struct

+ func NewJSONSchemaKey(typ JSONKeyType, field string, paths ...string) *JSONSchemaKey

+ func (f *JSONSchemaKey) QualifiedName(schema Schema) string

+ func (f *JSONSchemaKey) String() string

+ type NumericID int64

+ func (id *NumericID) Scan(src interface{}) error

+ func (id NumericID) Equals(other Identifier) bool

+ func (id NumericID) IsEmpty() bool

+ func (id NumericID) Raw() interface{}

+ func (id NumericID) String() string

+ func (id NumericID) Value() (driver.Value, error)

type SchemaField

+ func AtJSONPath(field SchemaField, typ JSONKeyType, path ...string) SchemaField

+ type ULID uuid.UUID

+ func NewULID() ULID

+ func (id *ULID) Scan(src interface{}) error

+ func (id ULID) Equals(other Identifier) bool

+ func (id ULID) IsEmpty() bool

+ func (id ULID) Raw() interface{}

+ func (id ULID) String() string

+ func (id ULID) Value() (driver.Value, error)

+ type UUID uuid.UUID

+ func (id *UUID) Scan(src interface{}) error

+ func (id UUID) Equals(other Identifier) bool

+ func (id UUID) IsEmpty() bool

+ func (id UUID) Raw() interface{}

+ func (id UUID) String() string

+ func (id UUID) Value() (driver.Value, error)

v0.12.0

Jan 31, 2017

Changes in this version

+ var ErrNoMoreRows = errors.New("kallax: there are no more rows in the result set")

+ func VirtualColumn(col string, r Record) sql.Scanner

type BaseQuery

+ func (q *BaseQuery) Schema() Schema

+ type BaseResultSet struct

+ func (rs *BaseResultSet) Get(schema Schema) (Record, error)

+ func (rs *BaseResultSet) RawScan(dest ...interface{}) error

+ func (rs *BaseResultSet) Scan(record Record) error

type BaseSchema

+ func (s *BaseSchema) New() Record

+ type BatchingResultSet struct

+ func NewBatchingResultSet(runner *batchQueryRunner) *BatchingResultSet

+ func (rs *BatchingResultSet) Close() error

+ func (rs *BatchingResultSet) Get(_ Schema) (Record, error)

+ func (rs *BatchingResultSet) Next() bool

+ func (rs *BatchingResultSet) RawScan(_ ...interface{}) error

type Condition

+ func ArrayContainedBy(col SchemaField, values ...interface{}) Condition

+ func ArrayContains(col SchemaField, values ...interface{}) Condition

+ func ArrayEq(col SchemaField, values ...interface{}) Condition

+ func ArrayGt(col SchemaField, values ...interface{}) Condition

+ func ArrayGtOrEq(col SchemaField, values ...interface{}) Condition

+ func ArrayLt(col SchemaField, values ...interface{}) Condition

+ func ArrayLtOrEq(col SchemaField, values ...interface{}) Condition

+ func ArrayNotEq(col SchemaField, values ...interface{}) Condition

+ func ArrayOverlap(col SchemaField, values ...interface{}) Condition

+ type ForeignKey struct

+ Inverse bool

+ func NewForeignKey(name string, inverse bool) *ForeignKey

type Model

+ func (m *Model) AddVirtualColumn(name string, v interface{})

+ func (m *Model) ClearVirtualColumns()

+ func (m *Model) VirtualColumn(name string) interface{}

type Query

+ Schema func() Schema

+ type RecordConstructor func() Record

+ type RecordWithSchema struct

+ Record Record

+ Schema Schema

type Relationship

+ Filter Condition

+ Type RelationshipType

+ type RelationshipType byte

+ const ManyToMany

+ const OneToMany

+ const OneToOne

type ResultSet

+ Get func(Schema) (Record, error)

+ Next func() bool

type Schema

+ New func() Record

type Timestamps

+ func (t *Timestamps) BeforeSave() error

+ type VirtualColumnContainer interface

+ AddVirtualColumn func(string, interface{})

+ ClearVirtualColumns func()

+ VirtualColumn func(string) interface{}

v0.10.0

Jan 24, 2017

Changes in this version

+ var ErrEmptyID = errors.New("a record without id is not allowed")

+ var ErrInvalidTxCallback = errors.New("invalid transaction callback given")

+ var ErrNewDocument = errors.New("cannot updated a new document")

+ var ErrNoRowUpdate = errors.New("update affected no rows")

+ var ErrNonNewDocument = errors.New("cannot insert a non new document")

+ var ErrNotWritable = errors.New("record is not writable")

+ var ErrRawScan = fmt.Errorf("result set comes from raw query, use RawScan instead")

+ var ErrStop = errors.New("stopped ForEach execution")

+ var ErrTransactionInsideTransaction = errors.New("can't start a transaction inside a transaction")

+ func ColumnNames(columns []SchemaField) []string

+ func RecordValues(record Valuer, columns ...string) ([]interface{}, error)

+ type BaseQuery struct

+ func NewBaseQuery(schema Schema) *BaseQuery

+ func (q *BaseQuery) AddRelation(schema Schema, field string) error

+ func (q *BaseQuery) BatchSize(size uint64)

+ func (q *BaseQuery) Copy() *BaseQuery

+ func (q *BaseQuery) GetBatchSize() uint64

+ func (q *BaseQuery) GetLimit() uint64

+ func (q *BaseQuery) GetOffset() uint64

+ func (q *BaseQuery) Limit(n uint64)

+ func (q *BaseQuery) Offset(n uint64)

+ func (q *BaseQuery) Order(cols ...ColumnOrder)

+ func (q *BaseQuery) Select(columns ...SchemaField)

+ func (q *BaseQuery) SelectNot(columns ...SchemaField)

+ func (q *BaseQuery) String() string

+ func (q *BaseQuery) Where(cond Condition)

+ type BaseSchema struct

+ func NewBaseSchema(table, alias string, id SchemaField, fks ForeignKeys, columns ...SchemaField) *BaseSchema

+ func (s *BaseSchema) Alias() string

+ func (s *BaseSchema) Columns() []SchemaField

+ func (s *BaseSchema) ForeignKey(field string) (SchemaField, bool)

+ func (s *BaseSchema) ID() SchemaField

+ func (s *BaseSchema) Table() string

+ func (s *BaseSchema) WithAlias(field string) Schema

+ type BaseSchemaField struct

+ func (f *BaseSchemaField) QualifiedName(schema Schema) string

+ func (f BaseSchemaField) String() string

+ type ColumnAddresser interface

+ ColumnAddress func(string) (interface{}, error)

+ type ColumnOrder interface

+ ToSql func(Schema) string

+ func Asc(col SchemaField) ColumnOrder

+ func Desc(col SchemaField) ColumnOrder

+ type Condition func(Schema) squirrel.Sqlizer

+ func And(conds ...Condition) Condition

+ func Eq(col SchemaField, value interface{}) Condition

+ func Gt(col SchemaField, n interface{}) Condition

+ func GtOrEq(col SchemaField, n interface{}) Condition

+ func In(col SchemaField, values ...interface{}) Condition

+ func Lt(col SchemaField, value interface{}) Condition

+ func LtOrEq(col SchemaField, n interface{}) Condition

+ func Neq(col SchemaField, n interface{}) Condition

+ func Not(cond Condition) Condition

+ func NotIn(col SchemaField, values ...interface{}) Condition

+ func Or(conds ...Condition) Condition

+ type ForeignKeys map[string]SchemaField

+ type ID uuid.UUID

+ func NewID() ID

+ func (id *ID) Scan(src interface{}) error

+ func (id ID) IsEmpty() bool

+ func (id ID) String() string

+ func (id ID) Value() (driver.Value, error)

+ type Identifiable interface

+ GetID func() ID

+ SetID func(id ID)

+ type Model struct

+ ID ID

+ func NewModel() Model

+ func (i *Model) GetID() ID

+ func (i *Model) SetID(id ID)

+ func (m *Model) IsPersisted() bool

+ func (m *Model) IsWritable() bool

+ type Persistable interface

+ IsPersisted func() bool

+ type Query interface

+ GetBatchSize func() uint64

+ GetLimit func() uint64

+ GetOffset func() uint64

+ type Record interface

+ type Relationable interface

+ NewRelationshipRecord func(string) (Record, error)

+ SetRelationship func(string, Record) error

+ type Relationship struct

+ Field string

+ Schema Schema

+ type ResultSet struct

+ func NewResultSet(rows *sql.Rows, readOnly bool, relationships []Relationship, columns ...string) *ResultSet

+ func (rs *ResultSet) RawScan(dest ...interface{}) error

+ func (rs *ResultSet) Scan(record Record) error

+ type Schema interface

+ Alias func() string

+ Columns func() []SchemaField

+ ForeignKey func(string) (SchemaField, bool)

+ ID func() SchemaField

+ Table func() string

+ WithAlias func(string) Schema

+ type SchemaField interface

+ QualifiedName func(Schema) string

+ String func() string

+ func NewSchemaField(name string) SchemaField

+ type Store struct

+ func NewStore(db *sql.DB, schema Schema) *Store

+ func (s *Store) Count(q Query) (count int64, err error)

+ func (s *Store) Delete(record Record) error

+ func (s *Store) Find(q Query) (*ResultSet, error)

+ func (s *Store) Insert(record Record) error

+ func (s *Store) MustCount(q Query) int64

+ func (s *Store) MustFind(q Query) *ResultSet

+ func (s *Store) RawExec(sql string, params ...interface{}) (int64, error)

+ func (s *Store) RawQuery(sql string, params ...interface{}) (*ResultSet, error)

+ func (s *Store) Reload(record Record) error

+ func (s *Store) Save(record Record) (updated bool, err error)

+ func (s *Store) Transaction(callback func(*Store) error) error

+ func (s *Store) Update(record Record, cols ...SchemaField) (int64, error)

+ type Timestamps struct

+ CreatedAt time.Time

+ UpdatedAt time.Time

+ func (t *Timestamps) BeforePersist() error

+ func (t *Timestamps) Timestamp()

+ type Valuer interface

+ Value func(string) (interface{}, error)

+ type Writable interface

+ IsWritable func() bool

Other modules containing this package

gopkg.in/src-d/go-kallax.v1

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