crud

Documentation

Index

• type Crud
• type Module
  • func Init(removeProjectScope bool) *Module
  • func (m *Module) Aggregate(ctx context.Context, dbType, project, col string, req *model.AggregateRequest) (interface{}, error)
  • func (m *Module) Batch(ctx context.Context, dbType, project string, req *model.BatchRequest) error
  • func (m *Module) Create(ctx context.Context, dbType, project, col string, req *model.CreateRequest) error
  • func (m *Module) CreateProjectIfNotExists(ctx context.Context, project, dbType string) error
  • func (m *Module) Delete(ctx context.Context, dbType, project, col string, req *model.DeleteRequest) error
  • func (m *Module) DeleteTable(ctx context.Context, project, dbType, col string) error
  • func (m *Module) DescribeTable(ctx context.Context, dbType, project, col string) ([]utils.FieldType, []utils.ForeignKeysType, error)
  • func (m *Module) GetCollections(ctx context.Context, project, dbType string) ([]utils.DatabaseCollections, error)
  • func (m *Module) GetConnectionState(ctx context.Context, dbType string) bool
  • func (m *Module) InternalCreate(ctx context.Context, dbType, project, col string, req *model.CreateRequest) error
  • func (m *Module) InternalDelete(ctx context.Context, dbType, project, col string, req *model.DeleteRequest) error
  • func (m *Module) InternalUpdate(ctx context.Context, dbType, project, col string, req *model.UpdateRequest) error
  • func (m *Module) RawBatch(ctx context.Context, dbType string, batchedQueries []string) error
  • func (m *Module) Read(ctx context.Context, dbType, project, col string, req *model.ReadRequest) (interface{}, error)
  • func (m *Module) SetConfig(project string, crud config.Crud) error
  • func (m *Module) SetHooks(hooks *model.CrudHooks, metricHook model.MetricCrudHook)
  • func (m *Module) Update(ctx context.Context, dbType, project, col string, req *model.UpdateRequest) error

Types

type Crud

type Crud interface {
	Create(ctx context.Context, project, col string, req *model.CreateRequest) (int64, error)
	Read(ctx context.Context, project, col string, req *model.ReadRequest) (int64, interface{}, error)
	Update(ctx context.Context, project, col string, req *model.UpdateRequest) (int64, error)
	Delete(ctx context.Context, project, col string, req *model.DeleteRequest) (int64, error)
	Aggregate(ctx context.Context, project, col string, req *model.AggregateRequest) (interface{}, error)
	Batch(ctx context.Context, project string, req *model.BatchRequest) ([]int64, error)
	DescribeTable(ctc context.Context, project, dbType, col string) ([]utils.FieldType, []utils.ForeignKeysType, error)
	RawExec(ctx context.Context, project string) error
	GetCollections(ctx context.Context, project string) ([]utils.DatabaseCollections, error)
	DeleteCollection(ctx context.Context, project, col string) error
	RawBatch(ctx context.Context, batchedQueries []string) error
	GetDBType() utils.DBType
	IsClientSafe() error
	Close() error
	GetConnectionState(ctx context.Context, dbType string) bool
}

Crud abstracts the implementation crud operations of databases

type Module

type Module struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Module is the root block providing convenient wrappers

func Init

func Init(removeProjectScope bool) *Module

Init create a new instance of the Module object

func (*Module) Aggregate

func (m *Module) Aggregate(ctx context.Context, dbType, project, col string, req *model.AggregateRequest) (interface{}, error)

Aggregate performs an aggregation defined via the pipeline

func (*Module) Batch

func (m *Module) Batch(ctx context.Context, dbType, project string, req *model.BatchRequest) error

Batch performs a batch operation on the database

func (*Module) Create

func (m *Module) Create(ctx context.Context, dbType, project, col string, req *model.CreateRequest) error

Create inserts a document (or multiple when op is "all") into the database based on dbType

func (*Module) CreateProjectIfNotExists

func (m *Module) CreateProjectIfNotExists(ctx context.Context, project, dbType string) error

GetCollections returns collection / tables name of specified database

func (*Module) Delete

func (m *Module) Delete(ctx context.Context, dbType, project, col string, req *model.DeleteRequest) error

Delete removes the document(s) which match a query from the database based on dbType

func (*Module) DeleteTable

func (m *Module) DeleteTable(ctx context.Context, project, dbType, col string) error

DeleteTable drop specified table from database

func (*Module) DescribeTable

func (m *Module) DescribeTable(ctx context.Context, dbType, project, col string) ([]utils.FieldType, []utils.ForeignKeysType, error)

DescribeTable performs a db operation for describing a table

func (*Module) GetCollections

func (m *Module) GetCollections(ctx context.Context, project, dbType string) ([]utils.DatabaseCollections, error)

GetCollections returns collection / tables name of specified database

func (*Module) GetConnectionState

func (m *Module) GetConnectionState(ctx context.Context, dbType string) bool

GetConnectionState gets the current state of client

func (*Module) InternalCreate

func (m *Module) InternalCreate(ctx context.Context, dbType, project, col string, req *model.CreateRequest) error

InternalCreate inserts a document (or multiple when op is "all") into the database based on dbType. It does not invoke any hooks. This should only be used by the eventing module.

func (*Module) InternalDelete

func (m *Module) InternalDelete(ctx context.Context, dbType, project, col string, req *model.DeleteRequest) error

InternalDelete removes the document(s) which match a query from the database based on dbType. It does not invoke any hooks. This should only be used by the eventing module.

func (*Module) InternalUpdate

func (m *Module) InternalUpdate(ctx context.Context, dbType, project, col string, req *model.UpdateRequest) error

InternalUpdate updates the document(s) which match a query from the database based on dbType. It does not invoke any hooks. This should only be used by the eventing module.

func (*Module) RawBatch

func (m *Module) RawBatch(ctx context.Context, dbType string, batchedQueries []string) error

RawBatch performs a db operaion for schema creation

func (*Module) Read

func (m *Module) Read(ctx context.Context, dbType, project, col string, req *model.ReadRequest) (interface{}, error)

Read returns the document(s) which match a query from the database based on dbType

func (*Module) SetConfig

func (m *Module) SetConfig(project string, crud config.Crud) error

SetConfig set the rules adn secret key required by the crud block

func (*Module) SetHooks

func (m *Module) SetHooks(hooks *model.CrudHooks, metricHook model.MetricCrudHook)

SetHooks sets the internal hooks

func (*Module) Update

func (m *Module) Update(ctx context.Context, dbType, project, col string, req *model.UpdateRequest) error

Update updates the document(s) which match a query from the database based on dbType