v2

Documentation

Index

• Variables
• type FeatureLastUsedInfoStorage
  • func NewFeatureLastUsedInfoStorage(qe mysql.QueryExecer) FeatureLastUsedInfoStorage
• type FeatureStorage
  • func NewFeatureStorage(qe mysql.QueryExecer) FeatureStorage
• type FlagTriggerStorage
  • func NewFlagTriggerStorage(qe mysql.QueryExecer) FlagTriggerStorage
• type SegmentStorage
  • func NewSegmentStorage(qe mysql.QueryExecer) SegmentStorage
• type SegmentUserStorage
  • func NewSegmentUserStorage(qe mysql.QueryExecer) SegmentUserStorage
• type TagStorage
  • func NewTagStorage(qe mysql.QueryExecer) TagStorage

Variables

var (
	ErrFeatureAlreadyExists          = errors.New("feature: already exists")
	ErrFeatureNotFound               = errors.New("feature: not found")
	ErrFeatureUnexpectedAffectedRows = errors.New("feature: unexpected affected rows")
)

var (
	ErrFlagTriggerAlreadyExists          = errors.New("flag trigger: already exists")
	ErrFlagTriggerNotFound               = errors.New("flag trigger: not found")
	ErrFlagTriggerUnexpectedAffectedRows = errors.New("flag trigger: unexpected affected rows")
)

var (
	ErrSegmentAlreadyExists          = errors.New("segment: already exists")
	ErrSegmentNotFound               = errors.New("segment: not found")
	ErrSegmentUnexpectedAffectedRows = errors.New("segment: unexpected affected rows")
)

var (
	ErrTagAlreadyExists = errors.New("tag: already exists")
	ErrTagNotFound      = errors.New("tag: not found")
)

var (
	ErrSegmentUserNotFound = errors.New("segmentUser: not found")
)

Types

type FeatureLastUsedInfoStorage

type FeatureLastUsedInfoStorage interface {
	GetFeatureLastUsedInfos(
		ctx context.Context,
		ids []string,
		environmentNamespace string,
	) ([]*domain.FeatureLastUsedInfo, error)
	UpsertFeatureLastUsedInfo(
		ctx context.Context,
		featureLastUsedInfos *domain.FeatureLastUsedInfo,
		environmentNamespace string,
	) error
}

func NewFeatureLastUsedInfoStorage

func NewFeatureLastUsedInfoStorage(qe mysql.QueryExecer) FeatureLastUsedInfoStorage

type FeatureStorage

type FeatureStorage interface {
	CreateFeature(ctx context.Context, feature *domain.Feature, environmentNamespace string) error
	UpdateFeature(ctx context.Context, feature *domain.Feature, environmentNamespace string) error
	GetFeature(ctx context.Context, key, environmentNamespace string) (*domain.Feature, error)
	ListFeatures(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Feature, int, int64, error)
	ListFeaturesFilteredByExperiment(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Feature, int, int64, error)
}

func NewFeatureStorage

func NewFeatureStorage(qe mysql.QueryExecer) FeatureStorage

type FlagTriggerStorage

type FlagTriggerStorage interface {
	CreateFlagTrigger(ctx context.Context, flagTrigger *domain.FlagTrigger) error
	UpdateFlagTrigger(ctx context.Context, flagTrigger *domain.FlagTrigger) error
	DeleteFlagTrigger(ctx context.Context, id, environmentNamespace string) error
	GetFlagTrigger(ctx context.Context, id, environmentNamespace string) (*domain.FlagTrigger, error)
	GetFlagTriggerByToken(ctx context.Context, token string) (*domain.FlagTrigger, error)
	ListFlagTriggers(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.FlagTrigger, int, int64, error)
}

func NewFlagTriggerStorage

func NewFlagTriggerStorage(
	qe mysql.QueryExecer,
) FlagTriggerStorage

type SegmentStorage

type SegmentStorage interface {
	CreateSegment(ctx context.Context, segment *domain.Segment, environmentNamespace string) error
	UpdateSegment(ctx context.Context, segment *domain.Segment, environmentNamespace string) error
	GetSegment(ctx context.Context, id, environmentNamespace string) (*domain.Segment, []string, error)
	ListSegments(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
		isInUseStatus *bool,
		environmentNamespace string,
	) ([]*proto.Segment, int, int64, map[string][]string, error)
}

func NewSegmentStorage

func NewSegmentStorage(qe mysql.QueryExecer) SegmentStorage

type SegmentUserStorage

type SegmentUserStorage interface {
	UpsertSegmentUsers(ctx context.Context, users []*proto.SegmentUser, environmentNamespace string) error
	GetSegmentUser(ctx context.Context, id, environmentNamespace string) (*domain.SegmentUser, error)
	ListSegmentUsers(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.SegmentUser, int, error)
}

func NewSegmentUserStorage

func NewSegmentUserStorage(qe mysql.QueryExecer) SegmentUserStorage

type TagStorage

type TagStorage interface {
	UpsertTag(ctx context.Context, tag *domain.Tag, environmentNamespace string) error
	ListTags(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Tag, int, int64, error)
}

func NewTagStorage

func NewTagStorage(qe mysql.QueryExecer) TagStorage