postgres

package
v0.0.0-...-ec57856 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientInfo 

type ClientInfo struct {
	URL string
}

type Driver 

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

Driver contains all the function needed to be recognized as a libdata driver

func NewClient 

func NewClient(info *ClientInfo) (*Driver, error)

func (*Driver) BeginTransaction 

func (d *Driver) BeginTransaction(
	wf *libapplication.Workflow, useCache bool,
) error

BeginTransaction will create a new transaction and return it.

func (*Driver) CheckIDExist 

func (d *Driver) CheckIDExist(
	model *libdomain.EntityDefinition,
	wk *libapplication.Workflow, id string,
) error

func (*Driver) Close 

func (c *Driver) Close()

func (*Driver) CommitOrchestratorTransaction 

func (c *Driver) CommitOrchestratorTransaction(tx interface{})

func (*Driver) CommitTransaction 

func (d *Driver) CommitTransaction(wk *libapplication.Workflow) error

CommitTransaction will definitely save all the operations in the transaction.

func (*Driver) CreateTenant 

func (d *Driver) CreateTenant(wk *libdata.Workflow,
	models []*libdata.ModelDefinition, tenant *libdata.Tenant) error

CreateTenant will create the tenant in postgres, either a new schema or a new tenant record

func (*Driver) Delete 

func (d *Driver) Delete(
	model libdomain.TableInterface,
	wk *libapplication.Workflow, filters []*basepb.Where,
) error

Delete will delete the filtered records.

func (*Driver) EventsKO 

func (d *Driver) EventsKO(
	wk *libdata.Workflow, aggregate string, aggregateID string, name string, payload []byte,
) (libdata.EventInterface, error)

func (*Driver) EventsOK 

func (d *Driver) EventsOK(
	wk *libdata.Workflow, aggregate string, aggregateID string, name string, payload []byte,
) (libdata.EventInterface, error)

func (*Driver) GenerateScanFunc 

func (d *Driver) GenerateScanFunc(table libdomain.TableInterface) string

func (*Driver) Get 

func (d *Driver) Get(
	t *libdomain.EntityDefinition,
	wk *libapplication.Workflow, id string,
) (interface{}, error)

Select will return the filtered records.

func (*Driver) GetAggregateEvents 

func (d *Driver) GetAggregateEvents(
	wk libdomain.WorkflowInterface,
	a libdomain.AggregateInterface, id string,
) ([]*libdomain.Event, error)

func (*Driver) GetConnection 

func (d *Driver) GetConnection() *sqlx.DB

func (*Driver) GetImportRepository 

func (d *Driver) GetImportRepository() string

func (*Driver) GetOrchestratorTransaction 

func (c *Driver) GetOrchestratorTransaction() interface{}

func (*Driver) GetTenant 

func (d *Driver) GetTenant(
	wk *libdata.Workflow, tenant *libdata.Tenant,
) (*libdata.Tenant, error)

GetTenant will return the tenant.

func (*Driver) GetWorker 

func (c *Driver) GetWorker(taskQueue interface{}, options interface{}) libdata.WorkerInterface

func (*Driver) GetWorkflow 

func (c *Driver) GetWorkflow(id string) (
	string, string, []byte, []byte, error,
)

func (*Driver) InitDB 

func (d *Driver) InitDB(
	writeInfo *libdata.ClusterInfo, readInfo *libdata.ClusterInfo,
) (*libdata.Cluster, error)

InitDB will connect to the postgres database and return the connection

func (*Driver) Insert 

func (d *Driver) Insert(
	t libdomain.TableInterface, wk *libapplication.Workflow, records []interface{},
	insertBuildArgs func([]interface{}) ([]string, map[string]interface{}),
) (interface{}, error)

Insert will insert the new record in the database.

func (*Driver) MarkDispatchedEvent 

func (d *Driver) MarkDispatchedEvent(
	wk libdomain.WorkflowInterface,
	event *libdomain.Event,
) error

func (*Driver) MigrateAggregate 

func (d *Driver) MigrateAggregate(
	aggregate *libdomain.AggregateDefinition,
) error

nolint: gocyclo

func (*Driver) NewWorkflow 

func (c *Driver) NewWorkflow(
	name string, idempotencyKey string, serializedArgs []byte,
) (string, error)

func (*Driver) OnActivitySuccess 

func (c *Driver) OnActivitySuccess(workflowUUID string, step int, serializedResult []byte) error

func (*Driver) OnWorkflowError 

func (c *Driver) OnWorkflowError(name string) error

func (*Driver) OnWorkflowSuccess 

func (c *Driver) OnWorkflowSuccess(name string, serializedResult []byte) error

func (*Driver) RegisterEvents 

func (d *Driver) RegisterEvents(
	wk libdomain.WorkflowInterface,
	a libdomain.AggregateInterface,
	events []*libdomain.Event) error

RegisterEvent will register the event in the event model.

func (*Driver) RollbackOrchestratorTransaction 

func (c *Driver) RollbackOrchestratorTransaction(tx interface{})

func (*Driver) RollbackTransaction 

func (d *Driver) RollbackTransaction(wk *libapplication.Workflow) error

RollbackTransaction will cancel all the operations in the transaction.

func (*Driver) SearchActivity 

func (c *Driver) SearchActivity(
	workflowUUID string, step int,
) ([]byte, error)

func (*Driver) SearchWorkflow 

func (c *Driver) SearchWorkflow(idempotencyKey string) (string, error)

func (*Driver) Select 

func (d *Driver) Select(
	model libdomain.TableInterface, wk *libapplication.Workflow,
	query *basepb.ListQuery,
) (interface{}, error)

Select will return the filtered records.

func (*Driver) SupportTransaction 

func (d *Driver) SupportTransaction() bool

func (*Driver) Update 

func (d *Driver) Update(
	t libdomain.TableInterface, wk *libapplication.Workflow,
	filters []*basepb.Where, record interface{}, updateMask *fieldmask.FieldMask,
	updateBuildArgs func(interface{}, *fieldmask.FieldMask) ([]string, map[string]interface{}),
) (interface{}, error)

Update will update the data in the filtered records.

type InsertActivity 

type InsertActivity struct {
	Workflow *libapplication.Workflow
	Query    string
	Args     map[string]interface{}
}

func (*InsertActivity) MarshalArgs 

func (a *InsertActivity) MarshalArgs() ([]byte, error)

func (*InsertActivity) MarshalResult 

func (a *InsertActivity) MarshalResult(result interface{}) ([]byte, error)

func (*InsertActivity) Run 

func (a *InsertActivity) Run(
	ctx context.Context,
) (interface{}, error)

func (*InsertActivity) UnmarshalArgs 

func (a *InsertActivity) UnmarshalArgs(data []byte) error

func (*InsertActivity) UnmarshalResult 

func (a *InsertActivity) UnmarshalResult(data []byte, resultInterface interface{}) error

type Store 

type Store interface {
	InsertBuildArgs([]libdata.ModelInterface) ([]string, map[string]interface{})
	UpdateBuildArgs(interface{}, *fieldmask.FieldMask) ([]string, map[string]interface{})
}

Store is an interface containing the functions needed to build the arguments specifics to the model type.

type Tx 

type Tx struct {
	Sqlx *sqlx.Tx
}

Tx contains all the function needed to be recognized as a libdata Tx

func (*Tx) Exec 

func (tx *Tx) Exec(query string, args interface{}) error

Exec will execute the specified query in this transaction.

func (*Tx) QueryRows 

func (tx *Tx) QueryRows(q string, args interface{}) (*sqlx.Rows, error)

QueryRows will execute the specified query in this transaction and return the records.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.