padmin

type AllBookiesResp struct {
	Bookies []RawBookieInfo `json:"bookies"`
}

type BacklogQuota struct {
	Limit     int64
	LimitSize int64
	LimitTime int64
	Policy    RetentionPolicy
}

type BacklogQuotaResp struct {
	DestinationStorage BacklogQuota `json:"destination_storage,omitempty"`
	MessageAge         BacklogQuota `json:"message_age,omitempty"`
}

type BacklogQuotaType string

type BookieInfo struct {
	Rack     string `json:"rack"`
	Hostname string `json:"hostname"`
}

type Bookies interface {
	// AllBookies Gets raw information for all the bookies in the cluster
	AllBookies() (*AllBookiesResp, error)
	// ListRacksInfo Gets the rack placement information for all the bookies in the cluster
	ListRacksInfo() (*ListRacksInfoResp, error)
	// RemoveRacksInfo Removed the rack placement information for a specific bookie in the cluster
	RemoveRacksInfo(string) error
	// GetRacksInfo Gets the rack placement information for a specific bookie in the cluster
	GetRacksInfo(string) (*BookieInfo, error)
	// UpdateRacksInfo Updates the rack placement information for a specific bookie in the cluster
	// (note. bookie address format:`address:port`)
	UpdateRacksInfo(string, *BookieInfo) error
}

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

type Clusters interface {
	List() ([]string, error)
}

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

type Compaction struct {
	LastCompactionRemovedEventCount   uint64 `json:"lastCompactionRemovedEventCount,omitempty"`
	LastCompactionSucceedTimestamp    uint64 `json:"lastCompactionSucceedTimestamp,omitempty"`
	LastCompactionFailedTimestamp     uint64 `json:"lastCompactionFailedTimestamp,omitempty"`
	LastCompactionDurationTimeInMills uint64 `json:"lastCompactionDurationTimeInMills,omitempty"`
}

type CompactionStatus string

type Config struct {

	// Host pulsar service address, default localhost
	Host string
	// Port pulsar service port, default 8080
	Port int
	// TlsEnable enable tls, default false
	TlsEnable bool
	// TlsConfig tls config
	TlsConfig *tls.Config
	// ConnectionTimeout connect timeout, default 0, zero means no timeout
	ConnectionTimeout int64
	// contains filtered or unexported fields
}

type CursorDetail struct {
	CursorBacklog  int64
	CursorLedgerId int64
}

type CursorStats struct {
	MarkDeletePosition                       string           `json:"markDeletePosition"`
	ReadPosition                             string           `json:"readPosition"`
	WaitingReadOp                            bool             `json:"waitingReadOp"`
	PendingReadOps                           int              `json:"pendingReadOps"`
	MessagesConsumedCounter                  int64            `json:"messagesConsumedCounter"`
	CursorLedger                             int64            `json:"cursorLedger"`
	CursorLedgerLastEntry                    int64            `json:"cursorLedgerLastEntry"`
	IndividuallyDeletedMessages              string           `json:"individuallyDeletedMessages"`
	LastLedgerSwitchTimestamp                string           `json:"lastLedgerSwitchTimestamp"`
	State                                    string           `json:"state"`
	Active                                   bool             `json:"active"`
	NumberOfEntriesSinceFirstNotAckedMessage int64            `json:"numberOfEntriesSinceFirstNotAckedMessage"`
	TotalNonContiguousDeletedMessagesRange   int              `json:"totalNonContiguousDeletedMessagesRange"`
	SubscriptionHavePendingRead              bool             `json:"subscriptionHavePendingRead"`
	SubscriptionHavePendingReplayRead        bool             `json:"subscriptionHavePendingReplayRead"`
	Properties                               map[string]int64 `json:"properties"`
}

type HttpClient interface {
	Get(path string) (*http.Response, error)
	Put(path string, body any) (*http.Response, error)
	Post(path string, body any) (*http.Response, error)
	Delete(path string) (*http.Response, error)
	Do(*http.Request) (*http.Response, error)
}

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

