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
Token string
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, token, 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
Source Files
Click to show internal directories.
Click to hide internal directories.