services

Documentation

Overview

* Service responsible for taking one or more REST requests and running them concurrently, then streaming their responses back on a common channel.

Index

• type AggregationService
• type AggregationServiceInstance
  • func InitializeAggregationService(aggThreadCount int) (*AggregationServiceInstance, error)
  • func (service *AggregationServiceInstance) FanOutRequests(cxt context.Context, aggReq models.AggRequest) *models.AggResponse
  • func (service AggregationServiceInstance) RequestConcurrent(requestChan chan models.RequestInstance, ...)
  • func (service AggregationServiceInstance) RequestTimeLatch(timeout int, timeChan chan bool)
• type VariableResponseTestService
• type VariableResponseTestServiceInstance
  • func InitializeVariableResponseTestService(Delay int) (*VariableResponseTestServiceInstance, error)
  • func (service *VariableResponseTestServiceInstance) VariableResponse(ctx context.Context, request models.TriggerRequest) *models.TriggerResponse

Types

type AggregationService

type AggregationService interface {
	FanOutRequests(context.Context, models.AggRequest) *models.AggResponse
}

* aggregation of call from the backend.

type AggregationServiceInstance

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

* aggregation of call from the backend.

func InitializeAggregationService

func InitializeAggregationService(aggThreadCount int) (*AggregationServiceInstance, error)

* Spin up the Aggregation service

func (*AggregationServiceInstance) FanOutRequests

func (service *AggregationServiceInstance) FanOutRequests(cxt context.Context, aggReq models.AggRequest) *models.AggResponse

* Given a request fan it out.

func (AggregationServiceInstance) RequestConcurrent

func (service AggregationServiceInstance) RequestConcurrent(requestChan chan models.RequestInstance, responseChan chan models.RequestsPipelineInstance)

func (AggregationServiceInstance) RequestTimeLatch

func (service AggregationServiceInstance) RequestTimeLatch(timeout int, timeChan chan bool)

type VariableResponseTestService

type VariableResponseTestService interface {
	VariableResponse(context.Context, models.TriggerRequest) *models.TriggerResponse
}

type VariableResponseTestServiceInstance

type VariableResponseTestServiceInstance struct {
	ResponseTimeDelayMs int
}

func InitializeVariableResponseTestService

func InitializeVariableResponseTestService(Delay int) (*VariableResponseTestServiceInstance, error)

func (*VariableResponseTestServiceInstance) VariableResponse

func (service *VariableResponseTestServiceInstance) VariableResponse(ctx context.Context, request models.TriggerRequest) *models.TriggerResponse