models

Documentation

Index

• Constants
• func LoadRandomUser(db *gorm.DB, userIDPool []string) (utils.User, error)
• func LoadUser(userData UserData) (utils.User, error)
• type ALBProxy
• type Certificate
• type Route
• type RouteManager
  • func NewManager(logger lager.Logger, iam utils.IamIface, elbSvc elbv2iface.ELBV2API, ...) RouteManager
  • func (m *RouteManager) Create(instanceId string, domains []string) (*Route, error)
  • func (m *RouteManager) DeleteOrphanedCerts()
  • func (m *RouteManager) Destroy(guid string) error
  • func (m *RouteManager) Get(guid string) (*Route, error)
  • func (m *RouteManager) GetDNSInstructions(route *Route) (string, error)
  • func (m *RouteManager) Poll(r *Route) error
  • func (m *RouteManager) Populate() error
  • func (m *RouteManager) Renew(r *Route) error
  • func (m *RouteManager) RenewAll()
  • func (m *RouteManager) Update(instanceId string, domain []string) error
• type RouteManagerIface
• type State
  • func (s *State) Scan(value interface{}) error
  • func (s State) Value() (driver.Value, error)
• type UserData
  • func SaveUser(db *gorm.DB, user utils.User) (UserData, error)

Constants

const (
	Provisioning  State = "provisioning"
	Provisioned         = "provisioned"
	Deprovisioned       = "deprovisioned"
)

Functions

func LoadRandomUser

func LoadRandomUser(db *gorm.DB, userIDPool []string) (utils.User, error)

* LoadRandomUser The Let's Encrypt v1 acme API has shut down user creation to force users to adopt v2. * In an attempt to contiune using v1 while we develop a v2 compliant broker, we are replacing * calls to create a new user for each new domain registration with a method that fetches an existing user * from a pool of ids. The random selection of users from a pool aims to minimize the impact of the following rate limits: * - 300 Pending Authorizations per account * - Failed Validation limit of 5 failures per account, per hostname, per hour.

func LoadUser

func LoadUser(userData UserData) (utils.User, error)

Types

type ALBProxy

type ALBProxy struct {
	ALBARN      string `gorm:"primary_key;column:alb_arn"`
	ALBDNSName  string `gorm:"column:alb_dns_name"`
	ListenerARN string
}

type Certificate

type Certificate struct {
	gorm.Model
	RouteGUID   string
	Domain      string
	CertURL     string
	Certificate []byte
	ARN         string
	Name        string
	Expires     time.Time `gorm:"index"`
}

type Route

type Route struct {
	GUID          string         `gorm:"primary_key"`
	State         State          `gorm:"not null;index"`
	Domains       pq.StringArray `gorm:"type:text[]"`
	ChallengeJSON []byte

	UserData   UserData
	UserDataID int

	ALBProxy    ALBProxy
	ALBProxyARN string

	Certificate Certificate
}

type RouteManager

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

func NewManager

func NewManager(
	logger lager.Logger,
	iam utils.IamIface,
	elbSvc elbv2iface.ELBV2API,
	settings config.Settings,
	db *gorm.DB,
) RouteManager

func (*RouteManager) Create

func (m *RouteManager) Create(instanceId string, domains []string) (*Route, error)

func (*RouteManager) DeleteOrphanedCerts

func (m *RouteManager) DeleteOrphanedCerts()

func (*RouteManager) Destroy

func (m *RouteManager) Destroy(guid string) error

func (*RouteManager) Get

func (m *RouteManager) Get(guid string) (*Route, error)

func (*RouteManager) GetDNSInstructions

func (m *RouteManager) GetDNSInstructions(route *Route) (string, error)

func (*RouteManager) Poll

func (m *RouteManager) Poll(r *Route) error

func (*RouteManager) Populate

func (m *RouteManager) Populate() error

func (*RouteManager) Renew

func (m *RouteManager) Renew(r *Route) error

func (*RouteManager) RenewAll

func (m *RouteManager) RenewAll()

func (*RouteManager) Update

func (m *RouteManager) Update(instanceId string, domain []string) error

type RouteManagerIface

type RouteManagerIface interface {
	Create(instanceId string, domains []string) (*Route, error)
	Update(instanceId string, domains []string) error
	Destroy(instanceId string) error
	Get(instanceId string) (*Route, error)
	Poll(route *Route) error
	Renew(route *Route) error
	RenewAll()
	DeleteOrphanedCerts()
	GetDNSInstructions(route *Route) (string, error)
	Populate() error
}

type State

type State string

func (*State) Scan

func (s *State) Scan(value interface{}) error

Unmarshal an `interface{}` to a `State` when reading from the database

func (State) Value

func (s State) Value() (driver.Value, error)

Marshal a `State` to a `string` when saving to the database

type UserData

type UserData struct {
	gorm.Model
	Email string `gorm:"not null"`
	Reg   []byte
	Key   []byte
}

func SaveUser

func SaveUser(db *gorm.DB, user utils.User) (UserData, error)