utils

package

Go to main page

Versions in this module

v0

v0.18.0

Dec 8, 2025

Changes in this version

type SchemaInfo

+ Timestamp int64

v0.18.0-candidate-2

Dec 8, 2025

v0.18.0-candidate-1

Dec 1, 2025

v0.17.0

Oct 10, 2025

v0.17.0-candidate-1

Oct 10, 2025

v0.16.0

Jul 28, 2025

Changes in this version

+ type AutoSubscriptionCreationOverride struct

+ AllowAutoSubscriptionCreation bool

+ func NewAutoSubscriptionCreationOverride() *AutoSubscriptionCreationOverride

type DelayedDeliveryData

+ MaxDelayInMillis int64

+ func NewDelayedDeliveryData(tickTime float64, active bool) *DelayedDeliveryData

+ func NewDelayedDeliveryDataWithMaxDelay(tickTime float64, active bool, maxDelayMs int64) *DelayedDeliveryData

+ type OffloadPolicies struct

+ ManagedLedgerOffloadAutoTriggerSizeThresholdBytes int64

+ ManagedLedgerOffloadDeletionLagInMillis int64

+ ManagedLedgerOffloadDriver string

+ ManagedLedgerOffloadDriverMetadata map[string]string

+ ManagedLedgerOffloadMaxThreads int

+ ManagedLedgerOffloadThresholdInBytes int64

+ OffloadersDirectory string

+ S3ManagedLedgerOffloadBucket string

+ S3ManagedLedgerOffloadCredentialID string

+ S3ManagedLedgerOffloadCredentialSecret string

+ S3ManagedLedgerOffloadRegion string

+ S3ManagedLedgerOffloadRole string

+ S3ManagedLedgerOffloadRoleSessionName string

+ S3ManagedLedgerOffloadServiceEndpoint string

+ func NewOffloadPolicies() *OffloadPolicies

type Policies

+ SchemaAutoUpdateCompatibilityStrategy SchemaAutoUpdateCompatibilityStrategy

+ type SchemaAutoUpdateCompatibilityStrategy string

+ func (s SchemaAutoUpdateCompatibilityStrategy) String() string

type SchemaCompatibilityStrategy

+ const SchemaCompatibilityStrategyAlwaysCompatible

+ const SchemaCompatibilityStrategyAlwaysIncompatible

+ const SchemaCompatibilityStrategyBackward

+ const SchemaCompatibilityStrategyBackwardTransitive

+ const SchemaCompatibilityStrategyForward

+ const SchemaCompatibilityStrategyForwardTransitive

+ const SchemaCompatibilityStrategyFull

+ const SchemaCompatibilityStrategyFullTransitive

+ const SchemaCompatibilityStrategyUndefined

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

v0.16.0-candidate-1

Jul 28, 2025

v0.15.1

May 15, 2025

v0.15.1-candidate-2

May 15, 2025

v0.15.1-candidate-1

May 15, 2025

v0.15.0

Mar 17, 2025

Changes in this version

+ const ProduceModeExclusive

+ const ProduceModeExclusiveWithFencing

+ const ProduceModeShared

+ const ProduceModeWaitForExclusive

type ConsumerStats

+ Address string

+ AvgMessagesPerEntry int

+ BytesOutCounter int64

+ ChunkedMessageRate float64

+ ClientVersion string

+ ConnectedSince string

+ LastAckedTimestamp int64

+ LastConsumedFlowTimestamp int64

+ LastConsumedTimestamp int64

+ MessageAckRate float64

+ MsgOutCounter int64

+ type GetAllSchemasResponse struct

+ Schemas []GetSchemaResponse

type NamespacesData

+ ClusterIDs string

+ type ProducerAccessMode string

type PublisherStats

+ AccessModel ProducerAccessMode

+ Address string

+ ChunkedMessageRate float64

+ ClientVersion string

+ ConnectedSince string

+ IsSupportsPartialProducer bool

+ ProducerName string

type SchemaInfoWithVersion

+ func ConvertGetAllSchemasResponseToSchemaInfosWithVersion(tn *TopicName, response GetAllSchemasResponse) []*SchemaInfoWithVersion

type SubscriptionStats

+ AllowOutOfOrderDelivery bool

+ BacklogSize int64

+ BytesOutCounter int64

+ ChunkedMessageRate float64

+ ConsumersAfterMarkDeletePosition map[string]string

+ DelayedMessageIndexSizeInBytes int64

+ EarliestMsgPublishTimeInBacklog int64

+ FilterAcceptedMsgCount int64

+ FilterProcessedMsgCount int64

+ FilterRejectedMsgCount int64

