Documentation
¶
Index ¶
- Variables
- func GrpcInsecureClient(name, host, port string, dopts []grpc.DialOption, ...) (*grpc.ClientConn, error)
- func GrpcMtlsClient(name, serverName, host, port string, dopts []grpc.DialOption, ...) (*grpc.ClientConn, error)
- func StartGrpcMtlsServer(name, serverName, host, port string, sopts []grpc.ServerOption, ...)
- func StartGrpcServer(name, host, port string, sopts []grpc.ServerOption, ...)
- func StartMessagingListener(topic, group string, handler MessagingHandlerFunc) (<-chan bool, error)
- type GrpcAdapterConfigurer
- type GrpcClientConfigurer
- type MessagingHandlerFunc
Constants ¶
This section is empty.
Variables ¶
View Source
var ( NoGrpcDialOptions = []grpc.DialOption{} NoGrpcConfigurer = func(conn *grpc.ClientConn) {} )
Functions ¶
func GrpcInsecureClient ¶
func GrpcInsecureClient(name, host, port string, dopts []grpc.DialOption, configurer GrpcClientConfigurer) (*grpc.ClientConn, error)
func GrpcMtlsClient ¶
func GrpcMtlsClient(name, serverName, host, port string, dopts []grpc.DialOption, configurer GrpcClientConfigurer) (*grpc.ClientConn, error)
func StartGrpcMtlsServer ¶
func StartGrpcMtlsServer(name, serverName, host, port string, sopts []grpc.ServerOption, configure GrpcAdapterConfigurer)
func StartGrpcServer ¶
func StartGrpcServer(name, host, port string, sopts []grpc.ServerOption, configure GrpcAdapterConfigurer)
func StartMessagingListener ¶
func StartMessagingListener(topic, group string, handler MessagingHandlerFunc) (<-chan bool, error)
Types ¶
type GrpcAdapterConfigurer ¶
type GrpcClientConfigurer ¶
type GrpcClientConfigurer func(conn *grpc.ClientConn)
type MessagingHandlerFunc ¶
Source Files
Click to show internal directories.
Click to hide internal directories.