eventing

Documentation

Index

• Constants
• Variables
• func ConfigMapNameFromPod(p *corev1.Pod) (string, error)
• type DeliveryOrdering
  • func (d DeliveryOrdering) Validate(context.Context) *apis.FieldError

Constants

const (
	// ConfigMapVolumeName is the volume name of the data plane ConfigMap
	ConfigMapVolumeName = "kafka-resources"

	DispatcherVolumeName = "contract-resources"
)

const (
	// GroupName defines the group of objects.
	GroupName = "internal.kafka.eventing.knative.dev"
)

Variables

var (
	// KafkaConsumerGroupResource represents a Kafka Consumer Group.
	KafkaConsumerGroupResource = schema.GroupResource{
		Group:    GroupName,
		Resource: "ConsumerGroup",
	}

	// KafkaConsumerResource represents a Kafka Consumer.
	KafkaConsumerResource = schema.GroupResource{
		Group:    GroupName,
		Resource: "Consumer",
	}
)

Functions

func ConfigMapNameFromPod

func ConfigMapNameFromPod(p *corev1.Pod) (string, error)

Types

type DeliveryOrdering

type DeliveryOrdering string

const (
	// Ordered is a per partition blocking consumer.
	// It waits for a successful response of the sink before
	// sending the next message in the partition.
	Ordered DeliveryOrdering = "ordered"
	// Unordered is non-blocking consumer that delivers
	// events out of any particular order.
	Unordered DeliveryOrdering = "unordered"
)

func (DeliveryOrdering) Validate

func (d DeliveryOrdering) Validate(context.Context) *apis.FieldError