postgres

Documentation

Index

• Variables
• type Pg
  • func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (pg *Pg, err error)
  • func (this *Pg) CountVariables(userId string, query model.VariablesQueryOptions) (result model.Count, err error)
  • func (this *Pg) DeleteVariable(userId string, key string) error
  • func (this *Pg) DeleteVariablesOfProcessDefinition(definitionId string) error
  • func (this *Pg) DeleteVariablesOfProcessInstance(instanceId string) error
  • func (this *Pg) GetVariable(userId string, key string) (result model.VariableWithUser, err error)
  • func (this *Pg) ListVariables(userId string, query model.VariablesQueryOptions) (result []model.VariableWithUnixTimestamp, err error)
  • func (this *Pg) SetVariable(variable model.VariableWithUser) error

Variables

var CreateTable = []func(db *Pg) error{}

Types

type Pg

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (pg *Pg, err error)

func (*Pg) CountVariables

func (this *Pg) CountVariables(userId string, query model.VariablesQueryOptions) (result model.Count, err error)

func (*Pg) DeleteVariable

func (this *Pg) DeleteVariable(userId string, key string) error

func (*Pg) DeleteVariablesOfProcessDefinition

func (this *Pg) DeleteVariablesOfProcessDefinition(definitionId string) error

func (*Pg) DeleteVariablesOfProcessInstance

func (this *Pg) DeleteVariablesOfProcessInstance(instanceId string) error

func (*Pg) GetVariable

func (this *Pg) GetVariable(userId string, key string) (result model.VariableWithUser, err error)

func (*Pg) ListVariables

func (this *Pg) ListVariables(userId string, query model.VariablesQueryOptions) (result []model.VariableWithUnixTimestamp, err error)

func (*Pg) SetVariable

func (this *Pg) SetVariable(variable model.VariableWithUser) error