# Functions
New creates a mock Ensign server for testing Ensign responses to RPC calls.
New creates a bufconn listener ready to attach servers and clients to.
NewEvent returns an event with random data.
NewEventWrapper returns an event wrapper with random data inside.
By default new publish handlers ack all events and return the specified topic map.
No description provided by the author
Allows you to pass an already instantiated grpc bufconn.Listener into the Listener.
The default buffer size is 1MiB -- if ou need a larger buffer to send larger messages then specify this dial option with a larger size.
WithTarget allows the user to change the "endpoint" of the connection from "bufnet" to some other endpoint.
# Constants
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
RPC Name constants based on the FullMethod that is returned from gRPC info.
# Variables
No description provided by the author
# Structs
Implements a mock gRPC server for testing Ensign client connections.
EventFactory creates random events with standard defaults.
Listener handles gRPC connections using an in-memory buffer that is useful for testing to prevent actual TCP network requests.
PublishHandler provides an OnPublish function that assists in the testing of publish streams by breaking down the initialization and messaging phase of the publisher stream.
SubscribeHandler provides an OnSubscribe function that assists in the testing of subscribe streams by breaking down the initialization and messaging phases of the subscription stream.
# Type aliases
DialOption -- optional arguments for constructing a Listener.