grpc

Dec 12, 2021

Changes in this version

+ const CodecName

+ type Codec struct

+ Base encoding.Codec

+ func (c *Codec) Marshal(v interface{}) ([]byte, error)

+ func (c *Codec) Name() string

+ func (c *Codec) String() string

+ func (c *Codec) Unmarshal(data []byte, v interface{}) error

Aug 1, 2020

Changes in this version

type Config

+ MaxConcurrentStreams int64

+ MaxConnectionAge time.Duration

+ MaxConnectionAgeGrace time.Duration

+ MaxConnectionIdle time.Duration

+ MaxRecvMsgSize int64

+ MaxSendMsgSize int64

+ PingTime time.Duration

+ Timeout time.Duration

May 25, 2020

Changes in this version

type TLS

+ RootCA string

Sep 6, 2019

Changes in this version

+ const EventUnaryCall

type Service

+ func (svc *Service) Server() *roadrunner.Server

+ type UnaryCallEvent struct

+ Context context.Context

+ Error error

+ Info *grpc.UnaryServerInfo

+ func (e *UnaryCallEvent) Elapsed() time.Duration

May 22, 2019

Changes in this version

type Service

+ func (svc *Service) Attach(ctr roadrunner.Controller)

Oct 20, 2018

Changes in this version

+ const ID

+ type Config struct

+ Listen string

+ Proto string

+ TLS TLS

+ Workers *roadrunner.ServerConfig

+ func (c *Config) EnableTLS() bool

+ func (c *Config) Hydrate(cfg service.Config) error

+ func (c *Config) Listener() (net.Listener, error)

+ func (c *Config) Valid() error

+ type Proxy struct

+ func NewProxy(name string, metadata string, rr *roadrunner.Server) *Proxy

+ func (p *Proxy) RegisterMethod(method string)

+ func (p *Proxy) ServiceDesc() *grpc.ServiceDesc

+ type Service struct

+ func (s *Service) AddListener(l func(event int, ctx interface{}))

+ func (s *Service) AddOption(opt grpc.ServerOption)

+ func (s *Service) AddService(r func(server *grpc.Server)) error

+ func (s *Service) Init(cfg *Config, r *rpc.Service, e env.Environment) (ok bool, err error)

+ func (s *Service) Serve() (err error)

+ func (s *Service) Stop()

+ type TLS struct

+ Cert string

+ Key string

+ type WorkerList struct

+ Workers []*util.State