unistack-org/protoc-gen-go-micro
4
0
Fork 0
Code Issues 5 Pull Requests Packages Projects Releases 61 Wiki Activity

Go-kit example: support services without unary calls

Browse Source
This commit is contained in:
Manfred Touron 2016-12-26 16:20:46 +01:00
parent cdb9580565
commit 877e93aa7c
No known key found for this signature in database
GPG Key ID: 9CCF47DF1FD978A1
3 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/go-kit/templates/{{.File.Package}}/gen/endpoints/endpoints.go.tmpl
View File

@ -10,7 +10,9 @@ import (
"github.com/go-kit/kit/endpoint" "github.com/go-kit/kit/endpoint"
) )
var _ = endpoint.Chain
var _ = fmt.Errorf var _ = fmt.Errorf
var _ = context.Background
type StreamEndpoint func(server interface{}, req interface{}) (err error) type StreamEndpoint func(server interface{}, req interface{}) (err error)

3
examples/go-kit/templates/{{.File.Package}}/gen/transports/grpc/grpc.go.tmpl
View File

@ -16,7 +16,8 @@ import (
var _ = fmt.Errorf var _ = fmt.Errorf
func MakeGRPCServer(ctx context.Context, endpoints endpoints.Endpoints) pb.{{.File.Package | title}}ServiceServer { func MakeGRPCServer(ctx context.Context, endpoints endpoints.Endpoints) pb.{{.File.Package | title}}ServiceServer {
options := []grpctransport.ServerOption{} var options []grpctransport.ServerOption
_ = options
return &grpcServer{ return &grpcServer{
{{range .Service.Method}} {{range .Service.Method}}
{{if or (.ClientStreaming) (.ServerStreaming)}} {{if or (.ClientStreaming) (.ServerStreaming)}}

5
examples/go-kit/templates/{{.File.Package}}/gen/transports/http/http.go.tmpl
View File

@ -14,6 +14,11 @@ import (
endpoints "{{cat .GoPWD "/" .DestinationDir | nospace | clean}}/endpoints" endpoints "{{cat .GoPWD "/" .DestinationDir | nospace | clean}}/endpoints"
) )
var _ = log.Printf
var _ = gokit_endpoint.Chain
var _ = httptransport.NewClient
{{range .Service.Method}} {{range .Service.Method}}
{{if and (not .ServerStreaming) (not .ClientStreaming)}} {{if and (not .ServerStreaming) (not .ClientStreaming)}}
func Make{{.Name}}Handler(ctx context.Context, svc pb.{{$file.Package | title}}ServiceServer, endpoint gokit_endpoint.Endpoint) *httptransport.Server { func Make{{.Name}}Handler(ctx context.Context, svc pb.{{$file.Package | title}}ServiceServer, endpoint gokit_endpoint.Endpoint) *httptransport.Server {