pulsar/

Versions in this module

v0

v0.6.1

Dec 24, 2025

v0.6.0

Jul 1, 2025

v0.5.0

Jul 29, 2020

Changes in this version

type Client

+ func NewWithAuthProvider(config *common.Config, authProvider auth.Provider) Client

v0.4.2

Apr 8, 2020

v0.4.1

Apr 8, 2020

Changes in this version

type Functions

+ DownloadFunction func(path, destinationFile string) error

+ DownloadFunctionByNs func(destinationFile, tenant, namespace, function string) error

v0.4.0

Mar 24, 2020

v0.3.0

Jan 16, 2020

Changes in this version

type Client

+ Token func() Token

+ type Token interface

+ Create func(algorithm.Algorithm, interface{}, string, int64) (string, error)

+ CreateKeyPair func(algorithm.Algorithm) (*keypair.KeyPair, error)

+ CreateSecretKey func(algorithm.Algorithm) ([]byte, error)

+ GetAlgorithm func(string) (string, error)

+ GetSubject func(string) (string, error)

+ Validate func(algorithm.Algorithm, string, interface{}) (string, int64, error)

v0.2.0

Nov 26, 2019

Changes in this version

type Config

+ TLSAllowInsecureConnection bool

+ TLSCertFile string

+ TLSKeyFile string

+ Token string

+ TokenFile string

v0.1.0

Oct 28, 2019

Changes in this version

+ const BatchHeader

+ const DEFAULTNAMESPACE

+ const DefaultAPIVersion

+ const DefaultHTTPTimeOutDuration

+ const DefaultWebServiceURL

+ const FirstBoundary

+ const GoRuntime

+ const JavaRuntime

+ const LastBoundary

+ const PARTITIONEDTOPICSUFFIX

+ const PATTEN

+ const PUBLICTENANT

+ const PropertyPrefix

+ const PublishTimeHeader

+ const PythonRuntime

+ const WindowConfigKey

+ var EXAMPLES = "EXAMPLES:"

+ var Earliest = MessageID

+ var Latest = MessageID

+ var OUTPUT = "OUTPUT:"

+ var PERMISSION = "REQUIRED PERMISSION:"

+ var ReleaseVersion = "None"

+ var SCOPE = "SCOPE:"

+ var SPACES = " "

+ var USEDFOR = "USED FOR:"

+ func IsAdminError(err error) bool

+ type APIVersion int

+ const V1

+ const V2

+ const V3

+ func (v APIVersion) String() string

+ type AllocatorStats struct

+ DirectArenas []PoolArenaStats

+ HeapArenas []PoolArenaStats

+ NormalCacheSize int

+ NumDirectArenas int

+ NumHeapArenas int

+ NumThreadLocalCaches int

+ SmallCacheSize int

+ TinyCacheSize int

+ type AuthAction string

+ func ParseAuthAction(action string) (AuthAction, error)

+ func (a AuthAction) String() string

+ type AuthPolicies struct

+ DestinationAuth map[string]map[string]AuthAction

+ NamespaceAuth map[string]AuthAction

+ SubscriptionAuthRoles map[string][]string

+ func NewAuthPolicies() *AuthPolicies

+ type AutoFailoverPolicyData struct

+ Parameters map[string]string

+ PolicyType AutoFailoverPolicyType

+ type AutoFailoverPolicyType string

+ const MinAvailable

+ type BacklogQuota struct

+ Limit int64

+ Policy RetentionPolicy

+ func NewBacklogQuota(limit int64, policy RetentionPolicy) BacklogQuota

+ type BacklogQuotaType string

+ const DestinationStorage

+ type BookieAffinityGroupData struct

+ BookkeeperAffinityGroupPrimary string

+ BookkeeperAffinityGroupSecondary string

+ type BrokerAssignment string

+ const Primary

+ const Secondary

+ const Shared

+ type BrokerData struct

+ ConfigName string

+ ConfigValue string

+ URL string

+ type BrokerNamespaceIsolationData struct

+ BrokerName string

+ IsPrimary bool

+ NamespaceRegex []string

+ PolicyName string

+ type BrokerStats interface

+ GetAllocatorStats func(allocatorName string) (*AllocatorStats, error)

+ GetLoadReport func() (*LocalBrokerData, error)

+ GetMBeans func() ([]Metrics, error)

+ GetMetrics func() ([]Metrics, error)

+ GetTopics func() (string, error)

+ type BrokerStatsData struct

+ Indent bool

+ type Brokers interface

+ DeleteDynamicConfiguration func(configName string) error

+ GetActiveBrokers func(cluster string) ([]string, error)

+ GetAllDynamicConfigurations func() (map[string]string, error)

+ GetDynamicConfigurationNames func() ([]string, error)

+ GetInternalConfigurationData func() (*InternalConfigurationData, error)

+ GetOwnedNamespaces func(cluster, brokerURL string) (map[string]NamespaceOwnershipStatus, error)

+ GetRuntimeConfigurations func() (map[string]string, error)

+ HealthCheck func() error

+ UpdateDynamicConfiguration func(configName, configValue string) error

+ type BundlesData struct

+ Boundaries []string

+ NumBundles int

+ func NewBundlesData(boundaries []string) BundlesData

+ func NewBundlesDataWithNumBundles(numBundles int) *BundlesData

+ func NewDefaultBoundle() *BundlesData

+ type Client interface

+ BrokerStats func() BrokerStats

+ Brokers func() Brokers

+ Clusters func() Clusters

+ Functions func() Functions

+ FunctionsWorker func() FunctionsWorker

+ Namespaces func() Namespaces

+ NsIsolationPolicy func() NsIsolationPolicy

+ ResourceQuotas func() ResourceQuotas

