Documentation
¶
Index ¶
- func CreateGRPCConn(addr string) (*grpc.ClientConn, error)
- func MustCreateGRPCConn(addr string) *grpc.ClientConn
- func MustStartGRPCServer(addr string, regFn func(s *grpc.Server))
- func New(ctx context.Context) *comptest
- func PubsubMessageToProtoMessage(m *pubsub.Message) (ptypes.DynamicAny, error)
- type CleanupFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateGRPCConn ¶
func CreateGRPCConn(addr string) (*grpc.ClientConn, error)
CreateGRPCConn will create grpc conn with disabled TLS.
func MustCreateGRPCConn ¶
func MustCreateGRPCConn(addr string) *grpc.ClientConn
func MustStartGRPCServer ¶
MustStartGRPCServer will register and start grpc server.
func PubsubMessageToProtoMessage ¶ added in v0.0.4
func PubsubMessageToProtoMessage(m *pubsub.Message) (ptypes.DynamicAny, error)
Types ¶
type CleanupFunc ¶
type CleanupFunc func()
Click to show internal directories.
Click to hide internal directories.