api

Documentation

Index

• func ExecuteProgressiveRolloutOperation(ctx context.Context, progressiveRollout *domain.ProgressiveRollout, ...) error
• type AutoOpsService
  • func NewAutoOpsService(mysqlClient mysql.Client, featureClient featureclient.Client, ...) *AutoOpsService
  • func (s *AutoOpsService) CreateAutoOpsRule(ctx context.Context, req *autoopsproto.CreateAutoOpsRuleRequest) (*autoopsproto.CreateAutoOpsRuleResponse, error)
  • func (s *AutoOpsService) CreateProgressiveRollout(ctx context.Context, req *autoopsproto.CreateProgressiveRolloutRequest) (*autoopsproto.CreateProgressiveRolloutResponse, error)
  • func (s *AutoOpsService) DeleteAutoOpsRule(ctx context.Context, req *autoopsproto.DeleteAutoOpsRuleRequest) (*autoopsproto.DeleteAutoOpsRuleResponse, error)
  • func (s *AutoOpsService) DeleteProgressiveRollout(ctx context.Context, req *autoopsproto.DeleteProgressiveRolloutRequest) (*autoopsproto.DeleteProgressiveRolloutResponse, error)
  • func (s *AutoOpsService) ExecuteAutoOps(ctx context.Context, req *autoopsproto.ExecuteAutoOpsRequest) (*autoopsproto.ExecuteAutoOpsResponse, error)
  • func (s *AutoOpsService) ExecuteProgressiveRollout(ctx context.Context, req *autoopsproto.ExecuteProgressiveRolloutRequest) (*autoopsproto.ExecuteProgressiveRolloutResponse, error)
  • func (s *AutoOpsService) GetAutoOpsRule(ctx context.Context, req *autoopsproto.GetAutoOpsRuleRequest) (*autoopsproto.GetAutoOpsRuleResponse, error)
  • func (s *AutoOpsService) GetProgressiveRollout(ctx context.Context, req *autoopsproto.GetProgressiveRolloutRequest) (*autoopsproto.GetProgressiveRolloutResponse, error)
  • func (s *AutoOpsService) ListAutoOpsRules(ctx context.Context, req *autoopsproto.ListAutoOpsRulesRequest) (*autoopsproto.ListAutoOpsRulesResponse, error)
  • func (s *AutoOpsService) ListOpsCounts(ctx context.Context, req *autoopsproto.ListOpsCountsRequest) (*autoopsproto.ListOpsCountsResponse, error)
  • func (s *AutoOpsService) ListProgressiveRollouts(ctx context.Context, req *autoopsproto.ListProgressiveRolloutsRequest) (*autoopsproto.ListProgressiveRolloutsResponse, error)
  • func (s *AutoOpsService) Register(server *grpc.Server)
  • func (s *AutoOpsService) StopProgressiveRollout(ctx context.Context, req *autoopsproto.StopProgressiveRolloutRequest) (*autoopsproto.StopProgressiveRolloutResponse, error)
  • func (s *AutoOpsService) UpdateAutoOpsRule(ctx context.Context, req *autoopsproto.UpdateAutoOpsRuleRequest) (*autoopsproto.UpdateAutoOpsRuleResponse, error)
• type Command
• type Option
  • func WithLogger(l *zap.Logger) Option

Functions

func ExecuteProgressiveRolloutOperation

func ExecuteProgressiveRolloutOperation(
	ctx context.Context,
	progressiveRollout *domain.ProgressiveRollout,
	feature *ftdomain.Feature,
	scheduleID, environmentNamespace string,
) error

Types

type AutoOpsService

type AutoOpsService struct {
	// contains filtered or unexported fields
}

func NewAutoOpsService

func NewAutoOpsService(
	mysqlClient mysql.Client,
	featureClient featureclient.Client,
	experimentClient experimentclient.Client,
	accountClient accountclient.Client,
	authClient authclient.Client,
	publisher publisher.Publisher,
	opts ...Option,
) *AutoOpsService

