triggertest

type AbstractBrokerSuite struct {
	processorsuite.TestSuite

	BrokerHost                 string
	FunctionPaths              map[string]string
	BrokerContainerID          string
	BrokerContainerNetworkName string
	SkipStartBrokerContainer   bool

	HttpClient *http.Client
	// contains filtered or unexported fields
}

type BrokerSuite interface {

	// GetContainerRunInfo returns information about the broker container
	GetContainerRunInfo() (string, *dockerclient.RunOptions)

	// WaitForBroker waits until the broker is ready
	WaitForBroker() error
}

type Event struct {
	Body      string            `json:"body"`
	Headers   map[string]string `json:"headers"`
	Timestamp string            `json:"timestamp"`
}

type MessagePublisher func(string, string) error

type PostPublishChecks struct {
	ValidateAckFunction              func(consumerGroup string, topic string, expectedNumberOfCommittedOffsets int) bool
	ExpectedNumberOfCommittedOffsets int
	ConsumerGroup                    string
}

type Request struct {
	Port     int
	Url      string
	Path     string
	Method   string
	Body     string
	Loglevel string
	Headers  map[string]interface{}
}

type TopicMessages struct {
	NumMessages         int
	CustomMessagePrefix string
}