Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PartitionTopics ¶
type PartitionTopics struct { NumberOfPartitions int PulsarURL string TokenSupplier func() (string, error) TrustStore string Tenant string Namespace string PartitionTopicName string TopicFullname string BaseAdminURL string // contains filtered or unexported fields }
PartitionTopics data struct is the persistent partition topic name and number of partitions it has
func NewPartitionTopic ¶
func NewPartitionTopic(url string, tokenSupplier func() (string, error), trustStore, topicFn, adminURL string, numOfPartitions int) (*PartitionTopics, error)
NewPartitionTopic creates a PartitionTopic test object
func (*PartitionTopics) CreatePartitionTopic ¶
func (pt *PartitionTopics) CreatePartitionTopic() error
CreatePartitionTopic creates a partition topic
func (*PartitionTopics) GetPartitionTopic ¶
func (pt *PartitionTopics) GetPartitionTopic() (bool, error)
GetPartitionTopic gets the partition topic
func (*PartitionTopics) TestPartitionTopic ¶
TestPartitionTopic sends multiple messages and to be verified by multiple consumers
func (*PartitionTopics) VerifyPartitionTopic ¶
func (pt *PartitionTopics) VerifyPartitionTopic() error
VerifyPartitionTopic verifies existence of the partition topic it creates one if it's missing
Click to show internal directories.
Click to hide internal directories.