webb_server

Documentation

Index

• func GetGRPCMethod(uriInfo map[string]interface{}) (interface{}, error)
• type ClientInterceptor
  • func (ci *ClientInterceptor) UnaryInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• type GRPCClient
  • func NewGRPCClient(endpoint string, sslEnabled bool, maxMessageLength int, ...) (*GRPCClient, error)
  • func (c *GRPCClient) Close()
  • func (c *GRPCClient) GetChannelKey() string
  • func (c *GRPCClient) GetConnection() *grpc.ClientConn
• type GRPCServer
  • func NewGRPCServer(port int, maxConnections int) *GRPCServer
  • func (s *GRPCServer) GetGRPCServer() *grpc.Server
  • func (s *GRPCServer) Run() error

Functions

func GetGRPCMethod

func GetGRPCMethod(uriInfo map[string]interface{}) (interface{}, error)

Types

type ClientInterceptor

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

func (*ClientInterceptor) UnaryInterceptor

func (ci *ClientInterceptor) UnaryInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

type GRPCClient

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

func NewGRPCClient

func NewGRPCClient(endpoint string, sslEnabled bool, maxMessageLength int, options map[string]interface{}) (*GRPCClient, error)

func (*GRPCClient) Close

func (c *GRPCClient) Close()

func (*GRPCClient) GetChannelKey

func (c *GRPCClient) GetChannelKey() string

func (*GRPCClient) GetConnection

func (c *GRPCClient) GetConnection() *grpc.ClientConn

type GRPCServer

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

func NewGRPCServer

func NewGRPCServer(port int, maxConnections int) *GRPCServer

func (*GRPCServer) GetGRPCServer

func (s *GRPCServer) GetGRPCServer() *grpc.Server

func (*GRPCServer) Run

func (s *GRPCServer) Run() error