rpc

Documentation

Index

• type GRPCBundle
  • func NewGRPCBundle(name string, opts ...GRPCOption) *GRPCBundle
  • func (s *GRPCBundle) GetName() string
  • func (s *GRPCBundle) Run(ctx context.Context)
  • func (s *GRPCBundle) Stop(ctx context.Context)
• type GRPCOption
  • func GRPCListen(listenAddr string) GRPCOption
  • func GRPCServerFactory(f func() *grpc.Server) GRPCOption

Types

type GRPCBundle

type GRPCBundle struct {
	Server *grpc.Server
	// contains filtered or unexported fields
}

func NewGRPCBundle

func NewGRPCBundle(name string, opts ...GRPCOption) *GRPCBundle

func (*GRPCBundle) GetName

func (s *GRPCBundle) GetName() string

func (*GRPCBundle) Run

func (s *GRPCBundle) Run(ctx context.Context)

func (*GRPCBundle) Stop

func (s *GRPCBundle) Stop(ctx context.Context)

type GRPCOption

type GRPCOption func(bundle *GRPCBundle)

func GRPCListen

func GRPCListen(listenAddr string) GRPCOption

func GRPCServerFactory

func GRPCServerFactory(f func() *grpc.Server) GRPCOption