v2

Documentation

Index

• Variables
• type AdminSubscriptionStorage
  • func NewAdminSubscriptionStorage(qe mysql.QueryExecer) AdminSubscriptionStorage
• type SubscriptionStorage
  • func NewSubscriptionStorage(qe mysql.QueryExecer) SubscriptionStorage

Variables

var (
	ErrAdminSubscriptionAlreadyExists          = errors.New("subscription: admin subscription already exists")
	ErrAdminSubscriptionNotFound               = errors.New("subscription: admin subscription not found")
	ErrAdminSubscriptionUnexpectedAffectedRows = errors.New("subscription: admin subscription unexpected affected rows")
)

var (
	ErrSubscriptionAlreadyExists          = errors.New("subscription: subscription already exists")
	ErrSubscriptionNotFound               = errors.New("subscription: subscription not found")
	ErrSubscriptionUnexpectedAffectedRows = errors.New("subscription: subscription unexpected affected rows")
)

Types

type AdminSubscriptionStorage

type AdminSubscriptionStorage interface {
	CreateAdminSubscription(ctx context.Context, e *domain.Subscription) error
	UpdateAdminSubscription(ctx context.Context, e *domain.Subscription) error
	DeleteAdminSubscription(ctx context.Context, id string) error
	GetAdminSubscription(ctx context.Context, id string) (*domain.Subscription, error)
	ListAdminSubscriptions(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Subscription, int, int64, error)
}

func NewAdminSubscriptionStorage

func NewAdminSubscriptionStorage(qe mysql.QueryExecer) AdminSubscriptionStorage

type SubscriptionStorage

type SubscriptionStorage interface {
	CreateSubscription(ctx context.Context, e *domain.Subscription, environmentNamespace string) error
	UpdateSubscription(ctx context.Context, e *domain.Subscription, environmentNamespace string) error
	DeleteSubscription(ctx context.Context, id, environmentNamespace string) error
	GetSubscription(ctx context.Context, id, environmentNamespace string) (*domain.Subscription, error)
	ListSubscriptions(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Subscription, int, int64, error)
}

func NewSubscriptionStorage

func NewSubscriptionStorage(qe mysql.QueryExecer) SubscriptionStorage