transport

type CORS struct {
	AllowedOrigins   []string `mapstructure:"allowedOrigins" envVar:"ATMK_CORS_ORIGINS"`
	AllowedMethods   []string `mapstructure:"allowedMethods" envVar:"ATMK_CORS_METHODS"`
	AllowedHeaders   []string `mapstructure:"allowedHeaders" envVar:"ATMK_CORS_HEADERS"`
	AllowCredentials bool     `mapstructure:"allowCredentials" envVar:"ATMK_CORS_CREDS"`
}

type Certs struct {
	CA   string `mapstructure:"ca" envVar:"ATMK_CERTS_CA"`
	Cert string `mapstructure:"cert" envVar:"ATMK_CERTS_CERT"`
	Key  string `mapstructure:"key" envVar:"ATMK_CERTS_KEY"`
}

type Code uint32

type Config struct {
	BasePath string `mapstructure:"basePath" envVar:"ATMK_TRANSPORT_BASEPATH"`
	Name     string `mapstructure:"name" envVar:"ATMK_TRANSPORT_NAME"`
	Port     string `mapstructure:"port" envVar:"ATMK_TRANSPORT_PORT"`
	WWW      string `mapstructure:"www" envVar:"ATMK_TRANSPORT_WWW"`
	Certs    *Certs `mapstructure:"certs"`
	CORS     *CORS  `mapstructure:"cors"`
}

type Error struct {
	Code Code        `json:"code"`
	Msg  interface{} `json:"msg"`
}

type Interceptor interface {
	Intercept(http.HandlerFunc) http.HandlerFunc
}

type Route struct {
	Handler http.Handler
	Method  string
}

type Transport interface {
	atomika.Service
	OnError(w http.ResponseWriter, r *http.Request, err error)
	Register(service, method string, h http.HandlerFunc)
	ServeHTTP(w http.ResponseWriter, r *http.Request)
	Use(route string, interceptorsList []Interceptor)
}