kafkatopic

Documentation

Index

• Variables
• func NewLoaderContext(ctx context.Context, watcher *watcher.Watcher[*KafkaTopic]) context.Context
• func NewWatcher(ctx context.Context, mgr *watcher.Manager) *watcher.Watcher[*KafkaTopic]
• func Search(ctx context.Context, q string) ([]*search.Result, error)
• type KafkaTopic
  • func Get(ctx context.Context, teamSlug slug.Slug, environment, name string) (*KafkaTopic, error)
  • func GetByIdent(ctx context.Context, id ident.Ident) (*KafkaTopic, error)
  • func ListAllForTeam(ctx context.Context, teamSlug slug.Slug) []*KafkaTopic
  • func (k *KafkaTopic) DeepCopyObject() runtime.Object
  • func (k *KafkaTopic) GetLabels() map[string]string
  • func (k *KafkaTopic) GetName() string
  • func (k *KafkaTopic) GetNamespace() string
  • func (k *KafkaTopic) GetObjectKind() schema.ObjectKind
  • func (k KafkaTopic) ID() ident.Ident
  • func (KafkaTopic) IsNode()
  • func (KafkaTopic) IsPersistence()
  • func (KafkaTopic) IsSearchNode()
• type KafkaTopicACL
• type KafkaTopicACLConnection
  • func ListForWorkload(ctx context.Context, teamSlug slug.Slug, workloadName, poolName string, ...) (*KafkaTopicACLConnection, error)
• type KafkaTopicACLEdge
• type KafkaTopicACLFilter
• type KafkaTopicACLOrder
• type KafkaTopicACLOrderField
  • func (e KafkaTopicACLOrderField) IsValid() bool
  • func (e KafkaTopicACLOrderField) MarshalGQL(w io.Writer)
  • func (e KafkaTopicACLOrderField) String() string
  • func (e *KafkaTopicACLOrderField) UnmarshalGQL(v interface{}) error
• type KafkaTopicConfiguration
• type KafkaTopicConnection
  • func ListForTeam(ctx context.Context, teamSlug slug.Slug, page *pagination.Pagination, ...) (*KafkaTopicConnection, error)
• type KafkaTopicEdge
• type KafkaTopicOrder
• type KafkaTopicOrderField
  • func (e KafkaTopicOrderField) IsValid() bool
  • func (e KafkaTopicOrderField) MarshalGQL(w io.Writer)
  • func (e KafkaTopicOrderField) String() string
  • func (e *KafkaTopicOrderField) UnmarshalGQL(v interface{}) error
• type TeamInventoryCountKafkaTopics

Variables

var (
	SortFilterTopic    = sortfilter.New[*KafkaTopic, KafkaTopicOrderField, struct{}](KafkaTopicOrderFieldName)
	SortFilterTopicACL = sortfilter.New[*KafkaTopicACL, KafkaTopicACLOrderField, *KafkaTopicACLFilter](KafkaTopicACLOrderFieldTopicName)
)

Functions

func NewLoaderContext

func NewLoaderContext(ctx context.Context, watcher *watcher.Watcher[*KafkaTopic]) context.Context

func NewWatcher

func NewWatcher(ctx context.Context, mgr *watcher.Manager) *watcher.Watcher[*KafkaTopic]

func Search

func Search(ctx context.Context, q string) ([]*search.Result, error)

Types

type KafkaTopic

type KafkaTopic struct {
	Name            string                   `json:"name"`
	Pool            string                   `json:"pool"`
	Configuration   *KafkaTopicConfiguration `json:"configuration,omitempty"`
	ACLs            []*KafkaTopicACL         `json:"-"`
	TeamSlug        slug.Slug                `json:"-"`
	EnvironmentName string                   `json:"-"`
}

func Get

func Get(ctx context.Context, teamSlug slug.Slug, environment, name string) (*KafkaTopic, error)

func GetByIdent

func GetByIdent(ctx context.Context, id ident.Ident) (*KafkaTopic, error)

func ListAllForTeam

func ListAllForTeam(ctx context.Context, teamSlug slug.Slug) []*KafkaTopic

func (*KafkaTopic) DeepCopyObject

func (k *KafkaTopic) DeepCopyObject() runtime.Object

func (*KafkaTopic) GetLabels

func (k *KafkaTopic) GetLabels() map[string]string

func (*KafkaTopic) GetName

func (k *KafkaTopic) GetName() string

func (*KafkaTopic) GetNamespace

func (k *KafkaTopic) GetNamespace() string

func (*KafkaTopic) GetObjectKind

func (k *KafkaTopic) GetObjectKind() schema.ObjectKind

func (KafkaTopic) ID

func (k KafkaTopic) ID() ident.Ident

func (KafkaTopic) IsNode

