server

Documentation

Index

• type Config
• type DomainsClaims
• type Route
  • func (route *Route) Data(ctx context.Context, reader io.Reader) error
  • func (route *Route) Mail(ctx context.Context, from string, opts smtp.MailOptions) error
  • func (route *Route) Rcpt(ctx context.Context, rcptTo string) error
• type RouteMeta
• type RouteStatus
• type Server
  • func NewServer(c *Config) (*Server, error)
  • func (server *Server) GetRoute(domain string) (dagent.Route, error)
  • func (server *Server) Logger() logrus.FieldLogger
  • func (server *Server) Mail(from string, opts smtp.MailOptions) error
  • func (server *Server) Serve(ctx context.Context) error
  • func (server *Server) Status() (*Status, error)
• type Status
  • func (status *Status) Copy() (*Status, error)
  • func (status *Status) SetDomainsClaims(domainsClaims *DomainsClaims) error
  • func (status *Status) SetLicenseClaims(licenseClaims []*license.Claims) error
• type TextEvent

Types

type Config

type Config struct {
	Iss *url.URL

	Logger logrus.FieldLogger

	OnReady  func(*Server)
	OnStatus func(*Server)

	APIBaseURI *url.URL

	Domains              []string
	PreferredDomainBases []string

	DAgentListenAddress string

	SMTPLocalAddr string

	StatePath string

	LicensesPath string
}

Config bundles configuration settings.

type DomainsClaims

type DomainsClaims struct {
	Domains []string `json:"domains"`
	// contains filtered or unexported fields
}

type Route

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

func (*Route) Data

func (route *Route) Data(ctx context.Context, reader io.Reader) error

func (*Route) Mail

func (route *Route) Mail(ctx context.Context, from string, opts smtp.MailOptions) error

func (*Route) Rcpt

func (route *Route) Rcpt(ctx context.Context, rcptTo string) error

type RouteMeta

type RouteMeta struct {
	Domain string           `json:"domain"`
	ID     string           `json:"id"`
	Expiry *jwt.NumericDate `json:"exp"`
}

type RouteStatus

type RouteStatus struct {
	Success bool `json:"success"`

	Code         int               `json:"code"`
	EnhancedCode smtp.EnhancedCode `json:"enhanced_code,omitempty"`
	Message      string            `json:"message"`
}

type Server

type Server struct {
	DAgent *dagent.DAgent
	// contains filtered or unexported fields
}

Server is our HTTP server implementation.

func NewServer

func NewServer(c *Config) (*Server, error)

NewServer constructs a server from the provided parameters.

func (*Server) GetRoute

func (server *Server) GetRoute(domain string) (dagent.Route, error)

func (*Server) Logger

func (server *Server) Logger() logrus.FieldLogger

func (*Server) Mail

func (server *Server) Mail(from string, opts smtp.MailOptions) error

func (*Server) Serve

func (server *Server) Serve(ctx context.Context) error

Serve starts all the accociated servers resources and listeners and blocks forever until signals or error occurs.

func (*Server) Status

func (server *Server) Status() (*Status, error)

type Status

type Status struct {
	sync.RWMutex

	HTTPProviderURL string   `json:"provider_url"`
	HTTPConnected   bool     `json:"provider_connected"`
	HTTPLicenseLIDs []string `json:"provider_license_ids"`

	SessionID  *string    `json:"session_id"`
	Domains    []string   `json:"domains"`
	Expiration *time.Time `json:"exp"`
}

func (*Status) Copy

func (status *Status) Copy() (*Status, error)

func (*Status) SetDomainsClaims

func (status *Status) SetDomainsClaims(domainsClaims *DomainsClaims) error

func (*Status) SetLicenseClaims

func (status *Status) SetLicenseClaims(licenseClaims []*license.Claims) error

type TextEvent

type TextEvent struct {
	Event string
	ID    string
	Data  string
}