Documentation ¶
Index ¶
- Variables
- type BackoffPolicy
- func (BackoffPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x BackoffPolicy) Enum() *BackoffPolicy
- func (BackoffPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x BackoffPolicy) Number() protoreflect.EnumNumber
- func (x BackoffPolicy) String() string
- func (BackoffPolicy) Type() protoreflect.EnumType
- type ContentMode
- func (ContentMode) Descriptor() protoreflect.EnumDescriptor
- func (x ContentMode) Enum() *ContentMode
- func (ContentMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContentMode) Number() protoreflect.EnumNumber
- func (x ContentMode) String() string
- func (ContentMode) Type() protoreflect.EnumType
- type Contract
- type Egress
- func (*Egress) Descriptor() ([]byte, []int)deprecated
- func (x *Egress) GetConsumerGroup() string
- func (x *Egress) GetDestination() string
- func (x *Egress) GetEgressConfig() *EgressConfig
- func (x *Egress) GetFilter() *Filter
- func (m *Egress) GetReplyStrategy() isEgress_ReplyStrategy
- func (x *Egress) GetReplyToOriginalTopic() *empty.Empty
- func (x *Egress) GetReplyUrl() string
- func (x *Egress) GetUid() string
- func (*Egress) ProtoMessage()
- func (x *Egress) ProtoReflect() protoreflect.Message
- func (x *Egress) Reset()
- func (x *Egress) String() string
- type EgressConfig
- func (*EgressConfig) Descriptor() ([]byte, []int)deprecated
- func (x *EgressConfig) GetBackoffDelay() uint64
- func (x *EgressConfig) GetBackoffPolicy() BackoffPolicy
- func (x *EgressConfig) GetDeadLetter() string
- func (x *EgressConfig) GetRetry() uint32
- func (*EgressConfig) ProtoMessage()
- func (x *EgressConfig) ProtoReflect() protoreflect.Message
- func (x *EgressConfig) Reset()
- func (x *EgressConfig) String() string
- type Egress_ReplyToOriginalTopic
- type Egress_ReplyUrl
- type Filter
- type Ingress
- func (*Ingress) Descriptor() ([]byte, []int)deprecated
- func (x *Ingress) GetContentMode() ContentMode
- func (x *Ingress) GetHost() string
- func (m *Ingress) GetIngressType() isIngress_IngressType
- func (x *Ingress) GetPath() string
- func (*Ingress) ProtoMessage()
- func (x *Ingress) ProtoReflect() protoreflect.Message
- func (x *Ingress) Reset()
- func (x *Ingress) String() string
- type Ingress_Host
- type Ingress_Path
- type Reference
- func (*Reference) Descriptor() ([]byte, []int)deprecated
- func (x *Reference) GetName() string
- func (x *Reference) GetNamespace() string
- func (x *Reference) GetUuid() string
- func (x *Reference) GetVersion() string
- func (*Reference) ProtoMessage()
- func (x *Reference) ProtoReflect() protoreflect.Message
- func (x *Reference) Reset()
- func (x *Reference) String() string
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetAbsentAuth() *empty.Empty
- func (m *Resource) GetAuth() isResource_Auth
- func (x *Resource) GetAuthSecret() *Reference
- func (x *Resource) GetBootstrapServers() string
- func (x *Resource) GetEgressConfig() *EgressConfig
- func (x *Resource) GetEgresses() []*Egress
- func (x *Resource) GetIngress() *Ingress
- func (x *Resource) GetTopics() []string
- func (x *Resource) GetUid() string
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- type Resource_AbsentAuth
- type Resource_AuthSecret
Constants ¶
This section is empty.
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 ( 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 File_proto_def_contract_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
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 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"` // contains filtered or unexported fields }
func (*Contract) Descriptor
deprecated
func (*Contract) GetGeneration ¶
func (*Contract) GetResources ¶
func (*Contract) ProtoMessage ¶
func (*Contract) ProtoMessage()
func (*Contract) ProtoReflect ¶
func (x *Contract) ProtoReflect() protoreflect.Message
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"` // Types that are assignable to ReplyStrategy: // *Egress_ReplyUrl // *Egress_ReplyToOriginalTopic ReplyStrategy isEgress_ReplyStrategy `protobuf_oneof:"replyStrategy"` 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"` // contains filtered or unexported fields }
func (*Egress) Descriptor
deprecated
func (*Egress) GetConsumerGroup ¶
func (*Egress) GetDestination ¶
func (*Egress) GetEgressConfig ¶ added in v0.21.0
func (x *Egress) GetEgressConfig() *EgressConfig
func (*Egress) GetReplyStrategy ¶
func (m *Egress) GetReplyStrategy() isEgress_ReplyStrategy
func (*Egress) GetReplyToOriginalTopic ¶
func (*Egress) GetReplyUrl ¶
func (*Egress) ProtoMessage ¶
func (*Egress) ProtoMessage()
func (*Egress) ProtoReflect ¶
func (x *Egress) ProtoReflect() protoreflect.Message
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"` // 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"` // 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) GetRetry ¶ added in v0.19.0
func (x *EgressConfig) GetRetry() uint32
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 Egress_ReplyUrl ¶
type Egress_ReplyUrl struct { // Send the response to an url ReplyUrl string `protobuf:"bytes,3,opt,name=replyUrl,proto3,oneof"` }
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) GetAttributes ¶
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
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"` // Ingress can both listen on a specific HTTP path // or listen to the / path but match the Host header // // Types that are assignable to IngressType: // *Ingress_Path // *Ingress_Host IngressType isIngress_IngressType `protobuf_oneof:"ingressType"` // contains filtered or unexported fields }
func (*Ingress) Descriptor
deprecated
func (*Ingress) GetContentMode ¶
func (x *Ingress) GetContentMode() ContentMode
func (*Ingress) GetIngressType ¶
func (m *Ingress) GetIngressType() isIngress_IngressType
func (*Ingress) ProtoMessage ¶
func (*Ingress) ProtoMessage()
func (*Ingress) ProtoReflect ¶
func (x *Ingress) ProtoReflect() protoreflect.Message
type Ingress_Host ¶
type Ingress_Host struct { // host header to match Host string `protobuf:"bytes,3,opt,name=host,proto3,oneof"` }
type Ingress_Path ¶
type Ingress_Path struct { // path to listen for incoming events. Path string `protobuf:"bytes,2,opt,name=path,proto3,oneof"` }
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 version. Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
Kubernetes resource reference.
func (*Reference) Descriptor
deprecated
added in
v0.21.0
func (*Reference) GetNamespace ¶ added in v0.21.0
func (*Reference) GetVersion ¶ added in v0.21.0
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
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 Auth isResource_Auth `protobuf_oneof:"Auth"` // contains filtered or unexported fields }
func (*Resource) Descriptor
deprecated
func (*Resource) GetAbsentAuth ¶ added in v0.21.0
func (*Resource) GetAuthSecret ¶ added in v0.21.0
func (*Resource) GetBootstrapServers ¶
func (*Resource) GetEgressConfig ¶
func (x *Resource) GetEgressConfig() *EgressConfig
func (*Resource) GetEgresses ¶
func (*Resource) GetIngress ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type Resource_AbsentAuth ¶ added in v0.21.0
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"` }
Click to show internal directories.
Click to hide internal directories.