Versions in this module Expand all Collapse all v0 v0.12.0 Jan 21, 2020 Changes in this version + const ApiServerConditionDeployed + const ApiServerConditionEventTypeProvided + const ApiServerConditionReady + const ApiServerConditionSinkProvided + const ApiServerConditionSufficientPermissions + const ApiServerSourceAddEventType + const ApiServerSourceAddRefEventType + const ApiServerSourceDeleteEventType + const ApiServerSourceDeleteRefEventType + const ApiServerSourceUpdateEventType + const ApiServerSourceUpdateRefEventType + const ContainerConditionDeployed + const ContainerConditionReady + const ContainerConditionSinkProvided + const CronJobConditionDeployed + const CronJobConditionEventTypeProvided + const CronJobConditionReady + const CronJobConditionResources + const CronJobConditionSinkProvided + const CronJobConditionValidSchedule + const CronJobEventType + const RefMode + const ResourceMode + const SinkBindingConditionReady + const StatusConditionTypeDeprecated + var AddToScheme = SchemeBuilder.AddToScheme + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + func CronJobEventSource(namespace, cronJobName string) string + func GetSinkURI(ctx context.Context) *apis.URL + func Kind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + func WithSinkURI(ctx context.Context, uri *apis.URL) context.Context + type ApiServerResource struct + APIVersion string + Controller bool + ControllerSelector metav1.OwnerReference + Kind string + LabelSelector metav1.LabelSelector + func (in *ApiServerResource) DeepCopy() *ApiServerResource + func (in *ApiServerResource) DeepCopyInto(out *ApiServerResource) + type ApiServerSource struct + Spec ApiServerSourceSpec + Status ApiServerSourceStatus + func (a *ApiServerSource) GetUntypedSpec() interface{} + func (c *ApiServerSource) Validate(ctx context.Context) *apis.FieldError + func (in *ApiServerSource) DeepCopy() *ApiServerSource + func (in *ApiServerSource) DeepCopyInto(out *ApiServerSource) + func (in *ApiServerSource) DeepCopyObject() runtime.Object + func (s *ApiServerSource) GetGroupVersionKind() schema.GroupVersionKind + func (s *ApiServerSource) SetDefaults(ctx context.Context) + type ApiServerSourceList struct + Items []ApiServerSource + func (in *ApiServerSourceList) DeepCopy() *ApiServerSourceList + func (in *ApiServerSourceList) DeepCopyInto(out *ApiServerSourceList) + func (in *ApiServerSourceList) DeepCopyObject() runtime.Object + type ApiServerSourceSpec struct + Mode string + Resources []ApiServerResource + ServiceAccountName string + Sink *duckv1beta1.Destination + func (cs *ApiServerSourceSpec) Validate(ctx context.Context) *apis.FieldError + func (in *ApiServerSourceSpec) DeepCopy() *ApiServerSourceSpec + func (in *ApiServerSourceSpec) DeepCopyInto(out *ApiServerSourceSpec) + func (ss *ApiServerSourceSpec) SetDefaults(ctx context.Context) + type ApiServerSourceStatus struct + SinkURI string + func (in *ApiServerSourceStatus) DeepCopy() *ApiServerSourceStatus + func (in *ApiServerSourceStatus) DeepCopyInto(out *ApiServerSourceStatus) + func (s *ApiServerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (s *ApiServerSourceStatus) InitializeConditions() + func (s *ApiServerSourceStatus) IsReady() bool + func (s *ApiServerSourceStatus) MarkEventTypes() + func (s *ApiServerSourceStatus) MarkNoEventTypes(reason, messageFormat string, messageA ...interface{}) + func (s *ApiServerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{}) + func (s *ApiServerSourceStatus) MarkNoSufficientPermissions(reason, messageFormat string, messageA ...interface{}) + func (s *ApiServerSourceStatus) MarkSink(uri string) + func (s *ApiServerSourceStatus) MarkSinkWarnRefDeprecated(uri string) + func (s *ApiServerSourceStatus) MarkSufficientPermissions() + func (s *ApiServerSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment) + type ContainerSource struct + Spec ContainerSourceSpec + Status ContainerSourceStatus + func (c *ContainerSource) GetUntypedSpec() interface{} + func (c *ContainerSource) Validate(ctx context.Context) *apis.FieldError + func (in *ContainerSource) DeepCopy() *ContainerSource + func (in *ContainerSource) DeepCopyInto(out *ContainerSource) + func (in *ContainerSource) DeepCopyObject() runtime.Object + func (s *ContainerSource) GetGroupVersionKind() schema.GroupVersionKind + func (s *ContainerSource) SetDefaults(ctx context.Context) + type ContainerSourceList struct + Items []ContainerSource + func (in *ContainerSourceList) DeepCopy() *ContainerSourceList + func (in *ContainerSourceList) DeepCopyInto(out *ContainerSourceList) + func (in *ContainerSourceList) DeepCopyObject() runtime.Object + type ContainerSourceSpec struct + DeprecatedArgs []string + DeprecatedEnv []corev1.EnvVar + DeprecatedImage string + DeprecatedServiceAccountName string + Sink *duckv1beta1.Destination + Template *corev1.PodTemplateSpec + func (cs *ContainerSourceSpec) Validate(ctx context.Context) *apis.FieldError + func (in *ContainerSourceSpec) DeepCopy() *ContainerSourceSpec + func (in *ContainerSourceSpec) DeepCopyInto(out *ContainerSourceSpec) + func (ss *ContainerSourceSpec) SetDefaults(ctx context.Context) + type ContainerSourceStatus struct + SinkURI string + func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus + func (in *ContainerSourceStatus) DeepCopyInto(out *ContainerSourceStatus) + func (s *ContainerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (s *ContainerSourceStatus) InitializeConditions() + func (s *ContainerSourceStatus) IsDeployed() bool + func (s *ContainerSourceStatus) IsReady() bool + func (s *ContainerSourceStatus) MarkDeployed() + func (s *ContainerSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{}) + func (s *ContainerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{}) + func (s *ContainerSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{}) + func (s *ContainerSourceStatus) MarkSink(uri string) + func (s *ContainerSourceStatus) MarkSinkWarnRefDeprecated(uri string) + type CronJobLimitsSpec struct + ResourceCPU string + ResourceMemory string + func (in *CronJobLimitsSpec) DeepCopy() *CronJobLimitsSpec + func (in *CronJobLimitsSpec) DeepCopyInto(out *CronJobLimitsSpec) + type CronJobRequestsSpec struct + ResourceCPU string + ResourceMemory string + func (in *CronJobRequestsSpec) DeepCopy() *CronJobRequestsSpec + func (in *CronJobRequestsSpec) DeepCopyInto(out *CronJobRequestsSpec) + type CronJobResourceSpec struct + Limits CronJobLimitsSpec + Requests CronJobRequestsSpec + func (in *CronJobResourceSpec) DeepCopy() *CronJobResourceSpec + func (in *CronJobResourceSpec) DeepCopyInto(out *CronJobResourceSpec) + type CronJobSource struct + Spec CronJobSourceSpec + Status CronJobSourceStatus + func (c *CronJobSource) GetUntypedSpec() interface{} + func (c *CronJobSource) Validate(ctx context.Context) *apis.FieldError + func (in *CronJobSource) DeepCopy() *CronJobSource + func (in *CronJobSource) DeepCopyInto(out *CronJobSource) + func (in *CronJobSource) DeepCopyObject() runtime.Object + func (s *CronJobSource) GetGroupVersionKind() schema.GroupVersionKind + func (s *CronJobSource) SetDefaults(ctx context.Context) + type CronJobSourceList struct + Items []CronJobSource + func (in *CronJobSourceList) DeepCopy() *CronJobSourceList + func (in *CronJobSourceList) DeepCopyInto(out *CronJobSourceList) + func (in *CronJobSourceList) DeepCopyObject() runtime.Object + type CronJobSourceSpec struct + Data string + Resources CronJobResourceSpec + Schedule string + ServiceAccountName string + Sink *duckv1beta1.Destination + func (cs *CronJobSourceSpec) Validate(ctx context.Context) *apis.FieldError + func (in *CronJobSourceSpec) DeepCopy() *CronJobSourceSpec + func (in *CronJobSourceSpec) DeepCopyInto(out *CronJobSourceSpec) + func (ss *CronJobSourceSpec) SetDefaults(ctx context.Context) + type CronJobSourceStatus struct + SinkURI string + func (in *CronJobSourceStatus) DeepCopy() *CronJobSourceStatus + func (in *CronJobSourceStatus) DeepCopyInto(out *CronJobSourceStatus) + func (s *CronJobSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition + func (s *CronJobSourceStatus) InitializeConditions() + func (s *CronJobSourceStatus) IsReady() bool + func (s *CronJobSourceStatus) MarkEventType() + func (s *CronJobSourceStatus) MarkInvalidSchedule(reason, messageFormat string, messageA ...interface{}) + func (s *CronJobSourceStatus) MarkNoEventType(reason, messageFormat string, messageA ...interface{}) + func (s *CronJobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{}) + func (s *CronJobSourceStatus) MarkResourcesCorrect() + func (s *CronJobSourceStatus) MarkResourcesIncorrect(reason, messageFormat string, messageA ...interface{}) + func (s *CronJobSourceStatus) MarkSchedule() + func (s *CronJobSourceStatus) MarkSink(uri string) + func (s *CronJobSourceStatus) MarkSinkWarnRefDeprecated(uri string) + func (s *CronJobSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment) + type Deprecated struct + func (d *Deprecated) MarkDeprecated(s *duckv1.Status, reason, msg string) + func (in *Deprecated) DeepCopy() *Deprecated + func (in *Deprecated) DeepCopyInto(out *Deprecated) + type SinkBinding struct + Spec SinkBindingSpec + Status SinkBindingStatus + func (c *SinkBinding) GetUntypedSpec() interface{} + func (fb *SinkBinding) Do(ctx context.Context, ps *duckv1.WithPod) + func (fb *SinkBinding) GetBindingStatus() duck.BindableStatus + func (fb *SinkBinding) GetSubject() tracker.Reference + func (fb *SinkBinding) SetDefaults(ctx context.Context) + func (fb *SinkBinding) Undo(ctx context.Context, ps *duckv1.WithPod) + func (fb *SinkBinding) Validate(ctx context.Context) *apis.FieldError + func (in *SinkBinding) DeepCopy() *SinkBinding + func (in *SinkBinding) DeepCopyInto(out *SinkBinding) + func (in *SinkBinding) DeepCopyObject() runtime.Object + func (s *SinkBinding) GetGroupVersionKind() schema.GroupVersionKind + type SinkBindingList struct + Items []SinkBinding + func (in *SinkBindingList) DeepCopy() *SinkBindingList + func (in *SinkBindingList) DeepCopyInto(out *SinkBindingList) + func (in *SinkBindingList) DeepCopyObject() runtime.Object + type SinkBindingSpec struct + func (fbs *SinkBindingSpec) Validate(ctx context.Context) *apis.FieldError + func (in *SinkBindingSpec) DeepCopy() *SinkBindingSpec + func (in *SinkBindingSpec) DeepCopyInto(out *SinkBindingSpec) + type SinkBindingStatus struct + func (fbs *SinkBindingStatus) InitializeConditions() + func (fbs *SinkBindingStatus) MarkBindingAvailable() + func (fbs *SinkBindingStatus) MarkBindingUnavailable(reason, message string) + func (fbs *SinkBindingStatus) SetObservedGeneration(gen int64) + func (in *SinkBindingStatus) DeepCopy() *SinkBindingStatus + func (in *SinkBindingStatus) DeepCopyInto(out *SinkBindingStatus)