transport

Documentation

Index

• Variables
• func MakeAggregationEndpoint(svc services.AggregationService) endpoint.Endpoint
• func MakeSlowEndpoint(svc services.VariableResponseTestService) endpoint.Endpoint
• func RegisterRoutes(r *mux.Router, svc services.AggregationService, ...)
• type Endpoints
  • func MakeEndpoints(svc services.AggregationService, testSvc services.VariableResponseTestService) Endpoints

Variables

var ErrTypeAssertQueryGetAggregationRequest = errors.New("type assertion failed on AggregationEndpoint")

Error for issues deserializing the requst for search.

var ErrTypeAssertTriggerRequest = errors.New("type assertion failed on trigger request")

Functions

func MakeAggregationEndpoint

func MakeAggregationEndpoint(svc services.AggregationService) endpoint.Endpoint

* Main endpoint for search aggregations.

func MakeSlowEndpoint

func MakeSlowEndpoint(svc services.VariableResponseTestService) endpoint.Endpoint

* Test endpoint for variable service response

func RegisterRoutes

func RegisterRoutes(r *mux.Router, svc services.AggregationService, testSvc services.VariableResponseTestService)

* Match the routes to the endpoints

Types

type Endpoints

type Endpoints struct {
	GetAggregationEndpoint endpoint.Endpoint
	GetTestServiceEndpoint endpoint.Endpoint
}

func MakeEndpoints

func MakeEndpoints(svc services.AggregationService, testSvc services.VariableResponseTestService) Endpoints

* Setup endpoints