v2

Documentation

Index

• Variables
• type EnvironmentStorage
  • func NewEnvironmentStorage(qe mysql.QueryExecer) EnvironmentStorage
• type OrganizationStorage
  • func NewOrganizationStorage(qe mysql.QueryExecer) OrganizationStorage
• type ProjectStorage
  • func NewProjectStorage(qe mysql.QueryExecer) ProjectStorage

Variables

var (
	ErrEnvironmentAlreadyExists          = errors.New("environment: already exists")
	ErrEnvironmentNotFound               = errors.New("environment: not found")
	ErrEnvironmentUnexpectedAffectedRows = errors.New("environment: unexpected affected rows")
)

var (
	ErrOrganizationAlreadyExists          = errors.New("organization: already exists")
	ErrOrganizationNotFound               = errors.New("organization: not found")
	ErrOrganizationUnexpectedAffectedRows = errors.New("organization: unexpected affected rows")
)

var (
	ErrProjectAlreadyExists          = errors.New("project: already exists")
	ErrProjectNotFound               = errors.New("project: not found")
	ErrProjectUnexpectedAffectedRows = errors.New("project: unexpected affected rows")
)

Types

type EnvironmentStorage

type EnvironmentStorage interface {
	CreateEnvironmentV2(ctx context.Context, e *domain.EnvironmentV2) error
	UpdateEnvironmentV2(ctx context.Context, e *domain.EnvironmentV2) error
	GetEnvironmentV2(ctx context.Context, id string) (*domain.EnvironmentV2, error)
	ListEnvironmentsV2(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.EnvironmentV2, int, int64, error)
}

func NewEnvironmentStorage

func NewEnvironmentStorage(qe mysql.QueryExecer) EnvironmentStorage

type OrganizationStorage

type OrganizationStorage interface {
	CreateOrganization(ctx context.Context, p *domain.Organization) error
	UpdateOrganization(ctx context.Context, p *domain.Organization) error
	GetOrganization(ctx context.Context, id string) (*domain.Organization, error)
	GetSystemAdminOrganization(ctx context.Context) (*domain.Organization, error)
	ListOrganizations(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Organization, int, int64, error)
}

func NewOrganizationStorage

func NewOrganizationStorage(qe mysql.QueryExecer) OrganizationStorage

type ProjectStorage

type ProjectStorage interface {
	CreateProject(ctx context.Context, p *domain.Project) error
	UpdateProject(ctx context.Context, p *domain.Project) error
	GetProject(ctx context.Context, id string) (*domain.Project, error)
	GetTrialProjectByEmail(
		ctx context.Context,
		email string,
		disabled, trial bool,
	) (*domain.Project, error)
	ListProjects(
		ctx context.Context,
		whereParts []mysql.WherePart,
		orders []*mysql.Order,
		limit, offset int,
	) ([]*proto.Project, int, int64, error)
}

func NewProjectStorage

func NewProjectStorage(qe mysql.QueryExecer) ProjectStorage