Documentation
¶
Index ¶
- type AlertRepository
- type NamespaceRepository
- func (r *NamespaceRepository) Commit(ctx context.Context) error
- func (r NamespaceRepository) Create(ctx context.Context, ns *namespace.EncryptedNamespace) error
- func (r NamespaceRepository) Delete(ctx context.Context, id uint64) error
- func (r NamespaceRepository) Get(ctx context.Context, id uint64) (*namespace.EncryptedNamespace, error)
- func (r NamespaceRepository) List(ctx context.Context) ([]namespace.EncryptedNamespace, error)
- func (r *NamespaceRepository) Rollback(ctx context.Context, err error) error
- func (r NamespaceRepository) Update(ctx context.Context, ns *namespace.EncryptedNamespace) error
- func (r *NamespaceRepository) WithTransaction(ctx context.Context) context.Context
- type ProviderRepository
- func (r ProviderRepository) Create(ctx context.Context, prov *provider.Provider) error
- func (r ProviderRepository) Delete(ctx context.Context, id uint64) error
- func (r ProviderRepository) Get(ctx context.Context, id uint64) (*provider.Provider, error)
- func (r ProviderRepository) List(ctx context.Context, flt provider.Filter) ([]provider.Provider, error)
- func (r ProviderRepository) Update(ctx context.Context, provDomain *provider.Provider) error
- type ReceiverRepository
- func (r ReceiverRepository) Create(ctx context.Context, rcv *receiver.Receiver) error
- func (r ReceiverRepository) Delete(ctx context.Context, id uint64) error
- func (r ReceiverRepository) Get(ctx context.Context, id uint64) (*receiver.Receiver, error)
- func (r ReceiverRepository) List(ctx context.Context, flt receiver.Filter) ([]receiver.Receiver, error)
- func (r ReceiverRepository) Update(ctx context.Context, rcv *receiver.Receiver) error
- type RuleRepository
- func (r *RuleRepository) Commit(ctx context.Context) error
- func (r *RuleRepository) List(ctx context.Context, flt rule.Filter) ([]rule.Rule, error)
- func (r *RuleRepository) Rollback(ctx context.Context, err error) error
- func (r *RuleRepository) Upsert(ctx context.Context, rl *rule.Rule) error
- func (r *RuleRepository) WithTransaction(ctx context.Context) context.Context
- type SubscriptionRepository
- func (r *SubscriptionRepository) Create(ctx context.Context, sub *subscription.Subscription) error
- func (r *SubscriptionRepository) Delete(ctx context.Context, id uint64) error
- func (r *SubscriptionRepository) Get(ctx context.Context, id uint64) (*subscription.Subscription, error)
- func (r *SubscriptionRepository) List(ctx context.Context, flt subscription.Filter) ([]subscription.Subscription, error)
- func (r *SubscriptionRepository) Update(ctx context.Context, sub *subscription.Subscription) error
- type TemplateRepository
- func (r TemplateRepository) Delete(ctx context.Context, name string) error
- func (r TemplateRepository) GetByName(ctx context.Context, name string) (*template.Template, error)
- func (r TemplateRepository) List(ctx context.Context, flt template.Filter) ([]template.Template, error)
- func (r TemplateRepository) Upsert(ctx context.Context, tmpl *template.Template) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertRepository ¶
type AlertRepository struct {
// contains filtered or unexported fields
}
AlertRepository talks to the store to read or insert data
func NewAlertRepository ¶
func NewAlertRepository(client *pgc.Client) *AlertRepository
NewAlertRepository returns repository struct
type NamespaceRepository ¶
type NamespaceRepository struct {
// contains filtered or unexported fields
}
NamespaceRepository talks to the store to read or insert data
func NewNamespaceRepository ¶
func NewNamespaceRepository(client *pgc.Client) *NamespaceRepository
NewNamespaceRepository returns repository struct
func (*NamespaceRepository) Commit ¶ added in v0.5.0
func (r *NamespaceRepository) Commit(ctx context.Context) error
func (NamespaceRepository) Create ¶
func (r NamespaceRepository) Create(ctx context.Context, ns *namespace.EncryptedNamespace) error
func (NamespaceRepository) Delete ¶
func (r NamespaceRepository) Delete(ctx context.Context, id uint64) error
func (NamespaceRepository) Get ¶
func (r NamespaceRepository) Get(ctx context.Context, id uint64) (*namespace.EncryptedNamespace, error)
func (NamespaceRepository) List ¶
func (r NamespaceRepository) List(ctx context.Context) ([]namespace.EncryptedNamespace, error)
func (*NamespaceRepository) Rollback ¶ added in v0.5.0
func (r *NamespaceRepository) Rollback(ctx context.Context, err error) error
func (NamespaceRepository) Update ¶
func (r NamespaceRepository) Update(ctx context.Context, ns *namespace.EncryptedNamespace) error
func (*NamespaceRepository) WithTransaction ¶ added in v0.5.0
func (r *NamespaceRepository) WithTransaction(ctx context.Context) context.Context
type ProviderRepository ¶
type ProviderRepository struct {
// contains filtered or unexported fields
}
ProviderRepository talks to the store to read or insert data
func NewProviderRepository ¶
func NewProviderRepository(client *pgc.Client) *ProviderRepository
NewProviderRepository returns repository struct
func (ProviderRepository) Delete ¶
func (r ProviderRepository) Delete(ctx context.Context, id uint64) error
type ReceiverRepository ¶
type ReceiverRepository struct {
// contains filtered or unexported fields
}
ReceiverRepository talks to the store to read or insert data
func NewReceiverRepository ¶
func NewReceiverRepository(client *pgc.Client) *ReceiverRepository
NewReceiverRepository returns repository struct
func (ReceiverRepository) Delete ¶
func (r ReceiverRepository) Delete(ctx context.Context, id uint64) error
type RuleRepository ¶
type RuleRepository struct {
// contains filtered or unexported fields
}
RuleRepository talks to the store to read or insert data
func NewRuleRepository ¶
func NewRuleRepository(client *pgc.Client) *RuleRepository
NewRuleRepository returns repository struct
func (*RuleRepository) Rollback ¶
func (r *RuleRepository) Rollback(ctx context.Context, err error) error
func (*RuleRepository) WithTransaction ¶
func (r *RuleRepository) WithTransaction(ctx context.Context) context.Context
type SubscriptionRepository ¶
type SubscriptionRepository struct {
// contains filtered or unexported fields
}
SubscriptionRepository talks to the store to read or insert data
func NewSubscriptionRepository ¶
func NewSubscriptionRepository(client *pgc.Client) *SubscriptionRepository
NewSubscriptionRepository returns SubscriptionRepository struct
func (*SubscriptionRepository) Create ¶
func (r *SubscriptionRepository) Create(ctx context.Context, sub *subscription.Subscription) error
func (*SubscriptionRepository) Delete ¶
func (r *SubscriptionRepository) Delete(ctx context.Context, id uint64) error
func (*SubscriptionRepository) Get ¶
func (r *SubscriptionRepository) Get(ctx context.Context, id uint64) (*subscription.Subscription, error)
func (*SubscriptionRepository) List ¶
func (r *SubscriptionRepository) List(ctx context.Context, flt subscription.Filter) ([]subscription.Subscription, error)
func (*SubscriptionRepository) Update ¶
func (r *SubscriptionRepository) Update(ctx context.Context, sub *subscription.Subscription) error
type TemplateRepository ¶
type TemplateRepository struct {
// contains filtered or unexported fields
}
TemplateRepository talks to the store to read or insert data
func NewTemplateRepository ¶
func NewTemplateRepository(client *pgc.Client) *TemplateRepository
NewTemplateRepository returns repository struct
func (TemplateRepository) Delete ¶
func (r TemplateRepository) Delete(ctx context.Context, name string) error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.