+ Schemas func() Schema

+ Sinks func() Sinks

+ Sources func() Sources

+ Subscriptions func() Subscriptions

+ Tenants func() Tenants

+ Topics func() Topics

+ func New(config *Config) (Client, error)

+ type ClusterData struct

+ BrokerServiceURL string

+ BrokerServiceURLTls string

+ Name string

+ PeerClusterNames []string

+ ServiceURL string

+ ServiceURLTls string

+ type Clusters interface

+ Create func(ClusterData) error

+ CreateFailureDomain func(FailureDomainData) error

+ Delete func(string) error

+ DeleteFailureDomain func(FailureDomainData) error

+ Get func(string) (ClusterData, error)

+ GetFailureDomain func(clusterName, domainName string) (FailureDomainData, error)

+ GetPeerClusters func(string) ([]string, error)

+ List func() ([]string, error)

+ ListFailureDomains func(string) (FailureDomainMap, error)

+ Update func(ClusterData) error

+ UpdateFailureDomain func(FailureDomainData) error

+ UpdatePeerClusters func(string, []string) error

+ type Config struct

+ APIVersion APIVersion

+ Auth *auth.TLSAuthProvider

+ AuthParams string

+ HTTPClient *http.Client

+ HTTPTimeout time.Duration

+ TLSOptions *TLSOptions

+ TokenAuth *auth.TokenAuthProvider

+ WebServiceURL string

+ func DefaultConfig() *Config

+ type ConnectorDefinition struct

+ Description string

+ Name string

+ SinkClass string

+ SourceClass string

+ type ConsumerConfig struct

+ IsRegexPattern bool

+ ReceiverQueueSize int

+ SchemaType string

+ SerdeClassName string

+ type ConsumerStats struct

+ AvailablePermits int

+ BlockedConsumerOnUnAckedMsgs bool

+ ConsumerName string

+ Metadata map[string]string

+ MsgRateOut float64

+ MsgRateRedeliver float64

+ MsgThroughputOut float64

+ UnAckedMessages int

+ type CursorInfo struct

+ CreationDate string

+ CursorsLedgerID int64

+ IndividualDeletedMessages []MessageRangeInfo

+ MarkDelete PositionInfo

+ ModificationDate string

+ Properties map[string]int64

+ Version int

+ type CursorStats struct

+ CursorLedger int64

+ CursorLedgerLastEntry int64

+ IndividuallyDeletedMessages string

+ LastLedgerWitchTimestamp string

+ MarkDeletePosition string

+ MessagesConsumedCounter int64

+ NumberOfEntriesSinceFirstNotAckedMessage int64

+ PendingReadOps int

+ Properties map[string]int64

+ ReadPosition string

+ State string

+ TotalNonContiguousDeletedMessagesRange int

+ WaitingReadOp bool

+ type DispatchRate struct

+ DispatchThrottlingRateInByte int64

+ DispatchThrottlingRateInMsg int

+ RatePeriodInSecond int

+ func NewDispatchRate() *DispatchRate

+ type Error struct

+ Code int

+ Reason string

+ func (e Error) Error() string

+ type Example struct

+ Command string

+ Desc string

+ type ExceptionInformation struct

+ ExceptionString string

+ TimestampMs int64

+ type FailureDomainData struct

+ BrokerList []string

+ ClusterName string

+ DomainName string

+ type FailureDomainMap map[string]FailureDomainData

+ type FunctionConfig struct

+ AutoAck bool

+ ClassName string

+ CleanupSubscription bool

+ CustomSchemaInputs map[string]string

+ CustomSerdeInputs map[string]string

+ DeadLetterTopic string

+ FQFN string

+ Go string

+ InputSpecs map[string]ConsumerConfig

+ Inputs []string

+ Jar string

+ LogTopic string

+ MaxMessageRetries int

+ Name string

+ Namespace string

+ Output string

+ OutputSchemaType string

+ OutputSerdeClassName string

+ Parallelism int

+ ProcessingGuarantees string

+ Py string

+ Resources *Resources

+ RetainOrdering bool

+ Runtime string

+ RuntimeFlags string

+ Secrets map[string]interface{}

+ SubName string

+ Tenant string

+ TimeoutMs *int64

+ TopicsPattern *string

+ UserConfig map[string]interface{}

+ WindowConfig *WindowConfig

+ type FunctionData struct

+ AutoAck bool

+ CPU float64

+ ClassName string

+ CustomSchemaInput string

+ CustomSerDeInputs string

+ DeadLetterTopic string

+ Disk int64

+ FQFN string

+ FuncConf *FunctionConfig

+ FuncName string

+ FunctionConfigFile string

+ Go string

+ Inputs string

+ InstanceID string

+ Jar string

+ Key string

+ LogTopic string

+ MaxMessageRetries int

+ Namespace string

+ Output string

+ OutputSerDeClassName string

+ Parallelism int

+ ProcessingGuarantees string

+ Py string

+ RAM int64

+ RetainOrdering bool

+ SchemaType string

+ SlidingIntervalCount int

+ SlidingIntervalDurationMs int64

+ State string

+ SubsName string

+ Tenant string

+ TimeoutMs int64

+ Topic string

+ TopicsPattern string

+ TriggerFile string

+ TriggerValue string

+ UpdateAuthData bool

+ UserCodeFile string

+ UserConfig string

+ Watch bool

+ WindowLengthCount int

+ WindowLengthDurationMs int64

+ type FunctionInstanceStats struct

+ InstanceID int64

+ Metrics FunctionInstanceStatsData

+ type FunctionInstanceStatsData struct

+ LastInvocation int64

+ OneMin FunctionInstanceStatsDataBase

+ UserMetrics map[string]float64

+ type FunctionInstanceStatsDataBase struct

