pulsar

package

v0.7.0 Latest Latest Go to latest Published: Nov 13, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation ¶

Index ¶

Constants
func FileExists(name string) bool
func Provider() *schema.Provider
func TopicNameValidatorDiag(i interface{}, p cty.Path) diag.Diagnostics
type PulsarClientBundle

Constants ¶

const (
	ProcessingGuaranteesAtLeastOnce     = "ATLEAST_ONCE"
	ProcessingGuaranteesAtMostOnce      = "ATMOST_ONCE"
	ProcessingGuaranteesEffectivelyOnce = "EFFECTIVELY_ONCE"
)

View Source

const (
	SubscriptionPositionEarliest = "Earliest"
	SubscriptionPositionLatest   = "Latest"
)

View Source

const DefaultPulsarAPIVersion string = "0" // 0 will automatically match the default api version

Variables ¶

This section is empty.

Functions ¶

func FileExists ¶ added in v0.1.3

func FileExists(name string) bool

Exists reports whether the named file or directory exists.

func Provider ¶

func Provider() *schema.Provider

Provider returns a schema.Provider

func TopicNameValidatorDiag ¶ added in v0.5.0

func TopicNameValidatorDiag(i interface{}, p cty.Path) diag.Diagnostics

Types ¶

type PulsarClientBundle ¶ added in v0.4.0

type PulsarClientBundle struct {
	Client   pulsaradmin.Client
	V3Client pulsaradmin.Client
}

PulsarClientBundle is a struct that holds the pulsar admin client for both v2 and v3 api versions

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL