contract

package
v0.40.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Protobuf format = "protobuf"
	Json     format = "json"
)

Variables

View Source 
var (
	BackoffPolicy_name = map[int32]string{
		0: "Exponential",
		1: "Linear",
	}
	BackoffPolicy_value = map[string]int32{
		"Exponential": 0,
		"Linear":      1,
	}
)

Enum value maps for BackoffPolicy.

View Source 
var (
	DeliveryOrder_name = map[int32]string{
		0: "UNORDERED",
		1: "ORDERED",
	}
	DeliveryOrder_value = map[string]int32{
		"UNORDERED": 0,
		"ORDERED":   1,
	}
)

Enum value maps for DeliveryOrder.

View Source 
var (
	KeyType_name = map[int32]string{
		0: "String",
		1: "Integer",
		2: "Double",
		3: "ByteArray",
	}
	KeyType_value = map[string]int32{
		"String":    0,
		"Integer":   1,
		"Double":    2,
		"ByteArray": 3,
	}
)

Enum value maps for KeyType.

View Source 
var (
	ContentMode_name = map[int32]string{
		0: "BINARY",
		1: "STRUCTURED",
	}
	ContentMode_value = map[string]int32{
		"BINARY":     0,
		"STRUCTURED": 1,
	}
)

Enum value maps for ContentMode.

View Source 
var (
	SecretField_name = map[int32]string{
		0: "SASL_MECHANISM",
		1: "CA_CRT",
		2: "USER_CRT",
		3: "USER_KEY",
		4: "USER",
		5: "PASSWORD",
	}
	SecretField_value = map[string]int32{
		"SASL_MECHANISM": 0,
		"CA_CRT":         1,
		"USER_CRT":       2,
		"USER_KEY":       3,
		"USER":           4,
		"PASSWORD":       5,
	}
)

Enum value maps for SecretField.

View Source 
var (
	Protocol_name = map[int32]string{
		0: "PLAINTEXT",
		1: "SASL_PLAINTEXT",
		2: "SSL",
		3: "SASL_SSL",
	}
	Protocol_value = map[string]int32{
		"PLAINTEXT":      0,
		"SASL_PLAINTEXT": 1,
		"SSL":            2,
		"SASL_SSL":       3,
	}
)

Enum value maps for Protocol.

View Source 
var File_contract_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type All added in v0.30.0 

type All struct {
	Filters []*DialectedFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*All) Descriptor deprecated added in v0.30.0 

func (*All) Descriptor() ([]byte, []int)

Deprecated: Use All.ProtoReflect.Descriptor instead.

func (*All) GetFilters added in v0.30.0 

func (x *All) GetFilters() []*DialectedFilter

func (*All) ProtoMessage added in v0.30.0 

func (*All) ProtoMessage()

func (*All) ProtoReflect added in v0.30.0 

func (x *All) ProtoReflect() protoreflect.Message

func (*All) Reset added in v0.30.0 

func (x *All) Reset()

func (*All) String added in v0.30.0 

func (x *All) String() string

type Any added in v0.30.0 

type Any struct {
	Filters []*DialectedFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*Any) Descriptor deprecated added in v0.30.0 

func (*Any) Descriptor() ([]byte, []int)

Deprecated: Use Any.ProtoReflect.Descriptor instead.

func (*Any) GetFilters added in v0.30.0 

func (x *Any) GetFilters() []*DialectedFilter

func (*Any) ProtoMessage added in v0.30.0 

func (*Any) ProtoMessage()

func (*Any) ProtoReflect added in v0.30.0 

func (x *Any) ProtoReflect() protoreflect.Message

func (*Any) Reset added in v0.30.0 

func (x *Any) Reset()

func (*Any) String added in v0.30.0 

func (x *Any) String() string

type BackoffPolicy added in v0.19.0 

type BackoffPolicy int32

BackoffPolicyType is the type for backoff policies 

const (
	// Exponential backoff policy
	BackoffPolicy_Exponential BackoffPolicy = 0
	// Linear backoff policy
	BackoffPolicy_Linear BackoffPolicy = 1
)

func (BackoffPolicy) Descriptor added in v0.19.0 

func (BackoffPolicy) Descriptor() protoreflect.EnumDescriptor

func (BackoffPolicy) Enum added in v0.19.0 

func (x BackoffPolicy) Enum() *BackoffPolicy

func (BackoffPolicy) EnumDescriptor deprecated added in v0.19.0 