+ AvgProcessLatency float64

+ ProcessedSuccessfullyTotal int64

+ ReceivedTotal int64

+ SystemExceptionsTotal int64

+ UserExceptionsTotal int64

+ type FunctionInstanceStatus struct

+ InstanceID int

+ Status FunctionInstanceStatusData

+ type FunctionInstanceStatusData struct

+ AverageLatency float64

+ Err string

+ LastInvocationTime int64

+ LatestSystemExceptions []ExceptionInformation

+ LatestUserExceptions []ExceptionInformation

+ NumReceived int64

+ NumRestarts int64

+ NumSuccessfullyProcessed int64

+ NumSystemExceptions int64

+ NumUserExceptions int64

+ Running bool

+ WorkerID string

+ type FunctionState struct

+ ByteValue []byte

+ Key string

+ NumValue int64

+ StringValue string

+ Version int64

+ type FunctionStats struct

+ AvgProcessLatency float64

+ Instances []FunctionInstanceStats

+ LastInvocation int64

+ OneMin FunctionInstanceStatsDataBase

+ ProcessedSuccessfullyTotal int64

+ ReceivedTotal int64

+ SystemExceptionsTotal int64

+ UserExceptionsTotal int64

+ func (fs *FunctionStats) AddInstance(functionInstanceStats FunctionInstanceStats)

+ func (fs *FunctionStats) CalculateOverall() *FunctionStats

+ type FunctionStatus struct

+ Instances []FunctionInstanceStatus

+ NumInstances int

+ NumRunning int

+ type Functions interface

+ CreateFunc func(data *FunctionConfig, fileName string) error

+ CreateFuncWithURL func(data *FunctionConfig, pkgURL string) error

+ DeleteFunction func(tenant, namespace, name string) error

+ GetFunction func(tenant, namespace, name string) (FunctionConfig, error)

+ GetFunctionState func(tenant, namespace, name, key string) (FunctionState, error)

+ GetFunctionStats func(tenant, namespace, name string) (FunctionStats, error)

+ GetFunctionStatsWithInstanceID func(tenant, namespace, name string, instanceID int) (FunctionInstanceStatsData, error)

+ GetFunctionStatus func(tenant, namespace, name string) (FunctionStatus, error)

+ GetFunctionStatusWithInstanceID func(tenant, namespace, name string, instanceID int) (FunctionInstanceStatusData, error)

+ GetFunctions func(tenant, namespace string) ([]string, error)

+ PutFunctionState func(tenant, namespace, name string, state FunctionState) error

+ RestartFunction func(tenant, namespace, name string) error

+ RestartFunctionWithID func(tenant, namespace, name string, instanceID int) error

+ StartFunction func(tenant, namespace, name string) error

+ StartFunctionWithID func(tenant, namespace, name string, instanceID int) error

+ StopFunction func(tenant, namespace, name string) error

+ StopFunctionWithID func(tenant, namespace, name string, instanceID int) error

+ TriggerFunction func(tenant, namespace, name, topic, triggerValue, triggerFile string) (string, error)

+ UpdateFunction func(functionConfig *FunctionConfig, fileName string, updateOptions *UpdateOptions) error

+ UpdateFunctionWithURL func(functionConfig *FunctionConfig, pkgURL string, updateOptions *UpdateOptions) error

+ type FunctionsWorker interface

+ GetAssignments func() (map[string][]string, error)

+ GetCluster func() ([]*WorkerInfo, error)

+ GetClusterLeader func() (*WorkerInfo, error)

+ GetFunctionsStats func() ([]*WorkerFunctionInstanceStats, error)

+ GetMetrics func() ([]*Metrics, error)

+ type GetSchemaResponse struct

+ Data string

+ Properties map[string]string

+ Timestamp int64

+ Type string

+ Version int64

+ type InternalConfigurationData struct

+ ConfigurationStoreServers string

+ LedgersRootPath string

+ StateStorageServiceURL string

+ ZookeeperServers string

+ type KeyValue struct

+ Key *string

+ Value *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KeyValue) ProtoMessage()

+ func (m *KeyValue) Reset()

+ func (m *KeyValue) String() string

+ type LedgerInfo struct

+ Entries int64

+ LedgerID int64

+ Size int64

+ Timestamp int64

+ type LocalBrokerData struct

+ BandwidthIn ResourceUsage

+ BandwidthOut ResourceUsage

+ BrokerVersionString string

+ Bundles []string

+ CPU ResourceUsage

+ DirectMemory ResourceUsage

+ LastBundleGains []string

+ LastBundleLosses []string

+ LastStats map[string]*NamespaceBundleStats

+ LastUpdate int64

+ LoadReportType string

+ Memory ResourceUsage

+ MsgRateIn float64

+ MsgRateOut float64

+ MsgThroughputIn float64

+ MsgThroughputOut float64

+ NonPersistentTopicsEnabled bool

+ NumBundles int

+ NumConsumers int

+ NumProducers int

+ NumTopics int

+ PersistentTopicsEnabled bool

+ Protocols map[string]string

+ PulsarServiceURL string

+ PulsarServiceURLTLS string

+ WebServiceURL string

+ WebServiceURLTLS string

+ func NewLocalBrokerData() LocalBrokerData

+ type LongDescription struct

+ CommandExamples []Example

+ CommandOutput []Output

+ CommandPermission string

+ CommandScope string

+ CommandUsedFor string

+ func (desc *LongDescription) ExampleToString() string

+ func (desc *LongDescription) ToString() string

+ type LongRunningProcessStatus struct

+ LastError string

+ Status Status

+ type LookupData struct

+ BrokerURL string

+ BrokerURLTLS string

+ HTTPURL string

+ HTTPURLTLS string

