kit: github.com/go-kit/kit/examples/addsvc/pkg/addendpoint Index | Files

package addendpoint

import "github.com/go-kit/kit/examples/addsvc/pkg/addendpoint"

Index

Package Files

middleware.go set.go

func InstrumentingMiddleware Uses

func InstrumentingMiddleware(duration metrics.Histogram) endpoint.Middleware

InstrumentingMiddleware returns an endpoint middleware that records the duration of each invocation to the passed histogram. The middleware adds a single field: "success", which is "true" if no error is returned, and "false" otherwise.

func LoggingMiddleware Uses

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 MakeConcatEndpoint Uses

func MakeConcatEndpoint(s addservice.Service) endpoint.Endpoint

MakeConcatEndpoint constructs a Concat endpoint wrapping the service.

func MakeSumEndpoint Uses

func MakeSumEndpoint(s addservice.Service) endpoint.Endpoint

MakeSumEndpoint constructs a Sum endpoint wrapping the service.

type ConcatRequest Uses

type ConcatRequest struct {
    A, B string
}

ConcatRequest collects the request parameters for the Concat method.

type ConcatResponse Uses

type ConcatResponse struct {
    V   string `json:"v"`
    Err error  `json:"-"`
}

ConcatResponse collects the response values for the Concat method.

func (ConcatResponse) Failed Uses

func (r ConcatResponse) Failed() error

Failed implements Failer.

type Failer Uses

type Failer interface {
    Failed() error
}

Failer is an interface that should be implemented by response types. Response encoders can check if responses are Failer, and if so if they've failed, and if so encode them using a separate write path based on the error.

type Set Uses

type Set struct {
    SumEndpoint    endpoint.Endpoint
    ConcatEndpoint endpoint.Endpoint
}

Set collects all of the endpoints that compose an add service. It's meant to be used as a helper struct, to collect all of the endpoints into a single parameter.

func New Uses

func New(svc addservice.Service, logger log.Logger, duration metrics.Histogram, trace stdopentracing.Tracer) Set

New returns a Set that wraps the provided server, and wires in all of the expected endpoint middlewares via the various parameters.

func (Set) Concat Uses

func (s Set) Concat(ctx context.Context, a, b string) (string, error)

Concat implements the service interface, so Set may be used as a service. This is primarily useful in the context of a client library.

func (Set) Sum Uses

func (s Set) Sum(ctx context.Context, a, b int) (int, error)

Sum implements the service interface, so Set may be used as a service. This is primarily useful in the context of a client library.

type SumRequest Uses

type SumRequest struct {
    A, B int
}

SumRequest collects the request parameters for the Sum method.

type SumResponse Uses

type SumResponse struct {
    V   int   `json:"v"`
    Err error `json:"-"` // should be intercepted by Failed/errorEncoder
}

SumResponse collects the response values for the Sum method.

func (SumResponse) Failed Uses

func (r SumResponse) Failed() error

Failed implements Failer.

Package addendpoint imports 13 packages (graph) and is imported by 2 packages. Updated 2017-07-29. Refresh now. Tools for package owners.