+ FilterRescheduledMsgCount int64

+ IsDurable bool

+ LastExpireTimestamp int64

+ LastMarkDeleteAdvancedTimestamp int64

+ MessageAckRate float64

+ MsgOutCounter int64

+ NonContiguousDeletedMessagesRanges int

+ NonContiguousDeletedMessagesRangesSrzSize int

+ SubscriptionProperties map[string]string

+ TotalMsgExpired int64

v0.15.0-candidate-2

Mar 17, 2025

v0.15.0-candidate-1

Jan 3, 2025

v0.14.0

Sep 23, 2024

Changes in this version

type MessageID

+ func ParseMessageIDWithPartitionIndex(str string, index int) (*MessageID, error)

type TopicName

+ func (t *TopicName) GetPartitionIndex() int

v0.14.0-candidate-1

Sep 23, 2024

v0.13.1

Jul 31, 2024

v0.13.1-candidate-1

Jul 31, 2024

v0.13.0

Jul 15, 2024

Changes in this version

+ func ConvertSchemaDataToStringLegacy(schemaInfo SchemaInfo) string

+ type BrokerInfo struct

+ BrokerID string

+ ServiceURL string

type FunctionData

+ RuntimeFlags string

+ type GetStatsOptions struct

+ ExcludeConsumers bool

+ ExcludePublishers bool

+ GetEarliestTimeInBacklog bool

+ GetPreciseBacklog bool

+ SubscriptionBacklogSize bool

+ type IsCompatibility struct

+ IsCompatibility bool

+ SchemaCompatibilityStrategy SchemaCompatibilityStrategy

type PostSchemaPayload

+ func ConvertSchemaInfoToPostSchemaPayload(schemaInfo SchemaInfo) PostSchemaPayload

type SinkData

+ RuntimeFlags string

type SourceData

+ RuntimeFlags string

+ type TopicVersion string

+ const TopicVersionV1

+ const TopicVersionV2

+ func (t TopicVersion) String() string

v0.13.0-candidate-2

Jul 15, 2024

v0.13.0-candidate-1

Jul 11, 2024

v0.12.1

Feb 29, 2024

v0.12.1-candidate-1

Feb 29, 2024

v0.12.0

Jan 22, 2024

Changes in this version

+ const BatchsourceClassnameKey

+ const BatchsourceConfigKey

+ const DEFAULTNAMESPACE

+ const FirstBoundary

+ const GoRuntime

+ const JavaRuntime

+ const LastBoundary

+ const PARTITIONEDTOPICSUFFIX

+ const PUBLICTENANT

+ const PythonRuntime

+ const WindowConfigKey

+ var Earliest = MessageID

+ var Latest = MessageID

+ func CheckName(name string) bool

+ func GetConfigPath() string

+ func HomeDir() string

+ func IsNilFixed(i interface{}) bool