+ type ManagedLedgerInfo struct

+ CreationDate string

+ Cursors map[string]CursorInfo

+ Ledgers []LedgerInfo

+ ModificationData string

+ TerminatedPosition PositionInfo

+ Version int

+ type Message struct

+ func NewMessage(topic string, id MessageID, payload []byte, properties map[string]string) *Message

+ func (m *Message) GetMessageID() MessageID

+ func (m *Message) GetPayload() []byte

+ func (m *Message) GetProperties() map[string]string

+ type MessageID struct

+ BatchIndex int

+ EntryID int64

+ LedgerID int64

+ PartitionedIndex int

+ func ParseMessageID(str string) (*MessageID, error)

+ func (m MessageID) String() string

+ type MessageRangeInfo struct

+ From PositionInfo

+ Offloaded bool

+ To PositionInfo

+ type Metrics struct

+ Dimensions map[string]string

+ Metrics map[string]interface{}

+ func NewMetrics(dimensionMap map[string]string) *Metrics

+ type NameSpaceName struct

+ func GetNameSpaceName(tenant, namespace string) (*NameSpaceName, error)

+ func GetNamespaceName(completeName string) (*NameSpaceName, error)

+ func (n *NameSpaceName) String() string

+ type NamespaceBundleStats struct

+ CacheSize int64

+ CacheSizeDifferenceThreshold int64

+ ConsumerCount int

+ MsgRateDifferenceThreshold float64

+ MsgRateIn float64

+ MsgRateOut float64

+ MsgThroughputIn float64

+ MsgThroughputOut float64

+ ProducerCount int

+ ThroughputDifferenceThreshold float64

+ TopicConnectionDifferenceThreshold int64

+ TopicsNum int64

+ func NewNamespaceBundleStats() *NamespaceBundleStats

+ type NamespaceIsolationData struct

+ AutoFailoverPolicy AutoFailoverPolicyData

+ Namespaces []string

+ Primary []string

+ Secondary []string

+ func CreateNamespaceIsolationData(namespaces, primary, secondry []string, autoFailoverPolicyTypeName string, ...) (*NamespaceIsolationData, error)

+ type NamespaceOwnershipStatus struct

+ BrokerAssignment BrokerAssignment

+ IsActive bool

+ IsControlled bool

+ type Namespaces interface

+ ClearNamespaceBacklog func(namespace NameSpaceName) error

+ ClearNamespaceBacklogForSubscription func(namespace NameSpaceName, sName string) error

+ ClearNamespaceBundleBacklog func(namespace NameSpaceName, bundle string) error

+ ClearNamespaceBundleBacklogForSubscription func(namespace NameSpaceName, bundle, sName string) error

+ ClearOffloadDeleteLag func(namespace NameSpaceName) error

+ CreateNamespace func(namespace string) error

+ CreateNsWithBundlesData func(namespace string, bundleData *BundlesData) error

+ CreateNsWithNumBundles func(namespace string, numBundles int) error

+ CreateNsWithPolices func(namespace string, polices Policies) error

+ DeleteBookieAffinityGroup func(namespace string) error

+ DeleteNamespace func(namespace string) error

+ DeleteNamespaceAntiAffinityGroup func(namespace string) error

+ DeleteNamespaceBundle func(namespace string, bundleRange string) error

+ GetAntiAffinityNamespaces func(tenant, cluster, namespaceAntiAffinityGroup string) ([]string, error)

+ GetBacklogQuotaMap func(namespace string) (map[BacklogQuotaType]BacklogQuota, error)

+ GetBookieAffinityGroup func(namespace string) (*BookieAffinityGroupData, error)

+ GetCompactionThreshold func(namespace NameSpaceName) (int64, error)

+ GetDispatchRate func(namespace NameSpaceName) (DispatchRate, error)

+ GetMaxConsumersPerSubscription func(namespace NameSpaceName) (int, error)

+ GetMaxConsumersPerTopic func(namespace NameSpaceName) (int, error)

+ GetMaxProducersPerTopic func(namespace NameSpaceName) (int, error)

+ GetNamespaceAntiAffinityGroup func(namespace string) (string, error)

+ GetNamespaceMessageTTL func(namespace string) (int, error)

+ GetNamespacePermissions func(namespace NameSpaceName) (map[string][]AuthAction, error)

+ GetNamespaceReplicationClusters func(namespace string) ([]string, error)

+ GetNamespaces func(tenant string) ([]string, error)

+ GetOffloadDeleteLag func(namespace NameSpaceName) (int64, error)

+ GetOffloadThreshold func(namespace NameSpaceName) (int64, error)

+ GetPersistence func(namespace string) (*PersistencePolicies, error)

+ GetPolicies func(namespace string) (*Policies, error)

+ GetReplicatorDispatchRate func(namespace NameSpaceName) (DispatchRate, error)

+ GetRetention func(namespace string) (*RetentionPolicies, error)

+ GetSchemaAutoUpdateCompatibilityStrategy func(namespace NameSpaceName) (SchemaCompatibilityStrategy, error)

+ GetSchemaValidationEnforced func(namespace NameSpaceName) (bool, error)

+ GetSubscribeRate func(namespace NameSpaceName) (SubscribeRate, error)

+ GetSubscriptionDispatchRate func(namespace NameSpaceName) (DispatchRate, error)

+ GetTopics func(namespace string) ([]string, error)

+ GrantNamespacePermission func(namespace NameSpaceName, role string, action []AuthAction) error

+ GrantSubPermission func(namespace NameSpaceName, sName string, roles []string) error

+ RemoveBacklogQuota func(namespace string) error

+ RevokeNamespacePermission func(namespace NameSpaceName, role string) error

+ RevokeSubPermission func(namespace NameSpaceName, sName, role string) error

