pulsar

type Cluster interface {
	// Start a pulsar cluster.
	Start(ctx context.Context) error

	// Stop a pulsar cluster.
	Stop(ctx context.Context) error

	// GetPlainTextServiceURL gets the pulsar service connect string.
	GetPlainTextServiceURL(ctx context.Context) (string, error)

	// GetHTTPServiceURL gets the pulsar HTTP service connect string.
	GetHTTPServiceURL(ctx context.Context) (string, error)

	// Close closes resources used for starting the cluster.
	Close(ctx context.Context)
}

type ClusterDef struct {
	// contains filtered or unexported fields
}

type ClusterSpec struct {
	Image                 string
	ClusterName           string
	BookiePort            int
	NumBookies            int
	BrokerServicePort     int
	BrokerHTTPServicePort int
	NumBrokers            int
	ProxyServicePort      int
	ProxyHTTPServicePort  int
	NumProxies            int
}

type InitConf struct {
	ClusterName        string
	ConfigurationStore string
	Zookeeper          string
	Broker             string
}