Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion cmd/kitgen/interface.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ func (i iface) httpHandler() ast.Decl {
return handlerFn
}

func (i iface) reciever() *ast.Field {
func (i iface) receiver() *ast.Field {
return field(i.receiverName(), i.stubName())
}

Expand Down
4 changes: 2 additions & 2 deletions cmd/kitgen/method.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ func (m method) definition(ifc iface) ast.Decl {
notImpl := fetchFuncDecl("ExampleEndpoint")

notImpl.Name = m.name
notImpl.Recv = fieldList(ifc.reciever())
notImpl.Recv = fieldList(ifc.receiver())
scope := scopeWith(notImpl.Recv.List[0].Names[0].Name)
notImpl.Type.Params = m.funcParams(scope)
notImpl.Type.Results = m.funcResults()
Expand All @@ -42,7 +42,7 @@ func (m method) endpointMaker(ifc iface) ast.Decl {

endpointFn.Body.List[0].(*ast.ReturnStmt).Results[0] = anonFunc
endpointFn.Name = m.endpointMakerName()
endpointFn.Type.Params = fieldList(ifc.reciever())
endpointFn.Type.Params = fieldList(ifc.receiver())
endpointFn.Type.Results = fieldList(typeField(sel(id("endpoint"), id("Endpoint"))))
return endpointFn
}
Expand Down
2 changes: 1 addition & 1 deletion metrics/cloudwatch2/cloudwatch2.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ type CloudWatch struct {
// Option is a function adapter to change config of the CloudWatch struct
type Option func(*CloudWatch)

// WithLogger sets the Logger that will recieve error messages generated
// WithLogger sets the Logger that will receive error messages generated
// during the WriteLoop. By default, no logger is used.
func WithLogger(logger log.Logger) Option {
return func(cw *CloudWatch) {
Expand Down
4 changes: 2 additions & 2 deletions tracing/zipkin/http_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import (
"reflect"
"testing"

"github.com/openzipkin/zipkin-go"
zipkin "github.com/openzipkin/zipkin-go"
"github.com/openzipkin/zipkin-go/model"
"github.com/openzipkin/zipkin-go/propagation/b3"
"github.com/openzipkin/zipkin-go/reporter/recorder"
Expand Down Expand Up @@ -166,7 +166,7 @@ func TestHTTPServerTrace(t *testing.T) {
rec := recorder.NewReporter()
defer rec.Close()

// explicitely show we use the default of RPC shared spans in Zipkin as it
// explicitly show we use the default of RPC shared spans in Zipkin as it
// is idiomatic for Zipkin to share span identifiers between client and
// server side.
tr, _ := zipkin.NewTracer(rec, zipkin.WithSharedSpans(true))
Expand Down
3 changes: 2 additions & 1 deletion transport/amqp/encode-decode.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package amqp

import (
"context"

"github.com/streadway/amqp"
)

Expand All @@ -13,7 +14,7 @@ type DecodeRequestFunc func(context.Context, *amqp.Delivery) (request interface{
// an AMQP Publishing object. It is designed to be used in AMQP Publishers.
type EncodeRequestFunc func(context.Context, *amqp.Publishing, interface{}) error

// EncodeResponseFunc encodes the passed reponse object to
// EncodeResponseFunc encodes the passed response object to
// an AMQP Publishing object. It is designed to be used in AMQP Subscribers.
type EncodeResponseFunc func(context.Context, *amqp.Publishing, interface{}) error

Expand Down