test

Documentation

Index

• func CloseSessions(sessions []*primitive.Session)
• func OpenSessions(partitions []primitive.Partition, opts ...primitive.SessionOption) ([]*primitive.Session, error)
• func StartTestPartitions(numPartitions int) ([]primitive.Partition, []chan struct{})
• func StopTestPartitions(chans []chan struct{})

Functions

func CloseSessions

func CloseSessions(sessions []*primitive.Session)

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

func StartTestPartitions(numPartitions int) ([]primitive.Partition, []chan struct{})

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