endpoint

type Authorizer interface {
	Authorization(ctx context.Context, PeekHeader func(key string) []byte) (int, error)
}

type Config struct {
	LogConfig         log.Configer
	ErrorHandler      ErrorHandler
	RequestValidator  RequestValidator
	ResponseValidator ResponseValidator
	MimeTypeHandlers  MimeTypeHandlers
	Resources         map[string]interface{}
	Timeout           time.Duration
	Tracer            opentracing.Tracer
}

type Endpoint struct {
	Config *Config
	// contains filtered or unexported fields
}

type ErrorHandler interface {
	HandleError(ctx context.Context, httpStatus int, err error) (int, interface{})
}

type Handler interface {
	// Handle business logic.
	// While not explicitly prevented, this function should
	//   not touch the request or do any post processing of
	//   any request data.
	Handle(ctx context.Context) (int, error)
}

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

type Marshaler func(v interface{}) ([]byte, error)

type MimeTypeHandler struct {
	MimeType  string
	Marshal   Marshaler
	Unmarshal Unmarshaler
}

type MimeTypeHandlers map[string]*MimeTypeHandler

type RequestValidator interface {
	// ValidateRequest and return validation failures.
	// Errors returned are passed straight through to the ErrorHandler.
	// Returned status code is not used unless error is not nil.
	ValidateRequest(ctx context.Context, requestBody []byte) (int, error)
}

type Requester interface {
	RequestId() string

	// HTTP Method.
	Method() []byte
	// Path of the actual request URL.
	Path() []byte

	ContentType() []byte
	Accept() []byte

	PeekHeader(key string) []byte
	VisitHeaders(f func(key []byte, value []byte))

	// MatchedPath returns the endpoint path that the request URL matches.
	// Ex: /some/path/{id}
	MatchedPath() string

	// PathParam returns the path parameter value for the given parameter name.
	// Returns false if parameter not found.
	PathParam(param string) (string, bool)
	QueryParam(param string) ([]byte, bool)

	RequestBody() []byte

	SetResponseHeader(header string, value string)
	SetResponseContentType(contentType string)
	ResponseContentType() string
	ResponseHeaders() map[string]string
}

type ResponseValidator interface {
	// ValidateRequest and return validation failures.
	// Errors returned are passed straight through to the ErrorHandler.
	// Returned status code is not used unless error is not nil.
	ValidateResponse(ctx context.Context, httpStatus int, responseBody []byte) (int, error)
}

type Unmarshaler func(data []byte, v interface{}) error