README
¶
Functional Tests
These tests exercise integration of the system
Before running, start the ZK and Kafka docker containers by running make functional-test/services/start in the root of the repo.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Provisioner ¶
type Provisioner struct {
// contains filtered or unexported fields
}
Provisioner encapsulates provisioning the test environment
func NewProvisioner ¶
func NewProvisioner(conf queue.Config) (*Provisioner, error)
NewProvisioner creates a new provisioner instance
func (*Provisioner) ProvisionTopics ¶
func (p *Provisioner) ProvisionTopics(ctx context.Context) error
ProvisionTopics creates the Kafka topics for (re)delivering queue messages
func (*Provisioner) TeardownTopics ¶
func (p *Provisioner) TeardownTopics(ctx context.Context) error
TeardownTopics deletes the marker and message topics from Kafka
Source Files
Click to show internal directories.
Click to hide internal directories.