+ SetBacklogQuota func(namespace string, backlogQuota BacklogQuota) error

+ SetBookieAffinityGroup func(namespace string, bookieAffinityGroup BookieAffinityGroupData) error

+ SetCompactionThreshold func(namespace NameSpaceName, threshold int64) error

+ SetDeduplicationStatus func(namespace string, enableDeduplication bool) error

+ SetDispatchRate func(namespace NameSpaceName, rate DispatchRate) error

+ SetEncryptionRequiredStatus func(namespace NameSpaceName, encrypt bool) error

+ SetMaxConsumersPerSubscription func(namespace NameSpaceName, max int) error

+ SetMaxConsumersPerTopic func(namespace NameSpaceName, max int) error

+ SetMaxProducersPerTopic func(namespace NameSpaceName, max int) error

+ SetNamespaceAntiAffinityGroup func(namespace string, namespaceAntiAffinityGroup string) error

+ SetNamespaceMessageTTL func(namespace string, ttlInSeconds int) error

+ SetNamespaceReplicationClusters func(namespace string, clusterIds []string) error

+ SetOffloadDeleteLag func(namespace NameSpaceName, timeMs int64) error

+ SetOffloadThreshold func(namespace NameSpaceName, threshold int64) error

+ SetPersistence func(namespace string, persistence PersistencePolicies) error

+ SetReplicatorDispatchRate func(namespace NameSpaceName, rate DispatchRate) error

+ SetRetention func(namespace string, policy RetentionPolicies) error

+ SetSchemaAutoUpdateCompatibilityStrategy func(namespace NameSpaceName, strategy SchemaCompatibilityStrategy) error

+ SetSchemaValidationEnforced func(namespace NameSpaceName, schemaValidationEnforced bool) error

+ SetSubscribeRate func(namespace NameSpaceName, rate SubscribeRate) error

+ SetSubscriptionAuthMode func(namespace NameSpaceName, mode SubscriptionAuthMode) error

+ SetSubscriptionDispatchRate func(namespace NameSpaceName, rate DispatchRate) error

+ SplitNamespaceBundle func(namespace, bundle string, unloadSplitBundles bool) error

+ Unload func(namespace string) error

+ UnloadNamespaceBundle func(namespace, bundle string) error

+ UnsubscribeNamespace func(namespace NameSpaceName, sName string) error

+ UnsubscribeNamespaceBundle func(namespace NameSpaceName, bundle, sName string) error

+ type NamespacesData struct

+ AntiAffinityGroup string

+ BookkeeperAckQuorum int

+ BookkeeperEnsemble int

+ BookkeeperWriteQuorum int

+ Bundle string

+ Cluster string

+ ClusterIds string

+ Clusters []string

+ Enable bool

+ LimitStr string

+ ManagedLedgerMaxMarkDeleteRate float64

+ MessageTTL int

+ NumBundles int

+ PolicyStr string

+ RetentionTimeStr string

+ Tenant string

+ Unload bool

+ type NsIsolationPoliciesData struct

+ AutoFailoverPolicyParams string

+ AutoFailoverPolicyTypeName string

+ Namespaces []string

+ Primary []string

+ Secondary []string

+ type NsIsolationPolicy interface

+ CreateNamespaceIsolationPolicy func(cluster, policyName string, namespaceIsolationData NamespaceIsolationData) error

+ DeleteNamespaceIsolationPolicy func(cluster, policyName string) error

+ GetBrokerWithNamespaceIsolationPolicy func(cluster, broker string) (*BrokerNamespaceIsolationData, error)

+ GetBrokersWithNamespaceIsolationPolicy func(cluster string) ([]BrokerNamespaceIsolationData, error)

+ GetNamespaceIsolationPolicies func(cluster string) (map[string]NamespaceIsolationData, error)

+ GetNamespaceIsolationPolicy func(cluster, policyName string) (*NamespaceIsolationData, error)

+ type OffloadProcessStatus struct

+ FirstUnOffloadedMessage MessageID

+ LastError string

+ Status Status

+ type Output struct

+ Desc string

+ Out string

+ type PartitionedTopicMetadata struct

+ Partitions int

+ type PartitionedTopicStats struct

+ AverageMsgSize float64

+ DeDuplicationStatus string

+ Metadata PartitionedTopicMetadata

+ MsgRateIn float64

+ MsgRateOut float64

+ MsgThroughputIn float64

+ MsgThroughputOut float64

+ Partitions map[string]TopicStats

+ Publishers []PublisherStats

+ Replication map[string]ReplicatorStats

+ StorageSize int64

+ Subscriptions map[string]SubscriptionStats

+ type PersistencePolicies struct

+ BookkeeperAckQuorum int

+ BookkeeperEnsemble int

+ BookkeeperWriteQuorum int

+ ManagedLedgerMaxMarkDeleteRate float64

+ func NewPersistencePolicies(bookkeeperEnsemble, bookkeeperWriteQuorum, bookkeeperAckQuorum int, ...) PersistencePolicies

+ type PersistentTopicInternalStats struct

+ CurrentLedgerEntries int64

+ CurrentLedgerSize int64

+ Cursors map[string]CursorStats

+ EntriesAddedCounter int64

+ LastConfirmedEntry string

+ LastLedgerCreatedTimestamp string

+ LastLedgerCreationFailureTimestamp string

+ Ledgers []LedgerInfo

+ NumberOfEntries int64

+ PendingAddEntriesCount int

+ State string

+ TotalSize int64

+ WaitingCursorsCount int

+ type Policies struct

+ AntiAffinityGroup string

+ AuthPolicies AuthPolicies

+ BacklogQuotaMap map[BacklogQuotaType]BacklogQuota