type LedgerDetail struct {
	Entries   int64
	Timestamp int64
	Size      int64
	LedgerId  int64
}

type LedgerInfo struct {
	LedgerId        int64  `json:"ledgerId"`
	Entries         int64  `json:"entries"`
	Size            int64  `json:"size"`
	Offloaded       bool   `json:"offloaded"`
	Metadata        string `json:"metadata"`
	UnderReplicated bool   `json:"underReplicated"`
}

type ListRacksInfoResp map[string]map[string]BookieInfo

type LongRunningProcessStatus struct {
	Status    CompactionStatus `json:"status"`
	LastError string           `json:"lastError"`
}

type Lookup interface {
	// GetOwner get the owner broker of the given topic.
	// topicDomain: ref TopicDomain type, value persistent or non-persistent
	GetOwner(topicDomain TopicDomain, tenant, namespace, topic string) (*LookupData, error)
	// GetNamespaceBundle get the namespace bundle which the given topic belongs to.
	GetNamespaceBundle(topicDomain TopicDomain, tenant, namespace, topic string) (string, error)
}

type LookupData struct {
	BrokerUrl    string `json:"brokerUrl"`
	BrokerUrlTls string `json:"brokerUrlTls"`
	HttpUrl      string `json:"httpUrl"`    // web service http address
	HttpUrlTls   string `json:"httpUrlTls"` // web service https address
	NativeUrl    string `json:"nativeUrl"`
}

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

type MessageId struct {
	LedgerId       int64 `json:"ledgerId"`
	EntryId        int64 `json:"entryId"`
	PartitionIndex int32 `json:"partitionIndex"`
	BatchIndex     int32 `json:"batchIndex"`
}

type NamespaceBacklog interface {
	// GetNamespaceBacklogQuota Get backlog quota map on a namespace.
	GetNamespaceBacklogQuota(tenant, namespace string) (*BacklogQuotaResp, error)
	// SetNamespaceBacklogQuota  Set a backlog quota for all the topics on a namespace.
	SetNamespaceBacklogQuota(tenant, namespace string, cfg *BacklogQuota) error
	// RemoveNamespaceBacklogQuota Remove a backlog quota policy from a namespace.
	RemoveNamespaceBacklogQuota(tenant, namespace string, opts ...Option) error
	//ClearNamespaceAllTopicsBacklog Clear backlog for all topics on a namespace.
	ClearNamespaceAllTopicsBacklog(tenant, namespace string) error
	// ClearNamespaceSubscriptionBacklog Clear backlog for a given subscription on all topics on a namespace.
	ClearNamespaceSubscriptionBacklog(tenant, namespace, subscription string) error
	// ClearNamespaceAllTopicsBacklogForBundle Clear backlog for all topics on a namespace bundle.
	ClearNamespaceAllTopicsBacklogForBundle(tenant, namespace, bundle string) error
	// ClearNamespaceSubscriptionBacklogForBundle Clear backlog for a given subscription on all topics on a namespace bundle.
	ClearNamespaceSubscriptionBacklogForBundle(tenant, namespace, subscription, bundle string) error
}

type NamespaceCompaction interface {
	// GetMaximumUnCompactedBytes Delete maximum number of uncompacted bytes in a topic before compaction is triggered.
	GetMaximumUnCompactedBytes(tenant, namespace string) (int64, error)
	// SetMaximumUnCompactedBytes Set maximum number of uncompacted bytes in a topic before compaction is triggered.
	SetMaximumUnCompactedBytes(tenant, namespace string, threshold int64) error
	// RemoveMaximumUnCompactedBytes Delete maximum number of uncompacted bytes in a topic before compaction is triggered.
	RemoveMaximumUnCompactedBytes(tenant, namespace string) error
}