func (KafkaTopic) IsNode()

func (KafkaTopic) IsPersistence

func (KafkaTopic) IsPersistence()

func (KafkaTopic) IsSearchNode

func (KafkaTopic) IsSearchNode()

type KafkaTopicACL

type KafkaTopicACL struct {
	// WorkloadName is the name used for the ACL rule. Can contain wildcards.
	WorkloadName string `json:"workloadName"`
	// TeamName is the name used for the ACL rule. Can contain wildcards.
	TeamName        string    `json:"teamName"`
	Access          string    `json:"access"`
	EnvironmentName string    `json:"-"`
	TopicName       string    `json:"-"`
	TeamSlug        slug.Slug `json:"-"`
}

type KafkaTopicACLConnection

type KafkaTopicACLConnection = pagination.Connection[*KafkaTopicACL]

func ListForWorkload

func ListForWorkload(ctx context.Context, teamSlug slug.Slug, workloadName, poolName string, orderBy *KafkaTopicACLOrder) (*KafkaTopicACLConnection, error)

type KafkaTopicACLEdge

type KafkaTopicACLEdge = pagination.Edge[*KafkaTopicACL]

type KafkaTopicACLFilter

type KafkaTopicACLFilter struct {
	Team     *slug.Slug `json:"team,omitempty"`
	Workload *string    `json:"workload,omitempty"`
}

type KafkaTopicACLOrder

type KafkaTopicACLOrder struct {
	Field     KafkaTopicACLOrderField `json:"field"`
	Direction model.OrderDirection    `json:"direction"`
}

type KafkaTopicACLOrderField

type KafkaTopicACLOrderField string

const (
	KafkaTopicACLOrderFieldTopicName KafkaTopicACLOrderField = "TOPIC_NAME"
	KafkaTopicACLOrderFieldTeamSlug  KafkaTopicACLOrderField = "TEAM_SLUG"
	KafkaTopicACLOrderFieldConsumer  KafkaTopicACLOrderField = "CONSUMER"
	KafkaTopicACLOrderFieldAccess    KafkaTopicACLOrderField = "ACCESS"
)

func (KafkaTopicACLOrderField) IsValid

func (e KafkaTopicACLOrderField) IsValid() bool

func (KafkaTopicACLOrderField) MarshalGQL

func (e KafkaTopicACLOrderField) MarshalGQL(w io.Writer)

func (KafkaTopicACLOrderField) String

func (e KafkaTopicACLOrderField) String() string

func (*KafkaTopicACLOrderField) UnmarshalGQL

func (e *KafkaTopicACLOrderField) UnmarshalGQL(v interface{}) error

type KafkaTopicConfiguration

type KafkaTopicConfiguration struct {
	CleanupPolicy         *string `json:"cleanupPolicy,omitempty"`
	MaxMessageBytes       *int    `json:"maxMessageBytes,omitempty"`
	MinimumInSyncReplicas *int    `json:"minimumInSyncReplicas,omitempty"`
	Partitions            *int    `json:"partitions,omitempty"`
	Replication           *int    `json:"replication,omitempty"`
	RetentionBytes        *int    `json:"retentionBytes,omitempty"`
	RetentionHours        *int    `json:"retentionHours,omitempty"`
	SegmentHours          *int    `json:"segmentHours,omitempty"`
}

type KafkaTopicConnection

type KafkaTopicConnection = pagination.Connection[*KafkaTopic]

func ListForTeam

func ListForTeam(ctx context.Context, teamSlug slug.Slug, page *pagination.Pagination, orderBy *KafkaTopicOrder) (*KafkaTopicConnection, error)

type KafkaTopicEdge

type KafkaTopicEdge = pagination.Edge[*KafkaTopic]

type KafkaTopicOrder

type KafkaTopicOrder struct {
	Field     KafkaTopicOrderField `json:"field"`
	Direction model.OrderDirection `json:"direction"`
}

type KafkaTopicOrderField

type KafkaTopicOrderField string

const (
	KafkaTopicOrderFieldName        KafkaTopicOrderField = "NAME"
	KafkaTopicOrderFieldEnvironment KafkaTopicOrderField = "ENVIRONMENT"
)

func (KafkaTopicOrderField) IsValid

func (e KafkaTopicOrderField) IsValid() bool

func (KafkaTopicOrderField) MarshalGQL

func (e KafkaTopicOrderField) MarshalGQL(w io.Writer)

func (KafkaTopicOrderField) String

func (e KafkaTopicOrderField) String() string

func (*KafkaTopicOrderField) UnmarshalGQL

func (e *KafkaTopicOrderField) UnmarshalGQL(v interface{}) error

type TeamInventoryCountKafkaTopics

type TeamInventoryCountKafkaTopics struct {
	Total int
}