director

Documentation

Overview

Package director provides proxy call routing facility

Index

• type Router
  • func NewRouter() *Router
  • func (r *Router) Director(ctx context.Context, fullMethodName string) (proxy.Mode, []proxy.Backend, error)
  • func (r *Router) Register(srv *grpc.Server)
  • func (r *Router) RegisterLocalBackend(serviceName string, backend proxy.Backend)

Types

type Router

type Router struct {
	// contains filtered or unexported fields
}

Router wraps grpc-proxy StreamDirector

func NewRouter

func NewRouter() *Router

NewRouter builds new Router

func (*Router) Director

func (r *Router) Director(ctx context.Context, fullMethodName string) (proxy.Mode, []proxy.Backend, error)

Director implements proxy.StreamDirector function

func (*Router) Register

func (r *Router) Register(srv *grpc.Server)

Register is no-op to implement factory.Registrator interface.

Actual proxy handler is installed via grpc.UnknownServiceHandler option.

func (*Router) RegisterLocalBackend

func (r *Router) RegisterLocalBackend(serviceName string, backend proxy.Backend)

RegisterLocalBackend registers local backend by service name.