type NamespaceMessageTTL interface {
	// GetNamespaceMessageTTL Get the message TTL for the namespace
	GetNamespaceMessageTTL(tenant, namespace string) (int64, error)
	// SetNamespaceMessageTTL Set the message TTL for the namespace
	SetNamespaceMessageTTL(tenant, namespace string, seconds int64) error
	// RemoveNamespaceMessageTTL Remove the message TTL for the namespace
	RemoveNamespaceMessageTTL(tenant, namespace string) error
}

type NamespaceRetention interface {
	// GetNamespaceRetention get retention configuration for namespace.
	GetNamespaceRetention(tenant, namespace string) (*RetentionConfiguration, error)
	// SetNamespaceRetention set retention configuration for namespace.
	SetNamespaceRetention(tenant, namespace string, cfg *RetentionConfiguration) error
	// RemoveNamespaceRetention remove retention configuration for namespace.
	RemoveNamespaceRetention(tenant, namespace string) error
}

type Namespaces interface {
	Create(tenant, namespace string) error
	Delete(tenant, namespace string) error
	List(tenant string) ([]string, error)
	NamespaceRetention
	NamespaceBacklog
	NamespaceMessageTTL
	NamespaceCompaction
}

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

type NonPersistentTopics interface {
	WithOptions(opts ...Option) NonPersistentTopics
	Topics
	TopicBacklog
	TopicMessageTTL
	TopicCompaction
	TopicStats
}

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

type OfflineTopicStats struct {
	StorageSize       int64
	TotalMessages     int64
	MessageBacklog    int64
	BrokerName        string
	TopicName         string
	DataLedgerDetails []LedgerDetail
	CursorDetails     map[string]CursorDetail
	StatGeneratedAt   time.Time
}

type Option func(*options)

type PartitionedMetadata struct {
	Deleted    bool  `json:"deleted"`
	Partitions int64 `json:"partitions"`
}

type PartitionedTopicInternalStats struct {
	Metadata   PartitionedMetadata            `json:"metadata"`
	Partitions map[string]*TopicInternalStats `json:"partitions"`
}

type PartitionedTopicMetadata struct {
	Partitions int32             `json:"partitions"`
	Properties map[string]string `json:"properties"`
}

type PersistentTopics interface {
	WithOptions(opts ...Option) PersistentTopics
	Topics
	TopicBacklog
	TopicMessageTTL
	TopicCompaction
	TopicStats
}

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

type PulsarAdmin struct {
	Clusters            Clusters
	Tenants             Tenants
	Namespaces          Namespaces
	PersistentTopics    PersistentTopics
	NonPersistentTopics NonPersistentTopics
	Bookies             Bookies
	Lookup              Lookup
}

type RawBookieInfo struct {
	BookieId string `json:"bookieId"`
}

type RetentionConfiguration struct {
	RetentionSizeInMB      int64 `json:"retentionSizeInMB"`
	RetentionTimeInMinutes int64 `json:"retentionTimeInMinutes"`
}

type RetentionPolicy string

type SubscriptionStats struct {
	LastConsumedFlowTimestamp uint64 `json:"lastConsumedFlowTimestamp,omitempty"`
	MsgBacklog                int    `json:"msgBacklog"`
}

type TenantInfo struct {
	AdminRoles      []string `json:"adminRoles,omitempty"`
	AllowedClusters []string `json:"allowedClusters,omitempty"`
}

type Tenants interface {
	Create(tenantName string, info TenantInfo) error
	Delete(tenantName string) error
	List() ([]string, error)
}

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

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