+ Bundles *BundlesData

+ ClusterSubscribeRate map[string]SubscribeRate

+ CompactionThreshold int64

+ DeduplicationEnabled bool

+ Deleted bool

+ EncryptionRequired bool

+ LatencyStatsSampleRate map[string]int

+ MaxConsumersPerSubscription int

+ MaxConsumersPerTopic int

+ MaxProducersPerTopic int

+ MessageTTLInSeconds int

+ OffloadDeletionLagMs int64

+ OffloadThreshold int64

+ Persistence *PersistencePolicies

+ ReplicationClusters []string

+ ReplicatorDispatchRate map[string]DispatchRate

+ RetentionPolicies *RetentionPolicies

+ SchemaCompatibilityStrategy SchemaCompatibilityStrategy

+ SchemaValidationEnforced bool

+ SubscriptionAuthMode SubscriptionAuthMode

+ SubscriptionDispatchRate map[string]DispatchRate

+ TopicDispatchRate map[string]DispatchRate

+ func NewDefaultPolicies() *Policies

+ type PoolArenaStats struct

+ ChunkLists []PoolChunkListStats

+ NumActiveAllocations int64

+ NumActiveHugeAllocations int64

+ NumActiveNormalAllocations int64

+ NumActiveSmallAllocations int64

+ NumActiveTinyAllocations int64

+ NumAllocations int64

+ NumChunkLists int

+ NumDeallocations int64

+ NumHugeAllocations int64

+ NumHugeDeallocations int64

+ NumNormalAllocations int64

+ NumNormalDeallocations int64

+ NumSmallAllocations int64

+ NumSmallDeallocations int64

+ NumSmallSubpages int

+ NumTinyAllocations int64

+ NumTinyDeallocations int64

+ NumTinySubpages int

+ SmallSubpages []PoolSubpageStats

+ TinySubpages []PoolSubpageStats

+ type PoolChunkListStats struct

+ Chunks []PoolChunkStats

+ MaxUsage int

+ MinUsage int

+ type PoolChunkStats struct

+ ChunkSize int

+ FreeBytes int

+ Usage int

+ type PoolSubpageStats struct

+ ElementSize int

+ MaxNumElements int

+ NumAvailable int

+ PageSize int

+ type PositionInfo struct

+ EntryID int64

+ LedgerID int64

+ type PostSchemaPayload struct

+ Properties map[string]string

+ Schema string

+ SchemaType string

+ type PublisherStats struct

+ AverageMsgSize float64

+ Metadata map[string]string

+ MsgRateIn float64

+ MsgThroughputIn float64

+ ProducerID int64

+ type ReplicatorStats struct

+ Connected bool

+ InboundConnectedSince string

+ InboundConnection string

+ MsgRateExpired float64

+ MsgRateIn float64

+ MsgRateOut float64

+ MsgThroughputIn float64

+ MsgThroughputOut float64

+ OutboundConnectedSince string

+ OutboundConnection string

+ ReplicationBacklog int64

+ ReplicationDelayInSeconds int64

+ type ResourceQuota struct

+ BandwidthIn float64

+ BandwidthOut float64

+ Dynamic bool

+ Memory float64

+ MsgRateIn float64

+ MsgRateOut float64

+ func NewResourceQuota() *ResourceQuota

+ type ResourceQuotaData struct

+ BandwidthIn int64

+ BandwidthOut int64

+ Bundle string

+ Dynamic bool

+ Memory int64

+ MsgRateIn int64

+ MsgRateOut int64

+ Names string

+ type ResourceQuotas interface

+ GetDefaultResourceQuota func() (*ResourceQuota, error)

+ GetNamespaceBundleResourceQuota func(namespace, bundle string) (*ResourceQuota, error)

+ ResetNamespaceBundleResourceQuota func(namespace, bundle string) error

+ SetDefaultResourceQuota func(quota ResourceQuota) error

+ SetNamespaceBundleResourceQuota func(namespace, bundle string, quota ResourceQuota) error

+ type ResourceUsage struct

+ Limit float64

+ Usage float64

+ func (ru *ResourceUsage) CompareTo(o *ResourceUsage) int

+ func (ru *ResourceUsage) PercentUsage() float32

+ func (ru *ResourceUsage) Reset()

+ type Resources struct

+ CPU float64

+ Disk int64

+ RAM int64

+ func NewDefaultResources() *Resources

+ type RetentionPolicies struct

+ RetentionSizeInMB int64

+ RetentionTimeInMinutes int

+ func NewRetentionPolicies(retentionTimeInMinutes int, retentionSizeInMB int) RetentionPolicies

+ type RetentionPolicy string

+ const ConsumerBacklogEviction

+ const ProducerException

+ const ProducerRequestHold

+ type Schema interface

+ CreateSchemaByPayload func(topic string, schemaPayload PostSchemaPayload) error

+ DeleteSchema func(topic string) error

+ GetSchemaInfo func(topic string) (*SchemaInfo, error)

+ GetSchemaInfoByVersion func(topic string, version int64) (*SchemaInfo, error)

+ GetSchemaInfoWithVersion func(topic string) (*SchemaInfoWithVersion, error)

+ type SchemaCompatibilityStrategy string

+ const AlwaysCompatible

+ const AutoUpdateDisabled

+ const Backward

+ const BackwardTransitive

+ const Forward

+ const ForwardTransitive

+ const Full

+ const FullTransitive

+ func ParseSchemaAutoUpdateCompatibilityStrategy(str string) (SchemaCompatibilityStrategy, error)

+ func (s SchemaCompatibilityStrategy) String() string

+ type SchemaData struct

+ AlwaysAllowNull bool

+ Classname string

+ DryRun bool

+ Filename string

+ Jar string

+ Type string