func (*AutoOpsService) CreateAutoOpsRule

func (s *AutoOpsService) CreateAutoOpsRule(
	ctx context.Context,
	req *autoopsproto.CreateAutoOpsRuleRequest,
) (*autoopsproto.CreateAutoOpsRuleResponse, error)

func (*AutoOpsService) CreateProgressiveRollout

func (s *AutoOpsService) CreateProgressiveRollout(
	ctx context.Context,
	req *autoopsproto.CreateProgressiveRolloutRequest,
) (*autoopsproto.CreateProgressiveRolloutResponse, error)

func (*AutoOpsService) DeleteAutoOpsRule

func (s *AutoOpsService) DeleteAutoOpsRule(
	ctx context.Context,
	req *autoopsproto.DeleteAutoOpsRuleRequest,
) (*autoopsproto.DeleteAutoOpsRuleResponse, error)

func (*AutoOpsService) DeleteProgressiveRollout

func (s *AutoOpsService) DeleteProgressiveRollout(
	ctx context.Context,
	req *autoopsproto.DeleteProgressiveRolloutRequest,
) (*autoopsproto.DeleteProgressiveRolloutResponse, error)

func (*AutoOpsService) ExecuteAutoOps

func (s *AutoOpsService) ExecuteAutoOps(
	ctx context.Context,
	req *autoopsproto.ExecuteAutoOpsRequest,
) (*autoopsproto.ExecuteAutoOpsResponse, error)

func (*AutoOpsService) ExecuteProgressiveRollout

func (s *AutoOpsService) ExecuteProgressiveRollout(
	ctx context.Context,
	req *autoopsproto.ExecuteProgressiveRolloutRequest,
) (*autoopsproto.ExecuteProgressiveRolloutResponse, error)

func (*AutoOpsService) GetAutoOpsRule

func (s *AutoOpsService) GetAutoOpsRule(
	ctx context.Context,
	req *autoopsproto.GetAutoOpsRuleRequest,
) (*autoopsproto.GetAutoOpsRuleResponse, error)

func (*AutoOpsService) GetProgressiveRollout

func (s *AutoOpsService) GetProgressiveRollout(
	ctx context.Context,
	req *autoopsproto.GetProgressiveRolloutRequest,
) (*autoopsproto.GetProgressiveRolloutResponse, error)

func (*AutoOpsService) ListAutoOpsRules

func (s *AutoOpsService) ListAutoOpsRules(
	ctx context.Context,
	req *autoopsproto.ListAutoOpsRulesRequest,
) (*autoopsproto.ListAutoOpsRulesResponse, error)

func (*AutoOpsService) ListOpsCounts

func (s *AutoOpsService) ListOpsCounts(
	ctx context.Context,
	req *autoopsproto.ListOpsCountsRequest,
) (*autoopsproto.ListOpsCountsResponse, error)

func (*AutoOpsService) ListProgressiveRollouts

func (s *AutoOpsService) ListProgressiveRollouts(
	ctx context.Context,
	req *autoopsproto.ListProgressiveRolloutsRequest,
) (*autoopsproto.ListProgressiveRolloutsResponse, error)

func (*AutoOpsService) Register

func (s *AutoOpsService) Register(server *grpc.Server)

func (*AutoOpsService) StopProgressiveRollout

func (s *AutoOpsService) StopProgressiveRollout(
	ctx context.Context,
	req *autoopsproto.StopProgressiveRolloutRequest,
) (*autoopsproto.StopProgressiveRolloutResponse, error)

func (*AutoOpsService) UpdateAutoOpsRule

func (s *AutoOpsService) UpdateAutoOpsRule(
	ctx context.Context,
	req *autoopsproto.UpdateAutoOpsRuleRequest,
) (*autoopsproto.UpdateAutoOpsRuleResponse, error)

type Command

type Command interface{}

type Option

type Option func(*options)

func WithLogger

func WithLogger(l *zap.Logger) Option