transport_http

Documentation

Index

• Variables
• func ContextWithOperators(ctx context.Context, ops ...courier.IOperator) context.Context
• func ContextWithRequest(ctx context.Context, req *http.Request) context.Context
• func ContextWithServiceName(ctx context.Context, serverName string) context.Context
• func CreateHttpHandler(s *ServeHTTP, ops ...courier.IOperator) httprouter.Handle
• func GetClientIP(r *http.Request) string
• func GetLongConnClient(timeout time.Duration) *http.Client
• func GetOperators(ctx context.Context) []courier.IOperator
• func GetParams(path string, url string) (params httprouter.Params, err error)
• func GetRequest(ctx context.Context) *http.Request
• func GetShortConnClient(timeout time.Duration) *http.Client
• func HttpStatusOK(code int) bool
• func MarshalOperator(r *http.Request, operator courier.IOperator) (err error)
• func PayloadMarshal(payload interface{}) ([]byte, error)
• func PayloadUnmarshal(data []byte, payload interface{}) error
• type File
  • func NewFile(filename string, contentType string) *File
  • func (file *File) ContentType() string
  • func (file *File) Meta() courier.Metadata
  • func (file *File) Read(p []byte) (n int, err error)
  • func (file *File) Write(p []byte) (n int, err error)
• type HttpRequest
  • func (httpRequest *HttpRequest) Do() (result courier.Result)
• type IBytesGetter
• type IContentType
• type IHttpRequestTransformer
• type IMethod
• type IPath
• type IStatus
• type IWebSocket
• type Listener
• type Listeners
  • func (listeners Listeners) On(v interface{}, listener Listener) Listeners
  • func (listeners Listeners) SubscribeOn(conn *websocket.Conn)
• type Msg
• type ParameterValuesGetter
  • func (getter *ParameterValuesGetter) Param(name string) string
• type ResponseWriter
  • func (w *ResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)
  • func (w *ResponseWriter) Write(p []byte) (int, error)
  • func (w *ResponseWriter) WriteHeader(code int)
• type ServeHTTP
  • func (s ServeHTTP) DockerDefaults() conf.DockerDefaults
  • func (s ServeHTTP) MarshalDefaults(v interface{})
  • func (s *ServeHTTP) Serve(router *courier.Router) error
  • func (s *ServeHTTP) ServeHTTP(w http.ResponseWriter, req *http.Request)
  • func (s *ServeHTTP) Stop() error
• type TransportWrapper
• type TypeAndListener
• type WSClient
  • func ConnWS(conn *websocket.Conn) *WSClient
  • func (c *WSClient) Close() error
  • func (c WSClient) Send(payload interface{}) (err error)

Variables

var (
	ContextKeyServerName = uuid.New().String()
	ContextKeyRequest    = uuid.New().String()
	ContextKeyOperators  = uuid.New().String()
)

var ProjectRef = os.Getenv("PROJECT_REF")

var RxHttpRouterPath = regexp.MustCompile("/:([^/]+)")

Functions

func ContextWithOperators

func ContextWithOperators(ctx context.Context, ops ...courier.IOperator) context.Context

func ContextWithRequest

func ContextWithRequest(ctx context.Context, req *http.Request) context.Context

func ContextWithServiceName

func ContextWithServiceName(ctx context.Context, serverName string) context.Context

func CreateHttpHandler

func CreateHttpHandler(s *ServeHTTP, ops ...courier.IOperator) httprouter.Handle

func GetClientIP

func GetClientIP(r *http.Request) string

func GetLongConnClient

func GetLongConnClient(timeout time.Duration) *http.Client

func GetOperators

func GetOperators(ctx context.Context) []courier.IOperator

func GetParams

func GetParams(path string, url string) (params httprouter.Params, err error)

func GetRequest

func GetRequest(ctx context.Context) *http.Request

func GetShortConnClient

func GetShortConnClient(timeout time.Duration) *http.Client

func HttpStatusOK

func HttpStatusOK(code int) bool

