adapters

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

Variables

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 GrpcAdapterConfigurer func(server *grpc.Server)

type GrpcClientConfigurer

type GrpcClientConfigurer func(conn *grpc.ClientConn)

type MessagingHandlerFunc

type MessagingHandlerFunc func(data []byte) error