Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseSessions ¶
CloseSessions closes the given sessions
func OpenSessions ¶
func OpenSessions(partitions []primitive.Partition, opts ...primitive.SessionOption) ([]*primitive.Session, error)
OpenSessions opens sessions for the given partitions
func StartTestPartitions ¶
StartTestPartitions starts the given number of local partitions and returns client connections for them
func StopTestPartitions ¶
func StopTestPartitions(chans []chan struct{})
StopTestPartitions stops the given test partition channels
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.