Affected by 
Documentation
¶
Index ¶
- type Option
- type Store
- func (s *Store) Create(_ context.Context, webhook *auth.Webhook) error
- func (s *Store) Delete(_ context.Context, id string) error
- func (s *Store) DeleteByDAGName(ctx context.Context, dagName string) error
- func (s *Store) GetByDAGName(ctx context.Context, dagName string) (*auth.Webhook, error)
- func (s *Store) GetByID(_ context.Context, id string) (*auth.Webhook, error)
- func (s *Store) List(ctx context.Context) ([]*auth.Webhook, error)
- func (s *Store) Update(_ context.Context, webhook *auth.Webhook) error
- func (s *Store) UpdateLastUsed(_ context.Context, id string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store implements auth.WebhookStore using the local filesystem. Webhooks are stored as individual JSON files in the configured directory. Thread-safe through internal locking.
func New ¶
New creates a new file-based webhook store. The baseDir must be non-empty; provided Option functions are applied to the store. If baseDir does not exist it is created with directory permissions 0750, and an initial in-memory index is built from existing webhook files.
func (*Store) DeleteByDAGName ¶
DeleteByDAGName removes a webhook by its DAG name.
func (*Store) GetByDAGName ¶
GetByDAGName retrieves the webhook for a specific DAG.
Source Files
Click to show internal directories.
Click to hide internal directories.