namespace

Documentation

Index

• func NewRecordAlreadyExists(id int64) error
• type Logger
• type Namespace
• type RecordAlreadyExistsError
  • func (e RecordAlreadyExistsError) Error() string
  • func (e RecordAlreadyExistsError) Is(err error) bool
• type WithIndexes
  • func CreateNamespace[R record.Record]() *WithIndexes[R]
  • func (ns *WithIndexes[R]) AddIndex(index indexes.Index[R])
  • func (ns *WithIndexes[R]) Delete(id int64) error
  • func (ns *WithIndexes[R]) Get(id int64) (R, bool)
  • func (ns *WithIndexes[R]) Insert(item R) error
  • func (ns *WithIndexes[R]) PreselectForExecutor(conditions where.Conditions[R]) ([]R, error)
  • func (ns *WithIndexes[R]) SetLogger(logger Logger)
  • func (ns *WithIndexes[R]) Upsert(item R) error

Functions

func NewRecordAlreadyExists

func NewRecordAlreadyExists(id int64) error

Types

type Logger

type Logger interface {
	Println(args ...any)
}

type Namespace

type Namespace[R record.Record] interface {
	Get(id int64) (R, bool)
	Insert(item R) error
	Delete(id int64) error
	Upsert(item R) error
	executor.Selector[R]
}

type RecordAlreadyExistsError

type RecordAlreadyExistsError struct {
	ID int64
}

func (RecordAlreadyExistsError) Error

func (e RecordAlreadyExistsError) Error() string

func (RecordAlreadyExistsError) Is

func (e RecordAlreadyExistsError) Is(err error) bool

type WithIndexes

type WithIndexes[R record.Record] struct {
	// contains filtered or unexported fields
}

func CreateNamespace

func CreateNamespace[R record.Record]() *WithIndexes[R]

func (*WithIndexes[R]) AddIndex

func (ns *WithIndexes[R]) AddIndex(index indexes.Index[R])

func (*WithIndexes[R]) Delete

func (ns *WithIndexes[R]) Delete(id int64) error

func (*WithIndexes[R]) Get

func (ns *WithIndexes[R]) Get(id int64) (R, bool)

func (*WithIndexes[R]) Insert

func (ns *WithIndexes[R]) Insert(item R) error

func (*WithIndexes[R]) PreselectForExecutor

func (ns *WithIndexes[R]) PreselectForExecutor(conditions where.Conditions[R]) (
	[]R,
	error,
)

func (*WithIndexes[R]) SetLogger

func (ns *WithIndexes[R]) SetLogger(logger Logger)

func (*WithIndexes[R]) Upsert

func (ns *WithIndexes[R]) Upsert(item R) error