view

Documentation

Index

• type View
  • func StartView(sqlClient *sql.DB, idGenerator id.Generator, queries *query.Queries) (*View, error)
  • func (v *View) ApplicationByOIDCClientID(ctx context.Context, clientID string) (*query.App, error)
  • func (v *View) ApplicationByProjecIDAndAppName(ctx context.Context, projectID, appName string) (_ *query.App, err error)
  • func (v *View) DeleteSessionTokens(agentID, userID, instanceID string, event *models.Event) error
  • func (v *View) DeleteToken(tokenID, instanceID string, event *models.Event) error
  • func (v *View) GetLatestTokenFailedEvent(sequence uint64, instanceID string) (*repository.FailedEvent, error)
  • func (v *View) GetLatestTokenSequence(instanceID string) (*repository.CurrentSequence, error)
  • func (v *View) Health() (err error)
  • func (v *View) ProcessedTokenFailedEvent(failedEvent *repository.FailedEvent) error
  • func (v *View) ProcessedTokenSequence(event *models.Event) error
  • func (v *View) PutToken(token *usr_view_model.TokenView, event *models.Event) error
  • func (v *View) TokenByIDs(tokenID, userID, instanceID string) (*usr_view_model.TokenView, error)
  • func (v *View) UpdateTokenSpoolerRunTimestamp() error

Types

type View

type View struct {
	Db    *gorm.DB
	Query *query.Queries
	// contains filtered or unexported fields
}

func StartView

func StartView(sqlClient *sql.DB, idGenerator id.Generator, queries *query.Queries) (*View, error)

func (*View) ApplicationByOIDCClientID

func (v *View) ApplicationByOIDCClientID(ctx context.Context, clientID string) (*query.App, error)

func (*View) ApplicationByProjecIDAndAppName

func (v *View) ApplicationByProjecIDAndAppName(ctx context.Context, projectID, appName string) (_ *query.App, err error)

func (*View) DeleteSessionTokens

func (v *View) DeleteSessionTokens(agentID, userID, instanceID string, event *models.Event) error

func (*View) DeleteToken

func (v *View) DeleteToken(tokenID, instanceID string, event *models.Event) error

func (*View) GetLatestTokenFailedEvent

func (v *View) GetLatestTokenFailedEvent(sequence uint64, instanceID string) (*repository.FailedEvent, error)

func (*View) GetLatestTokenSequence

func (v *View) GetLatestTokenSequence(instanceID string) (*repository.CurrentSequence, error)

func (*View) Health

func (v *View) Health() (err error)

func (*View) ProcessedTokenFailedEvent

func (v *View) ProcessedTokenFailedEvent(failedEvent *repository.FailedEvent) error

func (*View) ProcessedTokenSequence

func (v *View) ProcessedTokenSequence(event *models.Event) error

func (*View) PutToken

func (v *View) PutToken(token *usr_view_model.TokenView, event *models.Event) error

func (*View) TokenByIDs

func (v *View) TokenByIDs(tokenID, userID, instanceID string) (*usr_view_model.TokenView, error)

func (*View) UpdateTokenSpoolerRunTimestamp

func (v *View) UpdateTokenSpoolerRunTimestamp() error