grpcreconcilersql

Documentation

Index

• type ClearErrorsForTeamParams
• type DBTX
• type DeleteConfigParams
• type DeleteStateForTeamParams
• type GetConfigParams
• type GetConfigRow
• type GetStateForTeamParams
• type ListParams
• type Querier
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) ClearErrorsForTeam(ctx context.Context, arg ClearErrorsForTeamParams) error
  • func (q *Queries) Count(ctx context.Context) (int64, error)
  • func (q *Queries) DeleteConfig(ctx context.Context, arg DeleteConfigParams) error
  • func (q *Queries) DeleteStateForTeam(ctx context.Context, arg DeleteStateForTeamParams) error
  • func (q *Queries) Get(ctx context.Context, name string) (*Reconciler, error)
  • func (q *Queries) GetConfig(ctx context.Context, arg GetConfigParams) ([]*GetConfigRow, error)
  • func (q *Queries) GetStateForTeam(ctx context.Context, arg GetStateForTeamParams) (*ReconcilerState, error)
  • func (q *Queries) List(ctx context.Context, arg ListParams) ([]*Reconciler, error)
  • func (q *Queries) SetErrorForTeam(ctx context.Context, arg SetErrorForTeamParams) error
  • func (q *Queries) SetLastSuccessfulSyncForTeam(ctx context.Context, argSlug slug.Slug) error
  • func (q *Queries) Upsert(ctx context.Context, arg UpsertParams) (*Reconciler, error)
  • func (q *Queries) UpsertConfig(ctx context.Context, arg UpsertConfigParams) error
  • func (q *Queries) UpsertState(ctx context.Context, arg UpsertStateParams) (*ReconcilerState, error)
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type Reconciler
• type ReconcilerState
• type SetErrorForTeamParams
• type UpsertConfigParams
• type UpsertParams
• type UpsertStateParams

Types

type ClearErrorsForTeamParams

type ClearErrorsForTeamParams struct {
	TeamSlug   slug.Slug
	Reconciler string
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteConfigParams

type DeleteConfigParams struct {
	Reconciler string
	Keys       []string
}

type DeleteStateForTeamParams

type DeleteStateForTeamParams struct {
	ReconcilerName string
	TeamSlug       slug.Slug
}

type GetConfigParams

type GetConfigParams struct {
	IncludeSecret  bool
	ReconcilerName string
}

type GetConfigRow

type GetConfigRow struct {
	Reconciler  string
	Key         string
	DisplayName string
	Description string
	Configured  bool
	Value       *string
	Secret      bool
}

type GetStateForTeamParams

type GetStateForTeamParams struct {
	ReconcilerName string
	TeamSlug       slug.Slug
}

type ListParams

type ListParams struct {
	Offset int32
	Limit  int32
}

type Querier

type Querier interface {
	ClearErrorsForTeam(ctx context.Context, arg ClearErrorsForTeamParams) error
	Count(ctx context.Context) (int64, error)
	DeleteConfig(ctx context.Context, arg DeleteConfigParams) error
	DeleteStateForTeam(ctx context.Context, arg DeleteStateForTeamParams) error
	Get(ctx context.Context, name string) (*Reconciler, error)
	GetConfig(ctx context.Context, arg GetConfigParams) ([]*GetConfigRow, error)
	GetStateForTeam(ctx context.Context, arg GetStateForTeamParams) (*ReconcilerState, error)
	List(ctx context.Context, arg ListParams) ([]*Reconciler, error)
	SetErrorForTeam(ctx context.Context, arg SetErrorForTeamParams) error
	SetLastSuccessfulSyncForTeam(ctx context.Context, argSlug slug.Slug) error
	Upsert(ctx context.Context, arg UpsertParams) (*Reconciler, error)
	UpsertConfig(ctx context.Context, arg UpsertConfigParams) error
	UpsertState(ctx context.Context, arg UpsertStateParams) (*ReconcilerState, error)
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) ClearErrorsForTeam

func (q *Queries) ClearErrorsForTeam(ctx context.Context, arg ClearErrorsForTeamParams) error

func (*Queries) Count

func (q *Queries) Count(ctx context.Context) (int64, error)

func (*Queries) DeleteConfig

func (q *Queries) DeleteConfig(ctx context.Context, arg DeleteConfigParams) error

func (*Queries) DeleteStateForTeam

func (q *Queries) DeleteStateForTeam(ctx context.Context, arg DeleteStateForTeamParams) error

func (*Queries) Get

func (q *Queries) Get(ctx context.Context, name string) (*Reconciler, error)

func (*Queries) GetConfig

func (q *Queries) GetConfig(ctx context.Context, arg GetConfigParams) ([]*GetConfigRow, error)

func (*Queries) GetStateForTeam

func (q *Queries) GetStateForTeam(ctx context.Context, arg GetStateForTeamParams) (*ReconcilerState, error)

func (*Queries) List

func (q *Queries) List(ctx context.Context, arg ListParams) ([]*Reconciler, error)

func (*Queries) SetErrorForTeam

func (q *Queries) SetErrorForTeam(ctx context.Context, arg SetErrorForTeamParams) error

func (*Queries) SetLastSuccessfulSyncForTeam

func (q *Queries) SetLastSuccessfulSyncForTeam(ctx context.Context, argSlug slug.Slug) error

func (*Queries) Upsert

func (q *Queries) Upsert(ctx context.Context, arg UpsertParams) (*Reconciler, error)

func (*Queries) UpsertConfig

func (q *Queries) UpsertConfig(ctx context.Context, arg UpsertConfigParams) error

func (*Queries) UpsertState

func (q *Queries) UpsertState(ctx context.Context, arg UpsertStateParams) (*ReconcilerState, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type Reconciler

type Reconciler struct {
	Name        string
	DisplayName string
	Description string
	Enabled     bool
	MemberAware bool
}

type ReconcilerState

type ReconcilerState struct {
	ID             uuid.UUID
	ReconcilerName string
	TeamSlug       slug.Slug
	Value          []byte
	CreatedAt      pgtype.Timestamptz
	UpdatedAt      pgtype.Timestamptz
}

type SetErrorForTeamParams

type SetErrorForTeamParams struct {
	CorrelationID uuid.UUID
	TeamSlug      slug.Slug
	Reconciler    string
	ErrorMessage  string
}

type UpsertConfigParams

type UpsertConfigParams struct {
	Reconciler  string
	Key         string
	DisplayName string
	Description string
	Secret      bool
}

type UpsertParams

type UpsertParams struct {
	Name         string
	DisplayName  string
	Description  string
	MemberAware  bool
	EnabledIfNew bool
}

type UpsertStateParams

type UpsertStateParams struct {
	ReconcilerName string
	TeamSlug       slug.Slug
	Value          []byte
}