v2

Documentation

Index

• Variables
• type AutoOpsRuleStorage
  • func NewAutoOpsRuleStorage(qe mysql.QueryExecer) AutoOpsRuleStorage
• type WebhookStorage
  • func NewWebhookStorage(qe mysql.QueryExecer) WebhookStorage

Variables

var (
	ErrAutoOpsRuleAlreadyExists          = errors.New("autoOpsRule: already exists")
	ErrAutoOpsRuleNotFound               = errors.New("autoOpsRule: not found")
	ErrAutoOpsRuleUnexpectedAffectedRows = errors.New("autoOpsRule: unexpected affected rows")
)

var (
	ErrWebhookAlreadyExists          = errors.New("webhook: already exists")
	ErrWebhookNotFound               = errors.New("webhook: not found")
	ErrWebhookUnexpectedAffectedRows = errors.New("webhook: unexpected affected rows")
)

Types

type AutoOpsRuleStorage

type AutoOpsRuleStorage interface {
	CreateAutoOpsRule(ctx context.Context, e *domain.AutoOpsRule, environmentNamespace string) error
	UpdateAutoOpsRule(ctx context.Context, e *domain.AutoOpsRule, environmentNamespace string) error
	GetAutoOpsRule(ctx context.Context, id, environmentNamespace string) (*domain.AutoOpsRule, error)
	ListAutoOpsRules(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.AutoOpsRule, int, error)
}

func NewAutoOpsRuleStorage

func NewAutoOpsRuleStorage(qe mysql.QueryExecer) AutoOpsRuleStorage

type WebhookStorage

type WebhookStorage interface {
	CreateWebhook(ctx context.Context, webhook *domain.Webhook, environmentNamespace string) error
	UpdateWebhook(ctx context.Context, webhook *domain.Webhook, environmentNamespace string) error
	DeleteWebhook(ctx context.Context, id, environmentNamespace string) error
	GetWebhook(ctx context.Context, id, environmentNamespace string) (*domain.Webhook, error)
	ListWebhooks(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Webhook, int, int64, error)
}

func NewWebhookStorage

func NewWebhookStorage(
	qe mysql.QueryExecer,
) WebhookStorage