aggendpoint

Documentation

Index

• func InstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware
• func LoggingMiddleware(logger log.Logger) endpoint.Middleware
• func MakeAggregateEndpoint(s aggservice.Service) endpoint.Endpoint
• func MakeConcatEndpoint(s aggservice.Service) endpoint.Endpoint
• type AggregateRequest
• type AggregateResponse
• type CalculateRequest
• type CalculateResponse
• type Set
  • func New(svc aggservice.Service, logger log.Logger) Set
  • func (s Set) Aggregate(ctx context.Context, dist types.Distance) error
  • func (s Set) Calculate(ctx context.Context, obuID int) (*types.Invoice, error)

Functions

func InstrumentingMiddleware

func InstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware

func LoggingMiddleware

func LoggingMiddleware(logger log.Logger) endpoint.Middleware

LoggingMiddleware returns an endpoint middleware that logs the duration of each invocation, and the resulting error, if any.

func MakeAggregateEndpoint

func MakeAggregateEndpoint(s aggservice.Service) endpoint.Endpoint

func MakeConcatEndpoint

func MakeConcatEndpoint(s aggservice.Service) endpoint.Endpoint

MakeConcatEndpoint constructs a Concat endpoint wrapping the service.

Types

type AggregateRequest

type AggregateRequest struct {
	Value float64 `json:"value"`
	OBUID int     `json:"obuID"`
	Unix  int64   `json:"unix"`
}

type AggregateResponse

type AggregateResponse struct {
	Err error `json:"err"`
}

type CalculateRequest

type CalculateRequest struct {
	OBUID int `json:"obuID"`
}

type CalculateResponse

type CalculateResponse struct {
	OBUID         int     `json:"obuID"`
	TotalDistance float64 `json:"totalDistance"`
	TotalAmount   float64 `json:"totalAmount"`
	Err           error   `json:"err"`
}

type Set

type Set struct {
	AggregateEndpoint endpoint.Endpoint
	CalculateEndpoint endpoint.Endpoint
}

func New

func New(svc aggservice.Service, logger log.Logger) Set

func (Set) Aggregate

func (s Set) Aggregate(ctx context.Context, dist types.Distance) error

func (Set) Calculate

func (s Set) Calculate(ctx context.Context, obuID int) (*types.Invoice, error)