type TopicBacklog interface {
	// GetTopicBacklogQuota Get backlog quota map on a topic.
	GetTopicBacklogQuota(tenant, namespace, topic string) (*BacklogQuotaResp, error)
	// SetTopicBacklogQuota Set a backlog quota for a topic.
	SetTopicBacklogQuota(tenant, namespace, topic string, cfg *BacklogQuota) error
	// RemoveTopicBacklogQuota Remove a backlog quota policy from a topic.
	RemoveTopicBacklogQuota(tenant, namespace, topic string, opts ...Option) error
	// EstimatedOfflineTopicBacklog Get estimated backlog for offline topic.
	EstimatedOfflineTopicBacklog(tenant, namespace, topic string) (*OfflineTopicStats, error)
	// CalculateBacklogSizeByMessageID Calculate backlog size by a message ID (in bytes).
	CalculateBacklogSizeByMessageID(tenant, namespace, topic string) error
}

type TopicCompaction interface {
	// GetTopicCompactionThreshold Get compaction threshold configuration for specified topic.
	GetTopicCompactionThreshold(tenant, namespace, topic string) (int64, error)
	// SetTopicCompactionThreshold Set compaction threshold configuration for specified topic.
	SetTopicCompactionThreshold(tenant, namespace, topic string, threshold int64) error
	// RemoveTopicCompactionThreshold Remove compaction threshold configuration for specified topic.
	RemoveTopicCompactionThreshold(tenant, namespace, topic string) error
	// GetTopicCompactionStatus Get the status of a compaction operation for a topic.
	GetTopicCompactionStatus(tenant, namespace, topic string) (*LongRunningProcessStatus, error)
	// TriggerTopicCompaction Trigger a compaction operation on a topic.
	TriggerTopicCompaction(tenant, namespace, topic string) error
}

type TopicDomain string

type TopicInternalStats struct {
	EntriesAddedCounter                int64                  `json:"entriesAddedCounter"`
	NumberOfEntries                    int64                  `json:"numberOfEntries"`
	TotalSize                          int64                  `json:"totalSize"`
	CurrentLedgerEntries               int64                  `json:"currentLedgerEntries"`
	CurrentLedgerSize                  int64                  `json:"currentLedgerSize"`
	LastLedgerCreatedTimestamp         string                 `json:"lastLedgerCreatedTimestamp"`
	LastLedgerCreationFailureTimestamp string                 `json:"lastLedgerCreationFailureTimestamp"`
	WaitingCursorsCount                int32                  `json:"waitingCursorsCount"`
	PendingAddEntriesCount             int32                  `json:"pendingAddEntriesCount"`
	LastConfirmedEntry                 string                 `json:"lastConfirmedEntry"`
	State                              string                 `json:"state"`
	Ledgers                            []*LedgerInfo          `json:"ledgers"`
	Cursors                            map[string]CursorStats `json:"cursors"`
	SchemaLedgers                      []*LedgerInfo          `json:"schemaLedgers"`
	CompactedLedger                    *LedgerInfo            `json:"compactedLedger"`
}

type TopicMessageTTL interface {
	// GetTopicMessageTTL Get the message TTL for the topic
	GetTopicMessageTTL(tenant, namespace, topic string) (int64, error)
	// SetTopicMessageTTL Set the message TTL for the topic
	SetTopicMessageTTL(tenant, namespace, topic string, seconds int64) error
	// RemoveTopicMessageTTL Remove the message TTL for the topic
	RemoveTopicMessageTTL(tenant, namespace, topic string) error
}

type TopicRetention interface {
	// GetTopicRetention get retention configuration for namespace.
	GetTopicRetention(tenant, namespace, topic string) (*RetentionConfiguration, error)
	// SetTopicRetention set retention configuration for namespace.
	SetTopicRetention(tenant, namespace, topic string, cfg *RetentionConfiguration) error
	// RemoveTopicRetention remove retention configuration for namespace.
	RemoveTopicRetention(tenant, namespace, topic string) error
}

