test

Documentation

Index

• func ConsumeMessages[P any](suite *PulsarTestSuite, ctx context.Context, consumer pulsar.Consumer, ...) (actualPayloads []P)
• func ProduceMessages[P any](suite *PulsarTestSuite, ctx context.Context, producer pulsar.Producer, ...)
• func ProduceObjectsToTopic[P any](suite *PulsarTestSuite, topic connector.TopicName, payloads []P)
• func ProduceToTopic(suite *PulsarTestSuite, topic connector.TopicName, payloads [][]byte)
• func SubscribeToTopic[P any](suite *PulsarTestSuite, topic connector.TopicName, payloads []P, ...) (consumeFunc func() []P)
• type PulsarTestSuite
  • func (suite *PulsarTestSuite) SetupSuite()
  • func (suite *PulsarTestSuite) SetupTest()
  • func (suite *PulsarTestSuite) TearDownSuite()
  • func (suite *PulsarTestSuite) TearDownTest()

Functions

func ConsumeMessages

func ConsumeMessages[P any](suite *PulsarTestSuite, ctx context.Context, consumer pulsar.Consumer, consumerId string, timeoutSeconds int) (actualPayloads []P)

func ProduceMessages

func ProduceMessages[P any](suite *PulsarTestSuite, ctx context.Context, producer pulsar.Producer, payloads []P)

func ProduceObjectsToTopic

func ProduceObjectsToTopic[P any](suite *PulsarTestSuite, topic connector.TopicName, payloads []P)

func ProduceToTopic

func ProduceToTopic(suite *PulsarTestSuite, topic connector.TopicName, payloads [][]byte)

func SubscribeToTopic

func SubscribeToTopic[P any](suite *PulsarTestSuite, topic connector.TopicName, payloads []P, subscription string) (consumeFunc func() []P)

SubscribeToTopic - subscribe to a topic and returns a function that consumes messages from the topic

Types

type PulsarTestSuite

type PulsarTestSuite struct {
	suite.Suite
	DefaultTestConfig config.PulsarConfig
	Client            connector.Client
	AppPortStart      int
	AdminPortStart    int
	// contains filtered or unexported fields
}

func (*PulsarTestSuite) SetupSuite

func (suite *PulsarTestSuite) SetupSuite()

func (*PulsarTestSuite) SetupTest

func (suite *PulsarTestSuite) SetupTest()

func (*PulsarTestSuite) TearDownSuite

func (suite *PulsarTestSuite) TearDownSuite()

func (*PulsarTestSuite) TearDownTest

func (suite *PulsarTestSuite) TearDownTest()