grpc

Documentation

Index

• func InjectClient(injection func(conn *grpc.ClientConn), ops ...Option) error
• type Option
  • func WithAddr(addr string) Option
  • func WithTLSConfig(conf *tls.Config) Option
• type Server
  • func NewServer(ops ...Option) (*Server, error)
  • func (s *Server) Ready() <-chan struct{}
  • func (s *Server) Start(ctx context.Context)
  • func (s *Server) Stop()
  • func (s *Server) Stopped() <-chan struct{}

Functions

func InjectClient

func InjectClient(injection func(conn *grpc.ClientConn), ops ...Option) error

InjectClient inject grpc client to proto module

Types

type Option

type Option func(*config)

Option to grpc config

func WithAddr

func WithAddr(addr string) Option

WithAddr returns address option

func WithTLSConfig

func WithTLSConfig(conf *tls.Config) Option

WithTLSConfig returns tls config option

type Server

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

Server struct

func NewServer

func NewServer(ops ...Option) (*Server, error)

NewServer new grpc server with options

func (*Server) Ready

func (s *Server) Ready() <-chan struct{}

Ready Returns a channel that will be closed when etcd is ready

func (*Server) Start

func (s *Server) Start(ctx context.Context)

Start grpc server

func (*Server) Stop

func (s *Server) Stop()

Stop etcd server

func (*Server) Stopped

func (s *Server) Stopped() <-chan struct{}

Stopped Returns a channel that will be closed when etcd is stopped