Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + func InvokeEventRecorder(suite *processorsuite.TestSuite, host string, ...) + type AbstractBrokerSuite struct + BrokerContainerID string + BrokerContainerNetworkName string + BrokerHost string + FunctionPaths map[string]string + HttpClient *http.Client + SkipStartBrokerContainer bool + func NewAbstractBrokerSuite(brokerSuite BrokerSuite) *AbstractBrokerSuite + func (suite *AbstractBrokerSuite) EnsureDockerNetworkExisting() + func (suite *AbstractBrokerSuite) GetContainerRunInfo() (string, *dockerclient.RunOptions) + func (suite *AbstractBrokerSuite) RunContainer(imageName string, runOptions *dockerclient.RunOptions) string + func (suite *AbstractBrokerSuite) SendHTTPRequest(request *Request) (*http.Response, error) + func (suite *AbstractBrokerSuite) SetupSuite() + func (suite *AbstractBrokerSuite) StartBrokerContainer(imageName string, runOptions *dockerclient.RunOptions) + func (suite *AbstractBrokerSuite) TearDownSuite() + func (suite *AbstractBrokerSuite) WaitForBroker() error + type BrokerSuite interface + GetContainerRunInfo func() (string, *dockerclient.RunOptions) + WaitForBroker func() error + type Event struct + Body string + Headers map[string]string + Timestamp string + func GetEventRecorderReceivedEvents(logger logger.Logger, functionHost string, functionPort int) ([]Event, error) + type MessagePublisher func(string, string) error + type PostPublishChecks struct + ConsumerGroup string + ExpectedNumberOfCommittedOffsets int + ValidateAckFunction func(consumerGroup string, topic string, expectedNumberOfCommittedOffsets int) bool + type Request struct + Body string + Headers map[string]interface{} + Loglevel string + Method string + Path string + Port int + Url string + type TopicMessages struct + CustomMessagePrefix string + NumMessages int
Go to main page