func (BackoffPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use BackoffPolicy.Descriptor instead.

func (BackoffPolicy) Number added in v0.19.0 

func (x BackoffPolicy) Number() protoreflect.EnumNumber

func (BackoffPolicy) String added in v0.19.0 

func (x BackoffPolicy) String() string

func (BackoffPolicy) Type added in v0.19.0 

func (BackoffPolicy) Type() protoreflect.EnumType

type CESQL added in v0.30.0 

type CESQL struct {
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*CESQL) Descriptor deprecated added in v0.30.0 

func (*CESQL) Descriptor() ([]byte, []int)

Deprecated: Use CESQL.ProtoReflect.Descriptor instead.

func (*CESQL) GetExpression added in v0.30.0 

func (x *CESQL) GetExpression() string

func (*CESQL) ProtoMessage added in v0.30.0 

func (*CESQL) ProtoMessage()

func (*CESQL) ProtoReflect added in v0.30.0 

func (x *CESQL) ProtoReflect() protoreflect.Message

func (*CESQL) Reset added in v0.30.0 

func (x *CESQL) Reset()

func (*CESQL) String added in v0.30.0 

func (x *CESQL) String() string

type CloudEventOverrides added in v0.27.0 

type CloudEventOverrides struct {
	Extensions map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

CloudEvent overrides.

func (*CloudEventOverrides) Descriptor deprecated added in v0.27.0 

func (*CloudEventOverrides) Descriptor() ([]byte, []int)

Deprecated: Use CloudEventOverrides.ProtoReflect.Descriptor instead.

func (*CloudEventOverrides) GetExtensions added in v0.27.0 

func (x *CloudEventOverrides) GetExtensions() map[string]string

func (*CloudEventOverrides) ProtoMessage added in v0.27.0 

func (*CloudEventOverrides) ProtoMessage()

func (*CloudEventOverrides) ProtoReflect added in v0.27.0 

func (x *CloudEventOverrides) ProtoReflect() protoreflect.Message

func (*CloudEventOverrides) Reset added in v0.27.0 

func (x *CloudEventOverrides) Reset()

func (*CloudEventOverrides) String added in v0.27.0 

func (x *CloudEventOverrides) String() string

type ContentMode 

type ContentMode int32

CloudEvent content mode 

const (
	ContentMode_BINARY     ContentMode = 0
	ContentMode_STRUCTURED ContentMode = 1
)

func (ContentMode) Descriptor 

func (ContentMode) Descriptor() protoreflect.EnumDescriptor

func (ContentMode) Enum 

func (x ContentMode) Enum() *ContentMode

func (ContentMode) EnumDescriptor deprecated 

func (ContentMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContentMode.Descriptor instead.

func (ContentMode) Number 

func (x ContentMode) Number() protoreflect.EnumNumber

func (ContentMode) String 

func (x ContentMode) String() string

func (ContentMode) Type 

func (ContentMode) Type() protoreflect.EnumType

type Contract 

type Contract struct {

	// Count each contract update.
	// Make sure each data plane pod has the same contract generation number.
	Generation uint64      `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Resources  []*Resource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"`
	// PEM encoded CA trust bundles for HTTP client.
	TrustBundles []string `protobuf:"bytes,3,rep,name=trustBundles,proto3" json:"trustBundles,omitempty"`
	// contains filtered or unexported fields
}

func (*Contract) Descriptor deprecated 

func (*Contract) Descriptor() ([]byte, []int)

Deprecated: Use Contract.ProtoReflect.Descriptor instead.

func (*Contract) GetGeneration 

func (x *Contract) GetGeneration() uint64

func (*Contract) GetResources 

func (x *Contract) GetResources() []*Resource

func (*Contract) GetTrustBundles added in v0.40.0 

func (x *Contract) GetTrustBundles() []string

func (*Contract) IncrementGeneration added in v0.29.0 

func (x *Contract) IncrementGeneration()

IncrementGeneration increments Generation.

func (*Contract) MarshalLogObject added in v0.24.0 

func (x *Contract) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*Contract) ProtoMessage 

func (*Contract) ProtoMessage()

func (*Contract) ProtoReflect 

func (x *Contract) ProtoReflect() protoreflect.Message

func (*Contract) Reset 

func (x *Contract) Reset()

func (*Contract) String 

func (x *Contract) String() string

type DeliveryOrder added in v0.22.0 

type DeliveryOrder int32

Check dev.knative.eventing.kafka.broker.dispatcher.consumer.DeliveryOrder for more details 

const (
	DeliveryOrder_UNORDERED DeliveryOrder = 0
	DeliveryOrder_ORDERED   DeliveryOrder = 1
)

func (DeliveryOrder) Descriptor added in v0.22.0 

func (DeliveryOrder) Descriptor() protoreflect.EnumDescriptor

func (DeliveryOrder) Enum added in v0.22.0 

func (x DeliveryOrder) Enum() *DeliveryOrder

func (DeliveryOrder) EnumDescriptor deprecated added in v0.22.0 

func (DeliveryOrder) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeliveryOrder.Descriptor instead.

func (DeliveryOrder) Number added in v0.22.0 

func (x DeliveryOrder) Number() protoreflect.EnumNumber

func (DeliveryOrder) String added in v0.22.0 

func (x DeliveryOrder) String() string

func (DeliveryOrder) Type added in v0.22.0 

func (DeliveryOrder) Type() protoreflect.EnumType

type Deserializer added in v0.29.0 

type Deserializer interface {
	Deserialize([]byte) (*Contract, error)
}

type DialectedFilter added in v0.30.0 

type DialectedFilter struct {

	// Types that are assignable to Filter:
	//	*DialectedFilter_Exact
	//	*DialectedFilter_Prefix
	//	*DialectedFilter_Suffix
	//	*DialectedFilter_All
	//	*DialectedFilter_Any
	//	*DialectedFilter_Not
	//	*DialectedFilter_Cesql
	Filter isDialectedFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func FromSubscriptionFilter added in v0.30.2 

func FromSubscriptionFilter(f v1.SubscriptionsAPIFilter) *DialectedFilter

FromSubscriptionFilter converts a SubscriptionsAPIFilter to the corresponding DialectedFilter based on the property set in the SubscriptionsAPIFilter. If the SubscriptionsAPIFilter has multiple dialects set, they will be wrapped inside a Filter of the type DialectedFilter_All

E.g a SubscriptionsAPIFilter with the Exact field set will be converted to a DialectedFilter which Filter is of type DialectedFilter_Exact.

func (*DialectedFilter) Descriptor deprecated added in v0.30.0 

func (*DialectedFilter) Descriptor() ([]byte, []int)

Deprecated: Use DialectedFilter.ProtoReflect.Descriptor instead.

func (*DialectedFilter) GetAll added in v0.30.0 

func (x *DialectedFilter) GetAll() *All

func (*DialectedFilter) GetAny added in v0.30.0 

func (x *DialectedFilter) GetAny() *Any

func (*DialectedFilter) GetCesql added in v0.30.0 

func (x *DialectedFilter) GetCesql() *CESQL

func (*DialectedFilter) GetExact added in v0.30.0 

func (x *DialectedFilter) GetExact() *Exact

func (*DialectedFilter) GetFilter added in v0.30.0 

func (m *DialectedFilter) GetFilter() isDialectedFilter_Filter

func (*DialectedFilter) GetNot added in v0.30.0 

func (x *DialectedFilter) GetNot() *Not

func (*DialectedFilter) GetPrefix added in v0.30.0 

func (x *DialectedFilter) GetPrefix() *Prefix

func (*DialectedFilter) GetSuffix added in v0.30.0 

func (x *DialectedFilter) GetSuffix() *Suffix

func (*DialectedFilter) ProtoMessage added in v0.30.0 

func (*DialectedFilter) ProtoMessage()

func (*DialectedFilter) ProtoReflect added in v0.30.0 

func (x *DialectedFilter) ProtoReflect() protoreflect.Message

func (*DialectedFilter) Reset added in v0.30.0 

func (x *DialectedFilter) Reset()

func (*DialectedFilter) String added in v0.30.0 

func (x *DialectedFilter) String() string

type DialectedFilter_All added in v0.30.0 

type DialectedFilter_All struct {
	All *All `protobuf:"bytes,4,opt,name=all,proto3,oneof"`
}

type DialectedFilter_Any added in v0.30.0 

type DialectedFilter_Any struct {
	Any *Any `protobuf:"bytes,5,opt,name=any,proto3,oneof"`
}

type DialectedFilter_Cesql added in v0.30.0 

type DialectedFilter_Cesql struct {
	Cesql *CESQL `protobuf:"bytes,7,opt,name=cesql,proto3,oneof"`
}

type DialectedFilter_Exact added in v0.30.0 

type DialectedFilter_Exact struct {
	Exact *Exact `protobuf:"bytes,1,opt,name=exact,proto3,oneof"`
}

type DialectedFilter_Not added in v0.30.0 

type DialectedFilter_Not struct {
	Not *Not `protobuf:"bytes,6,opt,name=not,proto3,oneof"`
}

type DialectedFilter_Prefix added in v0.30.0 

type DialectedFilter_Prefix struct {
	Prefix *Prefix `protobuf:"bytes,2,opt,name=prefix,proto3,oneof"`
}

type DialectedFilter_Suffix added in v0.30.0 

type DialectedFilter_Suffix struct {
	Suffix *Suffix `protobuf:"bytes,3,opt,name=suffix,proto3,oneof"`
}

type Egress 

type Egress struct {

	// consumer group name
	ConsumerGroup string `protobuf:"bytes,1,opt,name=consumerGroup,proto3" json:"consumerGroup,omitempty"`
	// destination is the sink where events are sent.
	Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	// destination CA Cert is the CA Cert used for HTTPS communication through destination
	DestinationCACerts string `protobuf:"bytes,15,opt,name=destinationCACerts,proto3" json:"destinationCACerts,omitempty"`
	// Types that are assignable to ReplyStrategy:
	//	*Egress_ReplyUrl
	//	*Egress_ReplyToOriginalTopic
	//	*Egress_DiscardReply
	ReplyStrategy isEgress_ReplyStrategy `protobuf_oneof:"replyStrategy"`
	// replyUrl CA Cert is the CA Cert used for HTTPS communication through replyUrl
	ReplyUrlCACerts string `protobuf:"bytes,16,opt,name=replyUrlCACerts,proto3" json:"replyUrlCACerts,omitempty"`
	// A filter for performing exact match against Cloud Events attributes
	Filter *Filter `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// Id of the egress
	// It's the same as the Kubernetes resource uid
	Uid string `protobuf:"bytes,6,opt,name=uid,proto3" json:"uid,omitempty"`
	// Egress configuration.
	// It overrides Resource's EgressConfig.
	EgressConfig *EgressConfig `protobuf:"bytes,7,opt,name=egressConfig,proto3" json:"egressConfig,omitempty"`
	// Delivery guarantee to use
	// Empty defaults to unordered
	DeliveryOrder DeliveryOrder `protobuf:"varint,8,opt,name=deliveryOrder,proto3,enum=DeliveryOrder" json:"deliveryOrder,omitempty"`
	// Kafka record key type.
	KeyType KeyType `protobuf:"varint,10,opt,name=keyType,proto3,enum=KeyType" json:"keyType,omitempty"`
	// Resource reference.
	//
	// This reference is used to reference the associated resource for data plane
	// activities such as:
	// - tagging metrics
	Reference *Reference `protobuf:"bytes,11,opt,name=reference,proto3" json:"reference,omitempty"`
	// CNCF CloudEvents SubscriptionsAPI compliant filters
	DialectedFilter []*DialectedFilter `protobuf:"bytes,12,rep,name=dialectedFilter,proto3" json:"dialectedFilter,omitempty"`
	// Number of virtual replicas.
	VReplicas int32 `protobuf:"varint,13,opt,name=vReplicas,proto3" json:"vReplicas,omitempty"`
	// Egress feature flags.
	FeatureFlags *EgressFeatureFlags `protobuf:"bytes,14,opt,name=featureFlags,proto3" json:"featureFlags,omitempty"`
	// contains filtered or unexported fields
}

func (*Egress) Descriptor deprecated 

func (*Egress) Descriptor() ([]byte, []int)

Deprecated: Use Egress.ProtoReflect.Descriptor instead.

func (*Egress) GetConsumerGroup 

func (x *Egress) GetConsumerGroup() string

func (*Egress) GetDeliveryOrder added in v0.22.0 

func (x *Egress) GetDeliveryOrder() DeliveryOrder

func (*Egress) GetDestination 

func (x *Egress) GetDestination() string

func (*Egress) GetDestinationCACerts added in v0.38.0 

func (x *Egress) GetDestinationCACerts() string

func (*Egress) GetDialectedFilter added in v0.30.0 

func (x *Egress) GetDialectedFilter() []*DialectedFilter

func (*Egress) GetDiscardReply added in v0.27.0 

func (x *Egress) GetDiscardReply() *Empty

func (*Egress) GetEgressConfig added in v0.21.0 

func (x *Egress) GetEgressConfig() *EgressConfig

func (*Egress) GetFeatureFlags added in v0.32.0 

func (x *Egress) GetFeatureFlags() *EgressFeatureFlags

func (*Egress) GetFilter 

func (x *Egress) GetFilter() *Filter

func (*Egress) GetKeyType added in v0.27.0 

func (x *Egress) GetKeyType() KeyType

func (*Egress) GetReference added in v0.29.0 

func (x *Egress) GetReference() *Reference

func (*Egress) GetReplyStrategy 

func (m *Egress) GetReplyStrategy() isEgress_ReplyStrategy

func (*Egress) GetReplyToOriginalTopic 

func (x *Egress) GetReplyToOriginalTopic() *Empty

func (*Egress) GetReplyUrl 

func (x *Egress) GetReplyUrl() string

func (*Egress) GetReplyUrlCACerts added in v0.38.0 

func (x *Egress) GetReplyUrlCACerts() string

func (*Egress) GetUid added in v0.19.0 

func (x *Egress) GetUid() string

func (*Egress) GetVReplicas added in v0.32.0 

func (x *Egress) GetVReplicas() int32

func (*Egress) MarshalLogObject added in v0.24.0 

func (x *Egress) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*Egress) ProtoMessage 

func (*Egress) ProtoMessage()

func (*Egress) ProtoReflect 

func (x *Egress) ProtoReflect() protoreflect.Message

func (*Egress) Reset 

func (x *Egress) Reset()

func (*Egress) String 

func (x *Egress) String() string

type EgressConfig 

type EgressConfig struct {

	// Dead letter is where the event is sent when something goes wrong
	DeadLetter string `protobuf:"bytes,1,opt,name=deadLetter,proto3" json:"deadLetter,omitempty"`
	// Dead Letter CA Cert is the CA Cert used for HTTPS communication through dead letter
	DeadLetterCACerts string `protobuf:"bytes,6,opt,name=deadLetterCACerts,proto3" json:"deadLetterCACerts,omitempty"`
	// retry is the minimum number of retries the sender should attempt when
	// sending an event before moving it to the dead letter sink.
	//
	// Setting retry to 0 means don't retry.
	Retry uint32 `protobuf:"varint,2,opt,name=retry,proto3" json:"retry,omitempty"`
	// backoffPolicy is the retry backoff policy (linear, exponential).
	BackoffPolicy BackoffPolicy `protobuf:"varint,3,opt,name=backoffPolicy,proto3,enum=BackoffPolicy" json:"backoffPolicy,omitempty"`
	// backoffDelay is the delay before retrying in milliseconds.
	BackoffDelay uint64 `protobuf:"varint,4,opt,name=backoffDelay,proto3" json:"backoffDelay,omitempty"`
	// timeout is the single request timeout (not the overall retry timeout)
	Timeout uint64 `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*EgressConfig) Descriptor deprecated 

func (*EgressConfig) Descriptor() ([]byte, []int)

Deprecated: Use EgressConfig.ProtoReflect.Descriptor instead.

func (*EgressConfig) GetBackoffDelay added in v0.19.0 

func (x *EgressConfig) GetBackoffDelay() uint64

func (*EgressConfig) GetBackoffPolicy added in v0.19.0 

func (x *EgressConfig) GetBackoffPolicy() BackoffPolicy

func (*EgressConfig) GetDeadLetter 

func (x *EgressConfig) GetDeadLetter() string

func (*EgressConfig) GetDeadLetterCACerts added in v0.38.0 

func (x *EgressConfig) GetDeadLetterCACerts() string

func (*EgressConfig) GetRetry added in v0.19.0 

func (x *EgressConfig) GetRetry() uint32

func (*EgressConfig) GetTimeout added in v0.24.0 

func (x *EgressConfig) GetTimeout() uint64

func (*EgressConfig) MarshalLogObject added in v0.24.0 

func (x *EgressConfig) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*EgressConfig) ProtoMessage 

func (*EgressConfig) ProtoMessage()

func (*EgressConfig) ProtoReflect 

func (x *EgressConfig) ProtoReflect() protoreflect.Message

func (*EgressConfig) Reset 

func (x *EgressConfig) Reset()

func (*EgressConfig) String 

func (x *EgressConfig) String() string

type EgressFeatureFlags added in v0.32.0 

type EgressFeatureFlags struct {

	// Enable rateLimiter
	EnableRateLimiter bool `protobuf:"varint,1,opt,name=enableRateLimiter,proto3" json:"enableRateLimiter,omitempty"`
	// Enable newMetrics
	EnableOrderedExecutorMetrics bool `protobuf:"varint,2,opt,name=enableOrderedExecutorMetrics,proto3" json:"enableOrderedExecutorMetrics,omitempty"`
	// contains filtered or unexported fields
}

func (*EgressFeatureFlags) Descriptor deprecated added in v0.32.0 

func (*EgressFeatureFlags) Descriptor() ([]byte, []int)

Deprecated: Use EgressFeatureFlags.ProtoReflect.Descriptor instead.

func (*EgressFeatureFlags) GetEnableOrderedExecutorMetrics added in v0.33.0 

func (x *EgressFeatureFlags) GetEnableOrderedExecutorMetrics() bool

func (*EgressFeatureFlags) GetEnableRateLimiter added in v0.32.0 

func (x *EgressFeatureFlags) GetEnableRateLimiter() bool

func (*EgressFeatureFlags) ProtoMessage added in v0.32.0 

func (*EgressFeatureFlags) ProtoMessage()

func (*EgressFeatureFlags) ProtoReflect added in v0.32.0 

func (x *EgressFeatureFlags) ProtoReflect() protoreflect.Message

func (*EgressFeatureFlags) Reset added in v0.32.0 

func (x *EgressFeatureFlags) Reset()

func (*EgressFeatureFlags) String added in v0.32.0 

func (x *EgressFeatureFlags) String() string

type Egress_DiscardReply added in v0.27.0 

type Egress_DiscardReply struct {
	// Discard response.
	DiscardReply *Empty `protobuf:"bytes,9,opt,name=discardReply,proto3,oneof"`
}

type Egress_ReplyToOriginalTopic 

type Egress_ReplyToOriginalTopic struct {
	// Send the response to a Kafka topic
	ReplyToOriginalTopic *Empty `protobuf:"bytes,4,opt,name=replyToOriginalTopic,proto3,oneof"`
}

type Egress_ReplyUrl 

type Egress_ReplyUrl struct {
	// Send the response to an url
	ReplyUrl string `protobuf:"bytes,3,opt,name=replyUrl,proto3,oneof"`
}

type Empty added in v0.22.5 

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

We don't use the google.protobuf.Empty type because configuring the include directory is a mess for the contributors and for the build scripts. Hence, more than dealing with contributors that can't get their dev environment working with the project, we prefer to have this additional single line of code. Protobuf include nightmare? No thanks!

func (*Empty) Descriptor deprecated added in v0.22.5 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage added in v0.22.5 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v0.22.5 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset added in v0.22.5 

func (x *Empty) Reset()

func (*Empty) String added in v0.22.5 

func (x *Empty) String() string

type Exact added in v0.30.0 

type Exact struct {
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Exact) Descriptor deprecated added in v0.30.0 

func (*Exact) Descriptor() ([]byte, []int)

Deprecated: Use Exact.ProtoReflect.Descriptor instead.

func (*Exact) GetAttributes added in v0.30.0 

func (x *Exact) GetAttributes() map[string]string

func (*Exact) ProtoMessage added in v0.30.0 

func (*Exact) ProtoMessage()

func (*Exact) ProtoReflect added in v0.30.0 

func (x *Exact) ProtoReflect() protoreflect.Message

func (*Exact) Reset added in v0.30.0 

func (x *Exact) Reset()

func (*Exact) String added in v0.30.0 

func (x *Exact) String() string

type Filter 

type Filter struct {

	// attributes filters events by exact match on event context attributes.
	// Each key in the map is compared with the equivalent key in the event
	// context. An event passes the filter if all values are equal to the
	// specified values.
	//
	// Nested context attributes are not supported as keys. Only string values are supported.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

func (*Filter) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetAttributes 

func (x *Filter) GetAttributes() map[string]string

func (*Filter) MarshalLogObject added in v0.24.0 

func (x *Filter) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type FormatSerDe added in v0.29.0 

type FormatSerDe struct {
	Format format
}

func (*FormatSerDe) Deserialize added in v0.29.0 

func (s *FormatSerDe) Deserialize(data []byte) (*Contract, error)

func (*FormatSerDe) Serialize added in v0.29.0 

func (s *FormatSerDe) Serialize(ct *Contract) ([]byte, error)

type Ingress 

type Ingress struct {

	// Optional content mode to use when pushing messages to Kafka
	ContentMode ContentMode `protobuf:"varint,1,opt,name=contentMode,proto3,enum=ContentMode" json:"contentMode,omitempty"`
	// path to listen for incoming events.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// host header to match
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// whether to autocreate event types
	EnableAutoCreateEventTypes bool `protobuf:"varint,4,opt,name=enableAutoCreateEventTypes,proto3" json:"enableAutoCreateEventTypes,omitempty"`
	// contains filtered or unexported fields
}

Ingress is the definition for HTTP ingress that is receiving the events into the Knative Kafka component.

path and host fields are used for identifying the targets. They are exclusive. When a request comes with "/some-path", hostname will not be checked. When a request comes with "/", only hostname matching will be done. It is allowed to specify both path and host in ingress contract to support both modes.

func (*Ingress) Descriptor deprecated 

func (*Ingress) Descriptor() ([]byte, []int)

Deprecated: Use Ingress.ProtoReflect.Descriptor instead.

func (*Ingress) GetContentMode 

func (x *Ingress) GetContentMode() ContentMode

func (*Ingress) GetEnableAutoCreateEventTypes added in v0.38.0 

func (x *Ingress) GetEnableAutoCreateEventTypes() bool

func (*Ingress) GetHost 

func (x *Ingress) GetHost() string

func (*Ingress) GetPath 

func (x *Ingress) GetPath() string

func (*Ingress) MarshalLogObject added in v0.24.0 

func (x *Ingress) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*Ingress) ProtoMessage 

func (*Ingress) ProtoMessage()

func (*Ingress) ProtoReflect 

func (x *Ingress) ProtoReflect() protoreflect.Message

func (*Ingress) Reset 

func (x *Ingress) Reset()

func (*Ingress) String 

func (x *Ingress) String() string

type KeyFieldReference added in v0.27.0 

type KeyFieldReference struct {

	// Key in the secret.
	SecretKey string `protobuf:"bytes,2,opt,name=secretKey,proto3" json:"secretKey,omitempty"`
	// Field name.
	Field SecretField `protobuf:"varint,3,opt,name=field,proto3,enum=SecretField" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyFieldReference) Descriptor deprecated added in v0.27.0 

func (*KeyFieldReference) Descriptor() ([]byte, []int)

Deprecated: Use KeyFieldReference.ProtoReflect.Descriptor instead.

func (*KeyFieldReference) GetField added in v0.27.0 

func (x *KeyFieldReference) GetField() SecretField

func (*KeyFieldReference) GetSecretKey added in v0.27.0 

func (x *KeyFieldReference) GetSecretKey() string

func (*KeyFieldReference) ProtoMessage added in v0.27.0 

func (*KeyFieldReference) ProtoMessage()

func (*KeyFieldReference) ProtoReflect added in v0.27.0 

func (x *KeyFieldReference) ProtoReflect() protoreflect.Message

func (*KeyFieldReference) Reset added in v0.27.0 

func (x *KeyFieldReference) Reset()

func (*KeyFieldReference) String added in v0.27.0 

func (x *KeyFieldReference) String() string

type KeyType added in v0.27.0 

type KeyType int32
const (
	KeyType_String    KeyType = 0
	KeyType_Integer   KeyType = 1
	KeyType_Double    KeyType = 2
	KeyType_ByteArray KeyType = 3
)

func (KeyType) Descriptor added in v0.27.0 

func (KeyType) Descriptor() protoreflect.EnumDescriptor

func (KeyType) Enum added in v0.27.0 

func (x KeyType) Enum() *KeyType

func (KeyType) EnumDescriptor deprecated added in v0.27.0 

func (KeyType) EnumDescriptor() ([]byte, []int)

Deprecated: Use KeyType.Descriptor instead.

func (KeyType) Number added in v0.27.0 

func (x KeyType) Number() protoreflect.EnumNumber

func (KeyType) String added in v0.27.0 

func (x KeyType) String() string

func (KeyType) Type added in v0.27.0 

func (KeyType) Type() protoreflect.EnumType

type MultiSecretReference added in v0.27.0 

type MultiSecretReference struct {

	// Protocol.
	Protocol Protocol `protobuf:"varint,1,opt,name=protocol,proto3,enum=Protocol" json:"protocol,omitempty"`
	// Secret references.
	References []*SecretReference `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiSecretReference) Descriptor deprecated added in v0.27.0 

func (*MultiSecretReference) Descriptor() ([]byte, []int)

Deprecated: Use MultiSecretReference.ProtoReflect.Descriptor instead.

func (*MultiSecretReference) GetProtocol added in v0.27.0 

func (x *MultiSecretReference) GetProtocol() Protocol

func (*MultiSecretReference) GetReferences added in v0.27.0 

func (x *MultiSecretReference) GetReferences() []*SecretReference

func (*MultiSecretReference) ProtoMessage added in v0.27.0 

func (*MultiSecretReference) ProtoMessage()

func (*MultiSecretReference) ProtoReflect added in v0.27.0 

func (x *MultiSecretReference) ProtoReflect() protoreflect.Message

func (*MultiSecretReference) Reset added in v0.27.0 

func (x *MultiSecretReference) Reset()

func (*MultiSecretReference) String added in v0.27.0 

func (x *MultiSecretReference) String() string

type Not added in v0.30.0 

type Not struct {
	Filter *DialectedFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*Not) Descriptor deprecated added in v0.30.0 

func (*Not) Descriptor() ([]byte, []int)

Deprecated: Use Not.ProtoReflect.Descriptor instead.

func (*Not) GetFilter added in v0.30.0 

func (x *Not) GetFilter() *DialectedFilter

func (*Not) ProtoMessage added in v0.30.0 

func (*Not) ProtoMessage()

func (*Not) ProtoReflect added in v0.30.0 

func (x *Not) ProtoReflect() protoreflect.Message

func (*Not) Reset added in v0.30.0 

func (x *Not) Reset()

func (*Not) String added in v0.30.0 

func (x *Not) String() string

type Prefix added in v0.30.0 

type Prefix struct {
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Prefix) Descriptor deprecated added in v0.30.0 

func (*Prefix) Descriptor() ([]byte, []int)

Deprecated: Use Prefix.ProtoReflect.Descriptor instead.

func (*Prefix) GetAttributes added in v0.30.2 

func (x *Prefix) GetAttributes() map[string]string

func (*Prefix) ProtoMessage added in v0.30.0 

func (*Prefix) ProtoMessage()

func (*Prefix) ProtoReflect added in v0.30.0 

func (x *Prefix) ProtoReflect() protoreflect.Message

func (*Prefix) Reset added in v0.30.0 

func (x *Prefix) Reset()

func (*Prefix) String added in v0.30.0 

func (x *Prefix) String() string

type Protocol added in v0.27.0 

type Protocol int32
const (
	Protocol_PLAINTEXT      Protocol = 0
	Protocol_SASL_PLAINTEXT Protocol = 1
	Protocol_SSL            Protocol = 2
	Protocol_SASL_SSL       Protocol = 3
)

func (Protocol) Descriptor added in v0.27.0 

func (Protocol) Descriptor() protoreflect.EnumDescriptor

func (Protocol) Enum added in v0.27.0 

func (x Protocol) Enum() *Protocol

func (Protocol) EnumDescriptor deprecated added in v0.27.0 

func (Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use Protocol.Descriptor instead.

func (Protocol) Number added in v0.27.0 

func (x Protocol) Number() protoreflect.EnumNumber

func (Protocol) String added in v0.27.0 

func (x Protocol) String() string

func (Protocol) Type added in v0.27.0 

func (Protocol) Type() protoreflect.EnumType

type Reference added in v0.21.0 

type Reference struct {

	// Object id.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Object namespace.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Object name.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Object ResourceVersion.
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// Object kind.
	Kind string `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,omitempty"`
	// Object GroupVersion.
	GroupVersion string `protobuf:"bytes,6,opt,name=groupVersion,proto3" json:"groupVersion,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes resource reference.

func (*Reference) Descriptor deprecated added in v0.21.0 

func (*Reference) Descriptor() ([]byte, []int)

Deprecated: Use Reference.ProtoReflect.Descriptor instead.

func (*Reference) GetGroupVersion added in v0.40.0 

func (x *Reference) GetGroupVersion() string

func (*Reference) GetKind added in v0.40.0 

func (x *Reference) GetKind() string

func (*Reference) GetName added in v0.21.0 

func (x *Reference) GetName() string

func (*Reference) GetNamespace added in v0.21.0 

func (x *Reference) GetNamespace() string

func (*Reference) GetUuid added in v0.21.0 

func (x *Reference) GetUuid() string

func (*Reference) GetVersion added in v0.21.0 

func (x *Reference) GetVersion() string

func (*Reference) ProtoMessage added in v0.21.0 

func (*Reference) ProtoMessage()

func (*Reference) ProtoReflect added in v0.21.0 

func (x *Reference) ProtoReflect() protoreflect.Message

func (*Reference) Reset added in v0.21.0 

func (x *Reference) Reset()

func (*Reference) String added in v0.21.0 

func (x *Reference) String() string

type Resource 

type Resource struct {

	// Id of the resource
	// It's the same as the Kubernetes resource uid
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// Topics name
	// Note: If there is an ingress configured, then this field must have exactly 1 element otherwise,
	//  if the resource does just dispatch from Kafka, then this topic list can contain multiple elements
	Topics []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	// A comma separated list of host/port pairs to use for establishing the initial connection to the Kafka cluster.
	// Note: we're using a comma separated list simply because that's how java kafka client likes it.
	BootstrapServers string `protobuf:"bytes,3,opt,name=bootstrapServers,proto3" json:"bootstrapServers,omitempty"`
	// Optional ingress for this topic
	Ingress *Ingress `protobuf:"bytes,4,opt,name=ingress,proto3" json:"ingress,omitempty"`
	// Optional configuration of egress valid for the whole resource
	EgressConfig *EgressConfig `protobuf:"bytes,5,opt,name=egressConfig,proto3" json:"egressConfig,omitempty"`
	// Optional egresses for this topic
	Egresses []*Egress `protobuf:"bytes,6,rep,name=egresses,proto3" json:"egresses,omitempty"`
	// Types that are assignable to Auth:
	//	*Resource_AbsentAuth
	//	*Resource_AuthSecret
	//	*Resource_MultiAuthSecret
	Auth                isResource_Auth      `protobuf_oneof:"Auth"`
	CloudEventOverrides *CloudEventOverrides `protobuf:"bytes,10,opt,name=cloudEventOverrides,proto3" json:"cloudEventOverrides,omitempty"`
	// Resource reference.
	//
	// This reference is used to reference the associated resource for data plane
	// activities such as:
	// - setting the `source` attribute of a KafkaSource event (when it's not a CloudEvent)
	// - tagging metrics
	Reference *Reference `protobuf:"bytes,11,opt,name=reference,proto3" json:"reference,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated 

func (*Resource) Descriptor() ([]byte, []int)

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetAbsentAuth added in v0.21.0 

func (x *Resource) GetAbsentAuth() *Empty

func (*Resource) GetAuth added in v0.21.0 

func (m *Resource) GetAuth() isResource_Auth

func (*Resource) GetAuthSecret added in v0.21.0 

func (x *Resource) GetAuthSecret() *Reference

func (*Resource) GetBootstrapServers 

func (x *Resource) GetBootstrapServers() string

func (*Resource) GetCloudEventOverrides added in v0.27.0 

func (x *Resource) GetCloudEventOverrides() *CloudEventOverrides

func (*Resource) GetEgressConfig 

func (x *Resource) GetEgressConfig() *EgressConfig

func (*Resource) GetEgresses 

func (x *Resource) GetEgresses() []*Egress

func (*Resource) GetIngress 

func (x *Resource) GetIngress() *Ingress

func (*Resource) GetMultiAuthSecret added in v0.27.0 

func (x *Resource) GetMultiAuthSecret() *MultiSecretReference

func (*Resource) GetReference added in v0.27.0 

func (x *Resource) GetReference() *Reference

func (*Resource) GetTopics 

func (x *Resource) GetTopics() []string

func (*Resource) GetUid added in v0.19.0 

func (x *Resource) GetUid() string

func (*Resource) MarshalLogObject added in v0.24.0 

func (x *Resource) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

func (x *Resource) ProtoReflect() protoreflect.Message

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type Resource_AbsentAuth added in v0.21.0 

type Resource_AbsentAuth struct {
	// No auth configured.
	AbsentAuth *Empty `protobuf:"bytes,7,opt,name=absentAuth,proto3,oneof"`
}

type Resource_AuthSecret added in v0.21.0 

type Resource_AuthSecret struct {
	// Secret reference.
	//
	// Secret format:
	//
	//   protocol: (PLAINTEXT | SASL_PLAINTEXT | SSL | SASL_SSL)
	//   sasl.mechanism: (SCRAM-SHA-256 | SCRAM-SHA-512)
	//   ca.crt: <CA PEM certificate>
	//   user.crt: <User PEM certificate>
	//   user.key: <User PEM key>
	//   user: <SASL username>
	//   password: <SASL password>
	//
	// Validation:
	//   - protocol=PLAINTEXT
	//   - protocol=SSL
	//     - required:
	//       - ca.crt
	//       - user.crt
	//       - user.key
	//   - protocol=SASL_PLAINTEXT
	//     - required:
	//       - sasl.mechanism
	//       - user
	//       - password
	//   - protocol=SASL_SSL
	//     - required:
	//       - sasl.mechanism
	//       - ca.crt
	//       - user.crt
	//       - user.key
	//       - user
	//       - password
	AuthSecret *Reference `protobuf:"bytes,8,opt,name=authSecret,proto3,oneof"`
}

type Resource_MultiAuthSecret added in v0.27.0 

type Resource_MultiAuthSecret struct {
	// Multiple secrets reference.
	MultiAuthSecret *MultiSecretReference `protobuf:"bytes,9,opt,name=multiAuthSecret,proto3,oneof"`
}

type SecretField added in v0.27.0 

type SecretField int32
const (
	SecretField_SASL_MECHANISM SecretField = 0
	SecretField_CA_CRT         SecretField = 1
	SecretField_USER_CRT       SecretField = 2
	SecretField_USER_KEY       SecretField = 3
	SecretField_USER           SecretField = 4
	SecretField_PASSWORD       SecretField = 5
)

func (SecretField) Descriptor added in v0.27.0 

func (SecretField) Descriptor() protoreflect.EnumDescriptor

func (SecretField) Enum added in v0.27.0 

func (x SecretField) Enum() *SecretField

func (SecretField) EnumDescriptor deprecated added in v0.27.0 

func (SecretField) EnumDescriptor() ([]byte, []int)

Deprecated: Use SecretField.Descriptor instead.

func (SecretField) Number added in v0.27.0 

func (x SecretField) Number() protoreflect.EnumNumber

func (SecretField) String added in v0.27.0 

func (x SecretField) String() string

func (SecretField) Type added in v0.27.0 

func (SecretField) Type() protoreflect.EnumType

type SecretReference added in v0.27.0 

type SecretReference struct {

	// Secret reference.
	Reference *Reference `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
	// Multiple key-field references.
	KeyFieldReferences []*KeyFieldReference `protobuf:"bytes,2,rep,name=keyFieldReferences,proto3" json:"keyFieldReferences,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretReference) Descriptor deprecated added in v0.27.0 

func (*SecretReference) Descriptor() ([]byte, []int)

Deprecated: Use SecretReference.ProtoReflect.Descriptor instead.

func (*SecretReference) GetKeyFieldReferences added in v0.27.0 

func (x *SecretReference) GetKeyFieldReferences() []*KeyFieldReference

func (*SecretReference) GetReference added in v0.27.0 

func (x *SecretReference) GetReference() *Reference

func (*SecretReference) ProtoMessage added in v0.27.0 

func (*SecretReference) ProtoMessage()

func (*SecretReference) ProtoReflect added in v0.27.0 

func (x *SecretReference) ProtoReflect() protoreflect.Message

func (*SecretReference) Reset added in v0.27.0 

func (x *SecretReference) Reset()

func (*SecretReference) String added in v0.27.0 

func (x *SecretReference) String() string

type Serializer added in v0.29.0 

type Serializer interface {
	Serialize(ct *Contract) ([]byte, error)
}

type Suffix added in v0.30.0 

type Suffix struct {
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Suffix) Descriptor deprecated added in v0.30.0 

func (*Suffix) Descriptor() ([]byte, []int)

Deprecated: Use Suffix.ProtoReflect.Descriptor instead.

func (*Suffix) GetAttributes added in v0.30.2 

func (x *Suffix) GetAttributes() map[string]string

func (*Suffix) ProtoMessage added in v0.30.0 

func (*Suffix) ProtoMessage()

func (*Suffix) ProtoReflect added in v0.30.0 

func (x *Suffix) ProtoReflect() protoreflect.Message

func (*Suffix) Reset added in v0.30.0 

func (x *Suffix) Reset()

func (*Suffix) String added in v0.30.0 

func (x *Suffix) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.