Documentation
¶
Index ¶
- type Postgres
- func (p *Postgres) ChangePassword(ctx context.Context, account *api.Account, password []byte) error
- func (p *Postgres) CreateAPIToken(ctx context.Context, apiToken *api.APIToken) error
- func (p *Postgres) CreateAccount(ctx context.Context, account *api.Account) error
- func (p *Postgres) CreateNamespace(ctx context.Context, namespace *api.Namespace) (string, error)
- func (p *Postgres) CreateQueueWorkflow(ctx context.Context, workflow *api.Workflow) error
- func (p *Postgres) CreateServiceToken(ctx context.Context, serviceToken *api.ServiceToken) error
- func (p *Postgres) CreateWorkflow(ctx context.Context, workflow *api.Workflow) error
- func (p *Postgres) DeleteAPIToken(ctx context.Context, token string) error
- func (p *Postgres) DeleteAccount(ctx context.Context, username string) error
- func (p *Postgres) DeleteAuthenticatorKey(ctx context.Context, key string) error
- func (p *Postgres) DeleteNamespace(ctx context.Context, id string) error
- func (p *Postgres) DeleteQueueWorkflow(ctx context.Context, id string) error
- func (p *Postgres) DeleteServiceToken(ctx context.Context, token string) error
- func (p *Postgres) DeleteWorkflow(ctx context.Context, id string) error
- func (p *Postgres) GetAPIToken(ctx context.Context, token string) (*api.APIToken, error)
- func (p *Postgres) GetAPITokens(ctx context.Context) ([]*api.APIToken, error)
- func (p *Postgres) GetAccount(ctx context.Context, username string) (*api.Account, error)
- func (p *Postgres) GetAccountByID(ctx context.Context, id string) (*api.Account, error)
- func (p *Postgres) GetAccounts(ctx context.Context) ([]*api.Account, error)
- func (p *Postgres) GetAuthenticatorKey(ctx context.Context, a auth.Authenticator, key string) ([]byte, error)
- func (p *Postgres) GetAuthenticatorKeys(ctx context.Context, a auth.Authenticator, prefix string) ([][]byte, error)
- func (p *Postgres) GetNamespace(ctx context.Context, id string) (*api.Namespace, error)
- func (p *Postgres) GetNamespaces(ctx context.Context) ([]*api.Namespace, error)
- func (p *Postgres) GetNextQueueWorkflow(ctx context.Context, queueType string, scope *api.ProcessorScope) (*api.Workflow, error)
- func (p *Postgres) GetPendingWorkflowsCount(ctx context.Context) (uint64, error)
- func (p *Postgres) GetServiceToken(ctx context.Context, token string) (*api.ServiceToken, error)
- func (p *Postgres) GetServiceTokens(ctx context.Context) ([]*api.ServiceToken, error)
- func (p *Postgres) GetTotalProcessorsCount(ctx context.Context) (uint64, error)
- func (p *Postgres) GetTotalWorkflowsCount(ctx context.Context) (uint64, error)
- func (p *Postgres) GetWorkflow(ctx context.Context, id string) (*api.Workflow, error)
- func (p *Postgres) GetWorkflows(ctx context.Context) ([]*api.Workflow, error)
- func (p *Postgres) SetAuthenticatorKey(ctx context.Context, a auth.Authenticator, key string, value []byte, ...) error
- func (p *Postgres) UpdateAPIToken(ctx context.Context, apiToken *api.APIToken) error
- func (p *Postgres) UpdateAccount(ctx context.Context, account *api.Account) error
- func (p *Postgres) UpdateNamespace(ctx context.Context, namespace *api.Namespace) error
- func (p *Postgres) UpdateServiceToken(ctx context.Context, serviceToken *api.ServiceToken) error
- func (p *Postgres) UpdateWorkflow(ctx context.Context, workflow *api.Workflow) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Postgres ¶
type Postgres struct {
// contains filtered or unexported fields
}
func NewPostgres ¶
func (*Postgres) ChangePassword ¶
func (*Postgres) CreateAPIToken ¶
func (*Postgres) CreateAccount ¶
func (*Postgres) CreateNamespace ¶
func (*Postgres) CreateQueueWorkflow ¶
func (*Postgres) CreateServiceToken ¶
func (*Postgres) CreateWorkflow ¶
func (*Postgres) DeleteAPIToken ¶
func (*Postgres) DeleteAccount ¶
func (*Postgres) DeleteAuthenticatorKey ¶ added in v0.3.1
func (*Postgres) DeleteNamespace ¶
func (*Postgres) DeleteQueueWorkflow ¶
func (*Postgres) DeleteServiceToken ¶
func (*Postgres) DeleteWorkflow ¶
func (*Postgres) GetAPIToken ¶
func (*Postgres) GetAPITokens ¶
func (*Postgres) GetAccount ¶
func (*Postgres) GetAccountByID ¶
func (*Postgres) GetAccounts ¶
func (*Postgres) GetAuthenticatorKey ¶
func (*Postgres) GetAuthenticatorKeys ¶
func (*Postgres) GetNamespace ¶
func (*Postgres) GetNamespaces ¶
func (*Postgres) GetNextQueueWorkflow ¶
func (*Postgres) GetPendingWorkflowsCount ¶ added in v0.3.1
func (*Postgres) GetServiceToken ¶
func (*Postgres) GetServiceTokens ¶
func (*Postgres) GetTotalProcessorsCount ¶ added in v0.3.1
func (*Postgres) GetTotalWorkflowsCount ¶ added in v0.3.1
func (*Postgres) GetWorkflow ¶
func (*Postgres) GetWorkflows ¶
func (*Postgres) SetAuthenticatorKey ¶
func (*Postgres) UpdateAPIToken ¶
func (*Postgres) UpdateAccount ¶
func (*Postgres) UpdateNamespace ¶
func (*Postgres) UpdateServiceToken ¶
Click to show internal directories.
Click to hide internal directories.