Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the events v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=events.kabanero.io
Package v1alpha1 contains API Schema definitions for the events v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=events.kabanero.io
Index ¶
- Constants
- Variables
- func MediatorHashKey(mediator *EventMediator) string
- type EventConnection
- type EventConnections
- type EventConnectionsList
- type EventConnectionsSpec
- type EventConnectionsStatus
- type EventDestinationEndpoint
- type EventFunctionImpl
- type EventGithubRepository
- type EventMediationImpl
- type EventMediationRepositoryType
- type EventMediationSelector
- type EventMediationVariable
- type EventMediator
- type EventMediatorList
- type EventMediatorSourceEndpoint
- type EventMediatorSpec
- type EventMediatorStatus
- type EventRepository
- type EventSourceEndpoint
- type EventStatement
- type EventStatusParameter
- type EventStatusSummary
- type HttpsEndpoint
Constants ¶
const ( DEFAULT_HTTP_PORT = 9080 DEFAULT_HTTPS_PORT = 9443 )
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "events.kabanero.io", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} )
Functions ¶
func MediatorHashKey ¶
func MediatorHashKey(mediator *EventMediator) string
Types ¶
type EventConnection ¶
type EventConnection struct { From EventSourceEndpoint `json:"from"` To []EventDestinationEndpoint `json:"to"` }
Connections are from subscriber to publishers
from sender to receivers
func (*EventConnection) DeepCopy ¶
func (in *EventConnection) DeepCopy() *EventConnection
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventConnection.
func (*EventConnection) DeepCopyInto ¶
func (in *EventConnection) DeepCopyInto(out *EventConnection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventConnections ¶
type EventConnections struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec EventConnectionsSpec `json:"spec,omitempty"` Status EventConnectionsStatus `json:"status,omitempty"` }
EventConnections is the Schema for the eventconnections API +kubebuilder:subresource:status +kubebuilder:resource:path=eventconnections,scope=Namespaced
func (*EventConnections) DeepCopy ¶
func (in *EventConnections) DeepCopy() *EventConnections
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventConnections.
func (*EventConnections) DeepCopyInto ¶
func (in *EventConnections) DeepCopyInto(out *EventConnections)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventConnections) DeepCopyObject ¶
func (in *EventConnections) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EventConnectionsList ¶
type EventConnectionsList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []EventConnections `json:"items"` }
EventConnectionsList contains a list of EventConnections
func (*EventConnectionsList) DeepCopy ¶
func (in *EventConnectionsList) DeepCopy() *EventConnectionsList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventConnectionsList.
func (*EventConnectionsList) DeepCopyInto ¶
func (in *EventConnectionsList) DeepCopyInto(out *EventConnectionsList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventConnectionsList) DeepCopyObject ¶
func (in *EventConnectionsList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EventConnectionsSpec ¶
type EventConnectionsSpec struct { // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html Connections []EventConnection `json:"connections"` }
EventConnectionsSpec defines the desired state of EventConnections
func (*EventConnectionsSpec) DeepCopy ¶
func (in *EventConnectionsSpec) DeepCopy() *EventConnectionsSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventConnectionsSpec.
func (*EventConnectionsSpec) DeepCopyInto ¶
func (in *EventConnectionsSpec) DeepCopyInto(out *EventConnectionsSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventConnectionsStatus ¶
type EventConnectionsStatus struct { // INSERT ADDITIONAL STATUS FIELD - define observed state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html Message string `json:"message"` }
EventConnectionsStatus defines the observed state of EventConnections
func (*EventConnectionsStatus) DeepCopy ¶
func (in *EventConnectionsStatus) DeepCopy() *EventConnectionsStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventConnectionsStatus.
func (*EventConnectionsStatus) DeepCopyInto ¶
func (in *EventConnectionsStatus) DeepCopyInto(out *EventConnectionsStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventDestinationEndpoint ¶
type EventDestinationEndpoint struct {
Https *[]HttpsEndpoint `json:"https,omitempty"`
}
func (*EventDestinationEndpoint) DeepCopy ¶
func (in *EventDestinationEndpoint) DeepCopy() *EventDestinationEndpoint
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventDestinationEndpoint.
func (*EventDestinationEndpoint) DeepCopyInto ¶
func (in *EventDestinationEndpoint) DeepCopyInto(out *EventDestinationEndpoint)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventFunctionImpl ¶
type EventFunctionImpl struct { Name string `json:"name"` Input string `json:"input"` Output string `json:"output"` Body []EventStatement `json:"body"` }
func (*EventFunctionImpl) DeepCopy ¶
func (in *EventFunctionImpl) DeepCopy() *EventFunctionImpl
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventFunctionImpl.
func (*EventFunctionImpl) DeepCopyInto ¶
func (in *EventFunctionImpl) DeepCopyInto(out *EventFunctionImpl)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventGithubRepository ¶
type EventGithubRepository struct { Secret string `json:"secret,omitempty"` WebhookSecret string `json:"webhookSecret,omitempty"` }
func (*EventGithubRepository) DeepCopy ¶
func (in *EventGithubRepository) DeepCopy() *EventGithubRepository
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventGithubRepository.
func (*EventGithubRepository) DeepCopyInto ¶
func (in *EventGithubRepository) DeepCopyInto(out *EventGithubRepository)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediationImpl ¶
type EventMediationImpl struct { Name string `json:"name"` // Input string `json:"input,omitempty"` SendTo []string `json:"sendTo,omitempty"` Selector *EventMediationSelector `json:"selector,omitempty"` // local variables Variables *[]EventMediationVariable `json:"variables,omitempty"` Body []EventStatement `json:"body,omitempty"` }
func (*EventMediationImpl) DeepCopy ¶
func (in *EventMediationImpl) DeepCopy() *EventMediationImpl
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediationImpl.
func (*EventMediationImpl) DeepCopyInto ¶
func (in *EventMediationImpl) DeepCopyInto(out *EventMediationImpl)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediationRepositoryType ¶
type EventMediationRepositoryType struct { File string `json:"file"` NewVariable string `json:"newVariable"` }
func (*EventMediationRepositoryType) DeepCopy ¶
func (in *EventMediationRepositoryType) DeepCopy() *EventMediationRepositoryType
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediationRepositoryType.
func (*EventMediationRepositoryType) DeepCopyInto ¶
func (in *EventMediationRepositoryType) DeepCopyInto(out *EventMediationRepositoryType)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediationSelector ¶
type EventMediationSelector struct { UrlPattern string `json:"urlPattern,omitempty"` RepositoryType *EventMediationRepositoryType `json:"repositoryType,omitempty"` }
func (*EventMediationSelector) DeepCopy ¶
func (in *EventMediationSelector) DeepCopy() *EventMediationSelector
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediationSelector.
func (*EventMediationSelector) DeepCopyInto ¶
func (in *EventMediationSelector) DeepCopyInto(out *EventMediationSelector)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediationVariable ¶
type EventMediationVariable struct { Name string `json:"name"` Value *string `json:"value,omitempty"` // value treated as tring ValueExpression *string `json:"valueExpression,omitempty"` // value intrepreted as CEL expression }
func (*EventMediationVariable) DeepCopy ¶
func (in *EventMediationVariable) DeepCopy() *EventMediationVariable
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediationVariable.
func (*EventMediationVariable) DeepCopyInto ¶
func (in *EventMediationVariable) DeepCopyInto(out *EventMediationVariable)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediator ¶
type EventMediator struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec EventMediatorSpec `json:"spec,omitempty"` Status EventMediatorStatus `json:"status,omitempty"` }
EventMediator is the Schema for the eventmediators API +kubebuilder:subresource:status +kubebuilder:resource:path=eventmediators,scope=Namespaced
func (*EventMediator) DeepCopy ¶
func (in *EventMediator) DeepCopy() *EventMediator
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediator.
func (*EventMediator) DeepCopyInto ¶
func (in *EventMediator) DeepCopyInto(out *EventMediator)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventMediator) DeepCopyObject ¶
func (in *EventMediator) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EventMediatorList ¶
type EventMediatorList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []EventMediator `json:"items"` }
EventMediatorList contains a list of EventMediator
func (*EventMediatorList) DeepCopy ¶
func (in *EventMediatorList) DeepCopy() *EventMediatorList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediatorList.
func (*EventMediatorList) DeepCopyInto ¶
func (in *EventMediatorList) DeepCopyInto(out *EventMediatorList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventMediatorList) DeepCopyObject ¶
func (in *EventMediatorList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type EventMediatorSourceEndpoint ¶
type EventMediatorSourceEndpoint struct { Name string `json:"name"` Mediation string `json:"mediation,omitempty"` // Identifier of the endpoint Destination string `json:"destination,omitempty"` }
func (*EventMediatorSourceEndpoint) DeepCopy ¶
func (in *EventMediatorSourceEndpoint) DeepCopy() *EventMediatorSourceEndpoint
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediatorSourceEndpoint.
func (*EventMediatorSourceEndpoint) DeepCopyInto ¶
func (in *EventMediatorSourceEndpoint) DeepCopyInto(out *EventMediatorSourceEndpoint)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediatorSpec ¶
type EventMediatorSpec struct { // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html CreateListener bool `json:"createListener,omitempty"` InsecureListener bool `json:"insecureListener,omitempty"` CreateRoute bool `json:"createRoute,omitempty"` Repositories *[]EventRepository `json:"repositories,omitempty"` // global variables Variables *[]EventMediationVariable `json:"variables,omitempty"` // mediations Mediations *[]EventMediationImpl `json:"mediations,omitempty"` }
EventMediatorSpec defines the desired state of EventMediator
func (*EventMediatorSpec) DeepCopy ¶
func (in *EventMediatorSpec) DeepCopy() *EventMediatorSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediatorSpec.
func (*EventMediatorSpec) DeepCopyInto ¶
func (in *EventMediatorSpec) DeepCopyInto(out *EventMediatorSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventMediatorStatus ¶
type EventMediatorStatus struct { // INSERT ADDITIONAL STATUS FIELD - define observed state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html Summary []EventStatusSummary `json:"summary"` }
EventMediatorStatus defines the observed state of EventMediator
func (*EventMediatorStatus) DeepCopy ¶
func (in *EventMediatorStatus) DeepCopy() *EventMediatorStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventMediatorStatus.
func (*EventMediatorStatus) DeepCopyInto ¶
func (in *EventMediatorStatus) DeepCopyInto(out *EventMediatorStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventRepository ¶
type EventRepository struct {
Github *EventGithubRepository `json:"github,omitempty"`
}
func (*EventRepository) DeepCopy ¶
func (in *EventRepository) DeepCopy() *EventRepository
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventRepository.
func (*EventRepository) DeepCopyInto ¶
func (in *EventRepository) DeepCopyInto(out *EventRepository)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventSourceEndpoint ¶
type EventSourceEndpoint struct {
Mediator *EventMediatorSourceEndpoint `json:"mediator,omitempty"`
}
func (*EventSourceEndpoint) DeepCopy ¶
func (in *EventSourceEndpoint) DeepCopy() *EventSourceEndpoint
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceEndpoint.
func (*EventSourceEndpoint) DeepCopyInto ¶
func (in *EventSourceEndpoint) DeepCopyInto(out *EventSourceEndpoint)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStatement ¶
type EventStatement struct { If *string `json:"if,omitempty"` Assign *string `json:"=,omitempty"` Switch *[]EventStatement `json:"switch,omitempty"` Body *[]EventStatement `json:"body,omitempty"` Default *[]EventStatement `json:"default,omitempty"` }
Valid combinations are:
- assignment
- if and assignment
- if and body
- switch
- if and switch TBD: switch and default
func (*EventStatement) DeepCopy ¶
func (in *EventStatement) DeepCopy() *EventStatement
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventStatement.
func (*EventStatement) DeepCopyInto ¶
func (in *EventStatement) DeepCopyInto(out *EventStatement)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStatusParameter ¶
func (*EventStatusParameter) DeepCopy ¶
func (in *EventStatusParameter) DeepCopy() *EventStatusParameter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventStatusParameter.
func (*EventStatusParameter) DeepCopyInto ¶
func (in *EventStatusParameter) DeepCopyInto(out *EventStatusParameter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStatusSummary ¶
type EventStatusSummary struct { Time metav1.Time `json:"time,omitempty"` Operation string `json:"operation"` Input []EventStatusParameter `json:"input"` Result string `json:"result"` Message string `json:"message"` }
func (*EventStatusSummary) DeepCopy ¶
func (in *EventStatusSummary) DeepCopy() *EventStatusSummary
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventStatusSummary.
func (*EventStatusSummary) DeepCopyInto ¶
func (in *EventStatusSummary) DeepCopyInto(out *EventStatusSummary)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStatusSummary) Equals ¶
func (es *EventStatusSummary) Equals(other *EventStatusSummary) bool
Equality without taking time into account
type HttpsEndpoint ¶
type HttpsEndpoint struct { Url *string `json:"url,omitempty"` // uninterpreted URL UrlExpression *string `json:"urlExpression,omitempty"` // evaluate url as a cel expression first Insecure bool `json:"insecure,omitempty"` }
func (*HttpsEndpoint) DeepCopy ¶
func (in *HttpsEndpoint) DeepCopy() *HttpsEndpoint
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HttpsEndpoint.
func (*HttpsEndpoint) DeepCopyInto ¶
func (in *HttpsEndpoint) DeepCopyInto(out *HttpsEndpoint)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.