type TopicStatistics struct {
	MsgRateIn                                        float64                      `json:"msgRateIn,omitempty"`
	MsgThroughputIn                                  float64                      `json:"msgThroughputIn,omitempty"`
	MsgRateOut                                       float64                      `json:"msgRateOut,omitempty"`
	MsgThroughputOut                                 float64                      `json:"msgThroughputOut,omitempty"`
	BytesInCounter                                   uint64                       `json:"bytesInCounter,omitempty"`
	MsgInCounter                                     uint64                       `json:"msgInCounter,omitempty"`
	BytesOutCounter                                  uint64                       `json:"bytesOutCounter,omitempty"`
	MsgOutCounter                                    uint64                       `json:"msgOutCounter,omitempty"`
	AverageMsgSize                                   float64                      `json:"averageMsgSize,omitempty"`
	MsgChunkPublished                                bool                         `json:"msgChunkPublished,omitempty"`
	StorageSize                                      uint64                       `json:"storageSize,omitempty"`
	BacklogSize                                      uint64                       `json:"backlogSize,omitempty"`
	PublishRateLimitedTimes                          uint64                       `json:"publishRateLimitedTimes,omitempty"`
	EarliestMsgPublishTimeInBacklogs                 uint64                       `json:"earliestMsgPublishTimeInBacklogs,omitempty"`
	OffloadedStorageSize                             uint64                       `json:"offloadedStorageSize,omitempty"`
	LastOffloadLedgerId                              uint64                       `json:"lastOffloadLedgerId,omitempty"`
	LastOffloadSuccessTimeStamp                      uint64                       `json:"lastOffloadSuccessTimeStamp,omitempty"`
	LastOffloadFailureTimeStamp                      uint64                       `json:"lastOffloadFailureTimeStamp,omitempty"`
	OngoingTxnCount                                  uint64                       `json:"ongoingTxnCount,omitempty"`
	AbortedTxnCount                                  uint64                       `json:"abortedTxnCount,omitempty"`
	CommittedTxnCount                                uint64                       `json:"committedTxnCount,omitempty"`
	Publishers                                       []string                     `json:"publishers,omitempty"`
	WaitingPublishers                                uint64                       `json:"waitingPublishers,omitempty"`
	Subscriptions                                    map[string]SubscriptionStats `json:"subscriptions,omitempty"`
	Replication                                      map[string]string            `json:"replication,omitempty"`
	DeduplicationStatus                              string                       `json:"deduplicationStatus,omitempty"`
	NonContiguousDeletedMessagesRanges               uint64                       `json:"nonContiguousDeletedMessagesRanges,omitempty"`
	NonContiguousDeletedMessagesRangesSerializedSize uint64                       `json:"nonContiguousDeletedMessagesRangesSerializedSize,omitempty"`
	DelayedMessageIndexSizeInBytes                   uint64                       `json:"delayedMessageIndexSizeInBytes,omitempty"`
	Compaction                                       Compaction                   `json:"compaction"`
	OwnerBroker                                      string                       `json:"ownerBroker,omitempty"`
}

type TopicStats interface {
	GetStats(string, string, string) (*TopicStatistics, error)
	GetPartitionedStats(string, string, string) (*TopicStatistics, error)
	GetStatsInternal(string, string, string) (*TopicInternalStats, error)
	GetPartitionedStatsInternal(string, string, string) (*PartitionedTopicInternalStats, error)
}

type Topics interface {
	CreateNonPartitioned(tenant, namespace, topic string) error
	CreatePartitioned(tenant, namespace, topic string, numPartitions int) error
	DeleteNonPartitioned(tenant, namespace, topic string) error
	DeletePartitioned(tenant, namespace, topic string) error
	ListNonPartitioned(tenant, namespace string) ([]string, error)
	ListPartitioned(tenant, namespace string) ([]string, error)
	ListNamespaceTopics(tenant, namespace string) ([]string, error)
	GetPartitionedMetadata(tenant, namespace, topic string) (*PartitionedMetadata, error)
	CreateMissedPartitions(tenant, namespace, topic string) error
	GetLastMessageId(tenant, namespace, topic string) (*MessageId, error)
	TopicRetention
}