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 MakeCalculateEndpoint(s aggservice.Service) endpoint.Endpoint
• type AggregateRequest
• type AggregateResponse
• type CalculateRequest
• type CalculateResponse
• type Set
  • func New(svc aggservice.Service, duration metrics.Histogram, logger log.Logger) Set
  • func (s Set) Aggregate(ctx context.Context, dist types.Distance) error
  • func (s Set) Calculate(ctx context.Context, id int) (*types.Invoice, error)

Functions

func InstrumentingMiddleware

func InstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware

func LoggingMiddleware

func LoggingMiddleware(logger log.Logger) endpoint.Middleware

func MakeAggregateEndpoint

func MakeAggregateEndpoint(s aggservice.Service) endpoint.Endpoint

func MakeCalculateEndpoint

func MakeCalculateEndpoint(s aggservice.Service) endpoint.Endpoint

Types

type AggregateRequest

type AggregateRequest struct {
	OBUID int     `json:"obuID"`
	Value float64 `json:"value"`
	Unix  int64   `jsin:"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"`
	Amount        float64 `json:"amount"`
	Err           error   `json:"err"`
}

type Set

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

func New

func New(svc aggservice.Service, duration metrics.Histogram, 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, id int) (*types.Invoice, error)