postgres

Documentation

Index

• type ListResourceByFilterRow
• type Store
  • func Open(conStr string, refreshInterval, extendInterval time.Duration) (*Store, error)
  • func (st *Store) Close() error
  • func (st *Store) Create(ctx context.Context, r resource.Resource, hooks ...resource.MutationHook) error
  • func (st *Store) CreateModule(ctx context.Context, m module.Module) error
  • func (st *Store) Delete(ctx context.Context, urn string, hooks ...resource.MutationHook) error
  • func (st *Store) DeleteModule(ctx context.Context, urn string) error
  • func (st *Store) GetByURN(ctx context.Context, urn string) (*resource.Resource, error)
  • func (st *Store) GetModule(ctx context.Context, urn string) (*module.Module, error)
  • func (st *Store) List(ctx context.Context, filter resource.Filter, withSpecConfigs bool) ([]resource.Resource, error)
  • func (st *Store) ListModules(ctx context.Context, project string) ([]module.Module, error)
  • func (st *Store) Migrate(ctx context.Context) error
  • func (st *Store) Revisions(ctx context.Context, selector resource.RevisionsSelector) ([]resource.Revision, error)
  • func (st *Store) SyncOne(ctx context.Context, syncFn resource.SyncFn) error
  • func (st *Store) Update(ctx context.Context, r resource.Resource, saveRevision bool, reason string, ...) error
  • func (st *Store) UpdateModule(ctx context.Context, m module.Module) error
• type TxFunc

Types

type ListResourceByFilterRow

type ListResourceByFilterRow struct {
	ID              int64
	Urn             string
	Kind            string
	Name            string
	Project         string
	CreatedAt       *time.Time
	UpdatedAt       *time.Time
	SpecConfigs     []byte
	StateStatus     string
	StateOutput     []byte
	StateModuleData []byte
	StateNextSync   *time.Time
	StateSyncResult []byte
	CreatedBy       string
	UpdatedBy       string
	Tags            pq.StringArray
	Dependencies    []byte
}

type Store

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

func Open

func Open(conStr string, refreshInterval, extendInterval time.Duration) (*Store, error)

Open returns store instance backed by PostgresQL.

func (*Store) Close

func (st *Store) Close() error

func (*Store) Create

func (st *Store) Create(ctx context.Context, r resource.Resource, hooks ...resource.MutationHook) error

func (*Store) CreateModule

func (st *Store) CreateModule(ctx context.Context, m module.Module) error

func (*Store) Delete

func (st *Store) Delete(ctx context.Context, urn string, hooks ...resource.MutationHook) error

func (*Store) DeleteModule

func (st *Store) DeleteModule(ctx context.Context, urn string) error

func (*Store) GetByURN

func (st *Store) GetByURN(ctx context.Context, urn string) (*resource.Resource, error)

func (*Store) GetModule

func (st *Store) GetModule(ctx context.Context, urn string) (*module.Module, error)

func (*Store) List

func (st *Store) List(ctx context.Context, filter resource.Filter, withSpecConfigs bool) ([]resource.Resource, error)

func (*Store) ListModules

func (st *Store) ListModules(ctx context.Context, project string) ([]module.Module, error)

func (*Store) Migrate

func (st *Store) Migrate(ctx context.Context) error

func (*Store) Revisions

func (st *Store) Revisions(ctx context.Context, selector resource.RevisionsSelector) ([]resource.Revision, error)

func (*Store) SyncOne

func (st *Store) SyncOne(ctx context.Context, syncFn resource.SyncFn) error

func (*Store) Update

func (st *Store) Update(ctx context.Context, r resource.Resource, saveRevision bool, reason string, hooks ...resource.MutationHook) error

func (*Store) UpdateModule

func (st *Store) UpdateModule(ctx context.Context, m module.Module) error

type TxFunc

type TxFunc func(ctx context.Context, tx *sqlx.Tx) error