func MarshalOperator

func MarshalOperator(r *http.Request, operator courier.IOperator) (err error)

func PayloadMarshal

func PayloadMarshal(payload interface{}) ([]byte, error)

func PayloadUnmarshal

func PayloadUnmarshal(data []byte, payload interface{}) error

Types

type File

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

swagger:strfmt binary

func NewFile

func NewFile(filename string, contentType string) *File

func (*File) ContentType

func (file *File) ContentType() string

func (*File) Meta

func (file *File) Meta() courier.Metadata

func (*File) Read

func (file *File) Read(p []byte) (n int, err error)

func (*File) Write

func (file *File) Write(p []byte) (n int, err error)

type HttpRequest

type HttpRequest struct {
	BaseURL       string
	Method        string
	URI           string
	ID            string
	Metadata      courier.Metadata
	Timeout       time.Duration
	Req           interface{}
	WrapTransport TransportWrapper
}

func (*HttpRequest) Do

func (httpRequest *HttpRequest) Do() (result courier.Result)

type IBytesGetter

type IBytesGetter interface {
	Bytes() []byte
}

type IContentType

type IContentType interface {
	ContentType() string
}

type IHttpRequestTransformer

type IHttpRequestTransformer interface {
	TransformHttpRequest(req *http.Request)
}

type IMethod

type IMethod interface {
	Method() string
}

type IPath

type IPath interface {
	Path() string
}

type IStatus

type IStatus interface {
	Status() int
}

type IWebSocket

type IWebSocket interface {
	SubscribeOn(conn *websocket.Conn)
}

type Listener

type Listener func(v interface{}, ws *WSClient) error

type Listeners

type Listeners map[string]TypeAndListener

func (Listeners) On

func (listeners Listeners) On(v interface{}, listener Listener) Listeners

func (Listeners) SubscribeOn

func (listeners Listeners) SubscribeOn(conn *websocket.Conn)

type Msg

type Msg struct {
	Type    string `json:"type"`
	Payload []byte `json:"payload"`
}

type ParameterValuesGetter

type ParameterValuesGetter struct {
	*transform.ParameterValuesGetter
	Params *httprouter.Params
}

func (*ParameterValuesGetter) Param

func (getter *ParameterValuesGetter) Param(name string) string

type ResponseWriter

type ResponseWriter struct {
	http.ResponseWriter
	Code int
	// contains filtered or unexported fields
}

func (*ResponseWriter) Hijack

func (w *ResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)

func (*ResponseWriter) Write

func (w *ResponseWriter) Write(p []byte) (int, error)

func (*ResponseWriter) WriteHeader

func (w *ResponseWriter) WriteHeader(code int)

type ServeHTTP

type ServeHTTP struct {
	Name         string
	IP           string
	Port         int
	SwaggerPath  string
	WriteTimeout time.Duration
	ReadTimeout  time.Duration
	WithCORS     bool
	// contains filtered or unexported fields
}

func (ServeHTTP) DockerDefaults

func (s ServeHTTP) DockerDefaults() conf.DockerDefaults

func (ServeHTTP) MarshalDefaults

func (s ServeHTTP) MarshalDefaults(v interface{})

func (*ServeHTTP) Serve

func (s *ServeHTTP) Serve(router *courier.Router) error

func (*ServeHTTP) ServeHTTP

func (s *ServeHTTP) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*ServeHTTP) Stop

func (s *ServeHTTP) Stop() error

type TransportWrapper

type TransportWrapper func(rt http.RoundTripper) http.RoundTripper

type TypeAndListener

type TypeAndListener struct {
	Listener Listener
	Type     reflect.Type
}

type WSClient

type WSClient struct {
	Closed bool
	// contains filtered or unexported fields
}

func ConnWS

func ConnWS(conn *websocket.Conn) *WSClient

func (*WSClient) Close

func (c *WSClient) Close() error

func (WSClient) Send

func (c WSClient) Send(payload interface{}) (err error)