+ func MakeHTTPPath(apiVersion string, componentPath 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

+ LimitSize int64

+ LimitTime int64

+ Policy RetentionPolicy

+ func NewBacklogQuota(limitSize int64, limitTime int64, policy RetentionPolicy) BacklogQuota

+ type BacklogQuotaType string

+ const DestinationStorage

+ const MessageAge

+ func ParseBacklogQuotaType(str string) (BacklogQuotaType, error)

+ func (b BacklogQuotaType) String() string

+ type BatchSourceConfig struct

+ DiscoveryTriggererClassName string

+ DiscoveryTriggererConfig map[string]interface{}

+ 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 BrokerStatsData struct

+ Indent bool

+ type BundlesData struct

+ Boundaries []string

+ NumBundles int

+ func NewBundlesData(boundaries []string) BundlesData

+ func NewBundlesDataWithNumBundles(numBundles int) *BundlesData

+ func NewDefaultBoundle() *BundlesData

+ type ClusterData struct

+ AuthenticationParameters string

+ AuthenticationPlugin string

+ BrokerClientTLSEnabled bool

+ BrokerClientTrustCertsFilePath string

+ BrokerServiceURL string

+ BrokerServiceURLTls string

+ Name string

+ PeerClusterNames []string

+ ServiceURL string

+ ServiceURLTls string

+ type CompactedLedger struct

+ Entries int64

+ LedgerID int64

+ Offloaded bool

+ Size int64

+ UnderReplicated bool

+ type ConnectorDefinition struct

+ Description string

+ Name string

+ SinkClass string

+ SourceClass string

+ type ConsumerConfig struct

+ ConsumerProperties map[string]string

+ CryptoConfig *CryptoConfig

+ PoolMessages bool

+ ReceiverQueueSize int

+ RegexPattern bool

+ SchemaProperties map[string]string

+ 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 CryptoConfig struct

+ ConsumerCryptoFailureAction string

+ CryptoKeyReaderClassName string

+ CryptoKeyReaderConfig map[string]interface{}

+ EncryptionKeys []string

+ ProducerCryptoFailureAction string

+ 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 DelayedDeliveryCmdData struct

+ DelayedDeliveryTimeStr string

+ Disable bool

+ Enable bool

+ type DelayedDeliveryData struct

+ Active bool

+ TickTime float64

+ type DispatchRate struct

+ DispatchThrottlingRateInByte int64

+ DispatchThrottlingRateInMsg int

+ RatePeriodInSecond int

+ func NewDispatchRate() *DispatchRate

+ type DispatchRateData struct

+ DispatchThrottlingRateInByte int64

+ DispatchThrottlingRateInMsg int64

+ RatePeriodInSecond int64

+ RelativeToPublishRate bool

+ 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

+ BatchBuilder string

+ ClassName string

+ CleanupSubscription bool

+ CustomRuntimeOptions string

+ CustomSchemaInputs map[string]string

+ CustomSchemaOutputs map[string]string

+ CustomSerdeInputs map[string]string

+ DeadLetterTopic string

+ ExposePulsarAdminClientEnabled bool

+ FQFN string

+ ForwardSourceMessageProperty bool

+ FunctionType *string

+ Go *string

+ InputSpecs map[string]ConsumerConfig

+ InputTypeClassName string

+ Inputs []string

+ Jar *string

+ LogTopic string

+ MaxMessageRetries *int

+ MaxPendingAsyncRequests int

+ Name string

+ Namespace string

+ Output string

+ OutputSchemaType string

+ OutputSerdeClassName string

+ OutputTypeClassName string

+ Parallelism int

+ ProcessingGuarantees string

+ ProducerConfig *ProducerConfig

+ Py *string

+ Resources *Resources

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ Runtime string

+ RuntimeFlags string

+ Secrets map[string]interface{}

+ SkipToLatest bool

+ SubName string

+ SubscriptionPosition string

+ Tenant string

+ TimeoutMs *int64

+ TopicsPattern *string

+ UserConfig map[string]interface{}

+ WindowConfig *WindowConfig

+ type FunctionData struct

+ AutoAck bool

+ BatchBuilder string

+ CPU float64

+ ClassName string

+ CleanupSubscription bool

+ CustomRuntimeOptions string

+ CustomSchemaInput string

+ CustomSchemaOutput string

+ CustomSerDeInputs string

+ DeadLetterTopic string

+ DestinationFile string

+ Disk int64

+ FQFN string

+ ForwardSourceMessageProperty bool

+ FuncConf *FunctionConfig

+ FuncName string

+ FunctionConfigFile string

+ FunctionType string

+ Go string

+ InputSpecs string

+ InputTypeClassName string

+ Inputs string

+ InstanceID string

+ Jar string

+ Key string

+ LogTopic string

+ MaxMessageRetries int

+ Namespace string

+ Output string

+ OutputSerDeClassName string

+ OutputTypeClassName string

+ Parallelism int

+ Path string

+ ProcessingGuarantees string

+ ProducerConfig string

+ Py string

+ RAM int64

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ SchemaType string

+ Secrets string

+ SkipToLatest bool

+ SlidingIntervalCount int

+ SlidingIntervalDurationMs int64

+ State string

+ SubsName string

+ SubsPosition 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 GetSchemaResponse struct

+ Data string

+ Properties map[string]string

+ Timestamp int64

+ Type string

+ Version int64

+ type InactiveTopicDeleteMode string

+ const DeleteWhenNoSubscriptions

+ const DeleteWhenSubscriptionsCaughtUp

+ func ParseInactiveTopicDeleteMode(str string) (InactiveTopicDeleteMode, error)

+ func (i InactiveTopicDeleteMode) String() string

+ type InactiveTopicPolicies struct

+ DeleteWhileInactive bool

+ InactiveTopicDeleteMode *InactiveTopicDeleteMode

+ MaxInactiveDurationSeconds int

+ func NewInactiveTopicPolicies(inactiveTopicDeleteMode *InactiveTopicDeleteMode, ...) InactiveTopicPolicies

+ 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

+ MetaData string

+ Offloaded bool

+ Size int64

+ Timestamp int64

+ UnderReplicated bool

+ 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 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 []ManagedLedgerInfoLedgerInfo

+ ModificationData string

+ TerminatedPosition PositionInfo

+ Version int

+ type ManagedLedgerInfoLedgerInfo struct

+ Entries int64

+ LedgerID int64

+ Offloaded bool

+ OffloadedContextUUID string

+ Size int64

+ Timestamp int64

+ type Message struct

+ MessageID MessageID

+ Payload []byte

+ Properties map[string]string

+ Topic string

+ 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

+ PartitionIndex 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 NamespacesData struct

+ AntiAffinityGroup string

+ BacklogQuotaType string

+ BookkeeperAckQuorum int

+ BookkeeperEnsemble int

+ BookkeeperWriteQuorum int

+ Bundle string

+ Cluster string

+ ClusterIds string

+ Clusters []string

+ Enable bool

+ LimitStr string

+ LimitTime int64

+ 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 OffloadProcessStatus struct

+ FirstUnOffloadedMessage MessageID

+ LastError string

+ Status Status

+ type PackageMetadata struct

+ Contact string

+ CreateTime int64

+ Description string

+ ModificationTime int64

+ Properties map[string]string

+ type PackageName struct

+ func GetPackageName(completeName string) (*PackageName, error)

+ func GetPackageNameWithComponents(packageType PackageType, tenant, namespace, name, version string) (*PackageName, error)

+ func (p *PackageName) GetCompleteName() string

+ func (p *PackageName) GetName() string

+ func (p *PackageName) GetNamespace() string

+ func (p *PackageName) GetTenant() string

+ func (p *PackageName) GetType() PackageType

+ func (p *PackageName) GetVersion() string

+ func (p *PackageName) String() string

+ type PackageType string

+ const PackageTypeFunction

+ const PackageTypeSink

+ const PackageTypeSource

+ func (p PackageType) String() 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 PersistenceData struct

+ BookkeeperAckQuorum int64

+ BookkeeperEnsemble int64

+ BookkeeperWriteQuorum int64

+ ManagedLedgerMaxMarkDeleteRate float64

+ type PersistencePolicies struct

+ BookkeeperAckQuorum int

+ BookkeeperEnsemble int

+ BookkeeperWriteQuorum int

+ ManagedLedgerMaxMarkDeleteRate float64

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

+ type PersistentTopicInternalStats struct

+ CompactedLedger CompactedLedger

+ CurrentLedgerEntries int64

+ CurrentLedgerSize int64

+ Cursors map[string]CursorStats

+ EntriesAddedCounter int64

+ LastConfirmedEntry string

+ LastLedgerCreatedTimestamp string

+ LastLedgerCreationFailureTimestamp string

+ Ledgers []LedgerInfo

+ NumberOfEntries int64

+ PendingAddEntriesCount int

+ SchemaLedgers []SchemaLedger

+ 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

+ IsAllowAutoUpdateSchema *bool

+ LatencyStatsSampleRate map[string]int

+ MaxConsumersPerSubscription *int

+ MaxConsumersPerTopic *int

+ MaxProducersPerTopic *int

+ MessageTTLInSeconds *int

+ OffloadDeletionLagMs *int64

+ OffloadThreshold int64

+ Persistence *PersistencePolicies

+ PublishMaxMessageRate map[string]PublishRate

+ ReplicationClusters []string

+ ReplicatorDispatchRate map[string]DispatchRate

+ RetentionPolicies *RetentionPolicies

+ SchemaCompatibilityStrategy SchemaCompatibilityStrategy

+ SchemaValidationEnforced bool

+ SubscriptionAuthMode SubscriptionAuthMode

+ SubscriptionDispatchRate map[string]DispatchRate

+ TopicAutoCreationConfig *TopicAutoCreationConfig

+ 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 ProducerConfig struct

+ BatchBuilder string

+ CompressionType string

+ CryptoConfig *CryptoConfig

+ MaxPendingMessages int

+ MaxPendingMessagesAcrossPartitions int

+ UseThreadLocalProducers bool

+ type PublishRate struct

+ PublishThrottlingRateInByte int64

+ PublishThrottlingRateInMsg int

+ func NewPublishRate() *PublishRate

+ type PublishRateData struct

+ PublishThrottlingRateInByte int64

+ PublishThrottlingRateInMsg int64

+ 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 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

+ func ParseRetentionPolicy(str string) (RetentionPolicy, error)

+ func (s RetentionPolicy) String() string

+ 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

+ func ConvertGetSchemaResponseToSchemaInfo(tn *TopicName, response GetSchemaResponse) *SchemaInfo

+ type SchemaInfoWithVersion struct

+ SchemaInfo *SchemaInfo

+ Version int64

+ func ConvertGetSchemaResponseToSchemaInfoWithVersion(tn *TopicName, response GetSchemaResponse) *SchemaInfoWithVersion

+ type SchemaLedger struct

+ Entries int64

+ IsOffloaded bool

+ LedgerID int64

+ Size int64

+ Timestamp 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{}

+ CustomRuntimeOptions string

+ DeadLetterTopic string

+ InputSpecs map[string]ConsumerConfig

+ Inputs []string

+ MaxMessageRetries int

+ Name string

+ Namespace string

+ NegativeAckRedeliveryDelayMs int64

+ Parallelism int

+ ProcessingGuarantees string

+ Resources *Resources

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ RuntimeFlags string

+ Secrets map[string]interface{}

+ SinkType string

+ SourceSubscriptionName string

+ SourceSubscriptionPosition string

+ Tenant string

+ TimeoutMs *int64

+ TopicToSchemaProperties map[string]string

+ TopicToSchemaType map[string]string

+ TopicToSerdeClassName map[string]string

+ TopicsPattern *string

+ TransformFunction string

+ TransformFunctionClassName string

+ TransformFunctionConfig string

+ type SinkData struct

+ Archive string

+ AutoAck bool

+ CPU float64

+ ClassName string

+ CleanupSubscription bool

+ CustomRuntimeOptions string

+ CustomSchemaInputString string

+ CustomSerdeInputString string

+ DeadLetterTopic string

+ Disk int64

+ InputSpecs string

+ Inputs string

+ InstanceID string

+ MaxMessageRetries int

+ Name string

+ Namespace string

+ NegativeAckRedeliveryDelayMs int64

+ Parallelism int

+ ProcessingGuarantees string

+ RAM int64

+ RetainKeyOrdering bool

+ RetainOrdering bool

+ Secrets string

+ SinkConf *SinkConfig

+ SinkConfigFile string

+ SinkConfigString string

+ SinkType string

+ SubsName string

+ SubsPosition string

+ Tenant string

+ TimeoutMs int64

+ TopicsPattern string

+ TransformFunction string

+ TransformFunctionClassName string

+ TransformFunctionConfig 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 SourceConfig struct

+ Archive string

+ BatchBuilder string

+ BatchSourceConfig *BatchSourceConfig

+ ClassName string

+ Configs map[string]interface{}

+ CustomRuntimeOptions string

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ ProducerConfig *ProducerConfig

+ Resources *Resources

+ RuntimeFlags string

+ SchemaType string

+ Secrets map[string]interface{}

+ SerdeClassName string

+ Tenant string

+ TopicName string

+ type SourceData struct

+ Archive string

+ BatchBuilder string

+ BatchSourceConfigString string

+ CPU float64

+ ClassName string

+ CustomRuntimeOptions string

+ DeserializationClassName string

+ DestinationTopicName string

+ Disk int64

+ InstanceID string

+ Name string

+ Namespace string

+ Parallelism int

+ ProcessingGuarantees string

+ ProducerConfig string

+ RAM int64

+ SchemaType string

+ Secrets 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 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

+ LastAckedTimestamp int64

+ LastConsumedFlowTimestamp int64

+ LastConsumedTimestamp int64

+ MsgBacklog int64

+ MsgBacklogNoDelayed int64

+ MsgDelayed int64

+ MsgRateExpired float64

+ MsgRateOut float64

+ MsgRateRedeliver float64

+ MsgThroughputOut float64

+ SubType string

+ UnAckedMessages int64

+ type TenantData struct

+ AdminRoles []string

+ AllowedClusters []string

+ Name string

+ type TopicAutoCreationConfig struct

+ Allow bool

+ Partitions *int

+ Type TopicType

+ 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) GetNamespace() string

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

+ func (t *TopicName) GetRestPath() string

+ func (t *TopicName) GetTenant() string

+ func (t *TopicName) IsPersistent() bool

+ func (t *TopicName) String() string

+ type TopicStats struct

+ AverageMsgSize float64

+ BacklogSize int64

+ DeDuplicationStatus string

+ MsgCounterIn int64

+ MsgCounterOut int64

+ 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 TopicType string

+ const NonPartitioned

+ const Partitioned

+ func ParseTopicType(topicType string) (TopicType, error)

+ func (t TopicType) String() string

+ type UpdateOptions struct

+ UpdateAuthData bool

+ func NewUpdateOptions() *UpdateOptions

+ type WindowConfig struct

+ ActualWindowFunctionClassName *string

+ LateDataTopic *string

+ MaxLagMs *int64

+ ProcessingGuarantees *string

+ 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

v0.12.0-candidate-3

Jan 22, 2024

v0.12.0-candidate-2

Jan 15, 2024

v0.12.0-candidate-1

Jan 10, 2024

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