Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

grpc

package

Go to main page

Versions in this module

v1

v1.4.0

Dec 27, 2017

v1.3.1

Oct 31, 2017

Changes in this version

type Client

+ func (c *Client) WaitForStateReady(ctx ctx.Ctx) error

v1.3.0

Oct 29, 2017

Changes in this version

+ var ErrMissingJourney = errors.New("missing journey")

+ func EmbedContext(ctx netcontext.Context) (netcontext.Context, error)

+ func ExtractContext(context netcontext.Context, app app.Ctx) (journey.Ctx, error)

+ func MustDialOption(opt grpc.DialOption, err error) grpc.DialOption

+ func WithMutualTLS(serverName, certFile, keyFile, caFile string) (grpc.DialOption, error)

+ func WithTLS(certFile, serverNameOverride string) (grpc.DialOption, error)

+ type Client struct

+ GRPC *grpc.ClientConn

+ PropagateContext bool

+ func NewClient(appCtx app.Ctx, target string, opts ...grpc.DialOption) (*Client, error)

+ func (c *Client) AppendUnaryMiddleware(m UnaryClientMiddleware)

+ func (c *Client) Close() error

+ type Server struct

+ GRPC *grpc.Server

+ func NewServer() *Server

+ func (s *Server) ActivateMutualTLS(certFile, keyFile, caFile string)

+ func (s *Server) ActivateTLS(certFile, keyFile string)

+ func (s *Server) AppendUnaryMiddleware(m UnaryServerMiddleware)

+ func (s *Server) Drain()

+ func (s *Server) Handle(f func(*grpc.Server))

+ func (s *Server) RegisterService(sd *grpc.ServiceDesc, ss interface{})

+ func (s *Server) Serve(addr string, ctx app.Ctx) error

+ func (s *Server) SetOptions(opts ...grpc.ServerOption)

+ type UnaryClientMiddleware func(grpc.UnaryInvoker) grpc.UnaryInvoker

+ type UnaryHandler func(ctx journey.Ctx, req interface{}) (interface{}, error)

+ type UnaryServerMiddleware func(next UnaryHandler) UnaryHandler