v2

Documentation

Index

• Variables
• type AutoOpsRuleStorage
  • func NewAutoOpsRuleStorage(qe mysql.QueryExecer) AutoOpsRuleStorage
• type ProgressiveRolloutStorage
  • func NewProgressiveRolloutStorage(qe mysql.QueryExecer) ProgressiveRolloutStorage

Variables

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

var (
	ErrProgressiveRolloutAlreadyExists          = errors.New("progressiveRollout: already exists")
	ErrProgressiveRolloutNotFound               = errors.New("progressiveRollout: not found")
	ErrProgressiveRolloutUnexpectedAffectedRows = errors.New("progressiveRollout: 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 ProgressiveRolloutStorage

type ProgressiveRolloutStorage interface {
	CreateProgressiveRollout(
		ctx context.Context,
		progressiveRollout *domain.ProgressiveRollout,
		environmentNamespace string,
	) error
	GetProgressiveRollout(ctx context.Context, id, environmentNamespace string) (*domain.ProgressiveRollout, error)
	DeleteProgressiveRollout(ctx context.Context, id, environmentNamespace string) error
	ListProgressiveRollouts(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*autoopsproto.ProgressiveRollout, int64, int, error)
	UpdateProgressiveRollout(ctx context.Context,
		progressiveRollout *domain.ProgressiveRollout,
		environmentNamespace string,
	) error
}

func NewProgressiveRolloutStorage

func NewProgressiveRolloutStorage(qe mysql.QueryExecer) ProgressiveRolloutStorage