+ Version int64

+ type SchemaInfo struct

+ Name string

+ Properties map[string]string

+ Schema []byte

+ Type string

+ type SchemaInfoWithVersion struct

+ SchemaInfo *SchemaInfo

+ Version int64

+ type SingleMessageMetadata struct

+ CompactedOut *bool

+ EventTime *uint64

+ OrderingKey []byte

+ PartitionKey *string

+ PartitionKeyB64Encoded *bool

+ PayloadSize *int32

+ Properties []*KeyValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SingleMessageMetadata) ProtoMessage()

+ func (m *SingleMessageMetadata) GetPayloadSize() int32

+ func (m *SingleMessageMetadata) Reset()

+ func (m *SingleMessageMetadata) String() string

+ type SinkConfig struct

+ Archive string

+ AutoAck bool

+ ClassName string

+ CleanupSubscription bool

+ Configs map[string]interface{}

+ InputSpecs map[string]ConsumerConfig

+ Inputs []string

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ Resources *Resources

+ RetainOrdering bool

+ RuntimeFlags string

+ Secrets map[string]interface{}

+ SourceSubscriptionName string

+ Tenant string

+ TimeoutMs *int64

+ TopicToSchemaType map[string]string

+ TopicToSerdeClassName map[string]string

+ TopicsPattern *string

+ type SinkData struct

+ Archive string

+ AutoAck bool

+ CPU float64

+ ClassName string

+ CustomSchemaInputString string

+ CustomSerdeInputString string

+ Disk int64

+ Inputs string

+ InstanceID string

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ RAM int64

+ RetainOrdering bool

+ SinkConf *SinkConfig

+ SinkConfigFile string

+ SinkConfigString string

+ SinkType string

+ SubsName string

+ Tenant string

+ TimeoutMs int64

+ TopicsPattern string

+ UpdateAuthData bool

+ type SinkInstanceStatus struct

+ InstanceID int

+ Status SourceInstanceStatusData

+ type SinkInstanceStatusData struct

+ Err string

+ LastReceivedTime int64

+ LatestSinkExceptions []ExceptionInformation

+ LatestSystemExceptions []ExceptionInformation

+ NumReadFromPulsar int64

+ NumRestarts int64

+ NumSinkExceptions int64

+ NumSystemExceptions int64

+ NumWrittenToSink int64

+ Running bool

+ WorkerID string

+ type SinkStatus struct

+ Instances []*SinkInstanceStatus

+ NumInstances int

+ NumRunning int

+ type Sinks interface

+ CreateSink func(config *SinkConfig, fileName string) error

+ CreateSinkWithURL func(config *SinkConfig, pkgURL string) error

+ DeleteSink func(tenant, namespace, Sink string) error

+ GetBuiltInSinks func() ([]*ConnectorDefinition, error)

+ GetSink func(tenant, namespace, Sink string) (SinkConfig, error)

+ GetSinkStatus func(tenant, namespace, Sink string) (SinkStatus, error)

+ GetSinkStatusWithID func(tenant, namespace, Sink string, id int) (SinkInstanceStatusData, error)

+ ListSinks func(tenant, namespace string) ([]string, error)

+ ReloadBuiltInSinks func() error

+ RestartSink func(tenant, namespace, Sink string) error

+ RestartSinkWithID func(tenant, namespace, Sink string, id int) error

+ StartSink func(tenant, namespace, Sink string) error

+ StartSinkWithID func(tenant, namespace, Sink string, id int) error

+ StopSink func(tenant, namespace, Sink string) error

+ StopSinkWithID func(tenant, namespace, Sink string, id int) error

+ UpdateSink func(config *SinkConfig, fileName string, options *UpdateOptions) error

+ UpdateSinkWithURL func(config *SinkConfig, pkgURL string, options *UpdateOptions) error

+ type SourceConfig struct

+ Archive string

+ ClassName string

+ Configs map[string]interface{}

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ Resources *Resources

+ RuntimeFlags string

+ SchemaType string

+ Secrets map[string]interface{}

+ SerdeClassName string

+ Tenant string

+ TopicName string

+ type SourceData struct

+ Archive string

+ CPU float64

+ ClassName string

+ DeserializationClassName string

+ DestinationTopicName string

+ Disk int64

+ InstanceID string

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ RAM int64

+ SchemaType string

+ SourceConf *SourceConfig

+ SourceConfigFile string

+ SourceConfigString string

+ SourceType string

+ Tenant string

+ UpdateAuthData bool

+ type SourceInstanceStatus struct

+ InstanceID int

+ Status SourceInstanceStatusData

+ type SourceInstanceStatusData struct

+ Err string

+ LastReceivedTime int64

+ LatestSourceExceptions []ExceptionInformation

+ LatestSystemExceptions []ExceptionInformation

+ NumReceivedFromSource int64

+ NumRestarts int64

+ NumSourceExceptions int64

+ NumSystemExceptions int64

+ NumWritten int64

+ Running bool

+ WorkerID string

+ type SourceStatus struct

+ Instances []*SourceInstanceStatus

+ NumInstances int

+ NumRunning int

+ type Sources interface

+ CreateSource func(config *SourceConfig, fileName string) error

+ CreateSourceWithURL func(config *SourceConfig, pkgURL string) error

+ DeleteSource func(tenant, namespace, source string) error

+ GetBuiltInSources func() ([]*ConnectorDefinition, error)

+ GetSource func(tenant, namespace, source string) (SourceConfig, error)

+ GetSourceStatus func(tenant, namespace, source string) (SourceStatus, error)

+ GetSourceStatusWithID func(tenant, namespace, source string, id int) (SourceInstanceStatusData, error)

+ ListSources func(tenant, namespace string) ([]string, error)

