sqlanomalygroupstore

Documentation

Index

• type AnomalyGroupStore
  • func New(db pool.Pool) (*AnomalyGroupStore, error)
  • func (s *AnomalyGroupStore) AddAnomalyID(ctx context.Context, group_id string, anomaly_id string) error
  • func (s *AnomalyGroupStore) AddCulpritIDs(ctx context.Context, group_id string, culprit_ids []string) error
  • func (s *AnomalyGroupStore) Create(ctx context.Context, subscription_name string, subscription_revision string, ...) (string, error)
  • func (s *AnomalyGroupStore) FindExistingGroup(ctx context.Context, subscription_name string, subscription_revision string, ...) ([]*pb.AnomalyGroup, error)
  • func (s *AnomalyGroupStore) LoadById(ctx context.Context, group_id string) (*pb.AnomalyGroup, error)
  • func (s *AnomalyGroupStore) UpdateBisectID(ctx context.Context, group_id string, bisection_id string) error
  • func (s *AnomalyGroupStore) UpdateReportedIssueID(ctx context.Context, group_id string, reported_issue_id string) error

Types

type AnomalyGroupStore

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

func New

func New(db pool.Pool) (*AnomalyGroupStore, error)

func (*AnomalyGroupStore) AddAnomalyID

func (s *AnomalyGroupStore) AddAnomalyID(ctx context.Context, group_id string, anomaly_id string) error

func (*AnomalyGroupStore) AddCulpritIDs

func (s *AnomalyGroupStore) AddCulpritIDs(ctx context.Context, group_id string, culprit_ids []string) error

func (*AnomalyGroupStore) Create

func (s *AnomalyGroupStore) Create(
	ctx context.Context,
	subscription_name string,
	subscription_revision string,
	domain_name string,
	benchmark_name string,
	start int64,
	end int64,
	action string) (string, error)

func (*AnomalyGroupStore) FindExistingGroup

func (s *AnomalyGroupStore) FindExistingGroup(
	ctx context.Context,
	subscription_name string,
	subscription_revision string,
	domain_name string,
	benchmark_name string,
	start_commit int64,
	end_commit int64,
	action string) ([]*pb.AnomalyGroup, error)

func (*AnomalyGroupStore) LoadById

func (s *AnomalyGroupStore) LoadById(
	ctx context.Context,
	group_id string) (*pb.AnomalyGroup, error)

func (*AnomalyGroupStore) UpdateBisectID

func (s *AnomalyGroupStore) UpdateBisectID(ctx context.Context, group_id string, bisection_id string) error

func (*AnomalyGroupStore) UpdateReportedIssueID

func (s *AnomalyGroupStore) UpdateReportedIssueID(ctx context.Context, group_id string, reported_issue_id string) error