Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var CleanupPolicyCompactDelete = CleanupPolicies{ CleanupPolicyCompact, CleanupPolicyDelete, }
Functions ¶
Types ¶
type CleanupPolicies ¶
type CleanupPolicies []CleanupPolicy
func (CleanupPolicies) String ¶
func (c CleanupPolicies) String() string
type CleanupPolicy ¶
type CleanupPolicy string
const CleanupPolicyCompact CleanupPolicy = "compact"
const CleanupPolicyDelete CleanupPolicy = "delete"
func (CleanupPolicy) String ¶
func (f CleanupPolicy) String() string
type RetentionBytes ¶
type RetentionBytes int64
func (RetentionBytes) Int64 ¶
func (b RetentionBytes) Int64() int64
func (RetentionBytes) String ¶
func (b RetentionBytes) String() string
type RetentionMs ¶
type RetentionMs int64
func (RetentionMs) Int64 ¶
func (b RetentionMs) Int64() int64
func (RetentionMs) String ¶
func (b RetentionMs) String() string
type TopicBuilder ¶
type TopicBuilder interface {
Build(
name libkafka.Topic,
cleanupPolicies CleanupPolicies,
retentionMs RetentionMs,
retentionBytes RetentionBytes,
) v1beta2.KafkaTopic
}
func NewTopicBuilder ¶
func NewTopicBuilder() TopicBuilder
type TopicCreator ¶
type TopicCreator interface {
CreateTopic(
topic kafka.Topic,
cleanupPolicies CleanupPolicies,
retentionMs RetentionMs,
retentionBytes RetentionBytes,
) v1beta2.KafkaTopic
}
func NewTopicCreator ¶
func NewTopicCreator( topicBuilder TopicBuilder, ) TopicCreator
type TopicsProvider ¶
type TopicsProvider interface {
Get(ctx context.Context) (v1beta2.KafkaTopics, error)
}
type TopicsProviderFunc ¶
type TopicsProviderFunc func(ctx context.Context) (v1beta2.KafkaTopics, error)
func (TopicsProviderFunc) Get ¶
func (e TopicsProviderFunc) Get(ctx context.Context) (v1beta2.KafkaTopics, error)
type TopicsProviderList ¶
type TopicsProviderList []TopicsProvider
func (TopicsProviderList) Get ¶
func (e TopicsProviderList) Get(ctx context.Context) (v1beta2.KafkaTopics, error)
Source Files
Click to show internal directories.
Click to hide internal directories.