+ ReloadBuiltInSources func() error

+ RestartSource func(tenant, namespace, source string) error

+ RestartSourceWithID func(tenant, namespace, source string, id int) error

+ StartSource func(tenant, namespace, source string) error

+ StartSourceWithID func(tenant, namespace, source string, id int) error

+ StopSource func(tenant, namespace, source string) error

+ StopSourceWithID func(tenant, namespace, source string, id int) error

+ UpdateSource func(config *SourceConfig, fileName string, options *UpdateOptions) error

+ UpdateSourceWithURL func(config *SourceConfig, pkgURL string, options *UpdateOptions) error

+ type Status string

+ const ERROR

+ const NOTRUN

+ const RUNNING

+ const SUCCESS

+ func (s Status) String() string

+ type SubscribeRate struct

+ RatePeriodInSecond int

+ SubscribeThrottlingRatePerConsumer int

+ func NewSubscribeRate() *SubscribeRate

+ type SubscriptionAuthMode string

+ const None

+ const Prefix

+ func ParseSubscriptionAuthMode(s string) (SubscriptionAuthMode, error)

+ func (s SubscriptionAuthMode) String() string

+ type SubscriptionStats struct

+ ActiveConsumerName string

+ BlockedSubscriptionOnUnackedMsgs bool

+ Consumers []ConsumerStats

+ IsReplicated bool

+ MsgBacklog int64

+ MsgDelayed int64

+ MsgRateExpired float64

+ MsgRateOut float64

+ MsgRateRedeliver float64

+ MsgThroughputOut float64

+ SubType string

+ UnAckedMessages int64

+ type Subscriptions interface

+ ClearBacklog func(TopicName, string) error

+ Create func(TopicName, string, MessageID) error

+ Delete func(TopicName, string) error

+ ExpireAllMessages func(TopicName, int64) error

+ ExpireMessages func(TopicName, string, int64) error

+ List func(TopicName) ([]string, error)

+ PeekMessages func(TopicName, string, int) ([]*Message, error)

+ ResetCursorToMessageID func(TopicName, string, MessageID) error

+ ResetCursorToTimestamp func(TopicName, string, int64) error

+ SkipMessages func(TopicName, string, int64) error

+ type TLSOptions struct

+ AllowInsecureConnection bool

+ TrustCertsFilePath string

+ type TenantData struct

+ AdminRoles []string

+ AllowedClusters []string

+ Name string

+ type Tenants interface

+ Create func(TenantData) error

+ Delete func(string) error

+ Get func(string) (TenantData, error)

+ List func() ([]string, error)

+ Update func(TenantData) error

+ type TopicDomain string

+ func ParseTopicDomain(domain string) (TopicDomain, error)

+ func (t TopicDomain) String() string

+ type TopicName struct

+ func GetTopicName(completeName string) (*TopicName, error)

+ func (t *TopicName) GetDomain() TopicDomain

+ func (t *TopicName) GetEncodedTopic() string

+ func (t *TopicName) GetLocalName() string

+ func (t *TopicName) GetPartition(index int) (*TopicName, error)

+ func (t *TopicName) GetRestPath() string

+ func (t *TopicName) IsPersistent() bool

+ func (t *TopicName) String() string

+ type TopicStats struct

+ AverageMsgSize float64

+ DeDuplicationStatus string

+ MsgRateIn float64

+ MsgRateOut float64

+ MsgThroughputIn float64

+ MsgThroughputOut float64

+ Publishers []PublisherStats

+ Replication map[string]ReplicatorStats

+ StorageSize int64

+ Subscriptions map[string]SubscriptionStats

+ type TopicStatsStream struct

+ TopicsMap map[string]map[string]map[string]TopicStats

+ type Topics interface

+ Compact func(TopicName) error

+ CompactStatus func(TopicName) (LongRunningProcessStatus, error)

+ Create func(TopicName, int) error

+ Delete func(TopicName, bool, bool) error

+ GetBundleRange func(TopicName) (string, error)

+ GetInternalInfo func(TopicName) (ManagedLedgerInfo, error)

+ GetInternalStats func(TopicName) (PersistentTopicInternalStats, error)

+ GetLastMessageID func(TopicName) (MessageID, error)

+ GetMetadata func(TopicName) (PartitionedTopicMetadata, error)

+ GetPartitionedStats func(TopicName, bool) (PartitionedTopicStats, error)

+ GetPermissions func(TopicName) (map[string][]AuthAction, error)

+ GetStats func(TopicName) (TopicStats, error)

+ GrantPermission func(TopicName, string, []AuthAction) error

+ List func(NameSpaceName) ([]string, []string, error)

+ Lookup func(TopicName) (LookupData, error)

+ Offload func(TopicName, MessageID) error

+ OffloadStatus func(TopicName) (OffloadProcessStatus, error)

+ RevokePermission func(TopicName, string) error

+ Terminate func(TopicName) (MessageID, error)

+ Unload func(TopicName) error

+ Update func(TopicName, int) error

+ type UpdateOptions struct

+ UpdateAuthData bool

+ func NewUpdateOptions() *UpdateOptions

+ type WindowConfig struct

+ ActualWindowFunctionClassName string

+ LateDataTopic string

+ MaxLagMs int64

+ SlidingIntervalCount int

+ SlidingIntervalDurationMs int64

+ TimestampExtractorClassName string

+ WatermarkEmitIntervalMs int64

+ WindowLengthCount int

+ WindowLengthDurationMs int64

+ func NewDefaultWindowConfing() *WindowConfig

+ type WorkerFunctionInstanceStats struct

+ Metrics FunctionInstanceStatsData

+ Name string

+ type WorkerInfo struct

+ Port int

+ WorkerHostname string

+ WorkerID string

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