Documentation
¶
Overview ¶
+groupName=cloudiot.google.kubeform.com
Index ¶
- Variables
- func GetDecoder() map[string]jsoniter.ValDecoder
- func GetEncoder() map[string]jsoniter.ValEncoder
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type Device
- func (in *Device) DeepCopy() *Device
- func (in *Device) DeepCopyInto(out *Device)
- func (in *Device) DeepCopyObject() runtime.Object
- func (r *Device) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Device) ValidateCreate() error
- func (r *Device) ValidateDelete() error
- func (r *Device) ValidateUpdate(old runtime.Object) error
- type DeviceList
- type DeviceSpec
- type DeviceSpecConfig
- type DeviceSpecCredentials
- type DeviceSpecCredentialsPublicKey
- type DeviceSpecCredentialsPublicKeyCodec
- type DeviceSpecGatewayConfig
- type DeviceSpecGatewayConfigCodec
- type DeviceSpecLastErrorStatus
- type DeviceSpecResource
- type DeviceSpecState
- type DeviceStatus
- type Registry
- func (in *Registry) DeepCopy() *Registry
- func (in *Registry) DeepCopyInto(out *Registry)
- func (in *Registry) DeepCopyObject() runtime.Object
- func (r *Registry) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Registry) ValidateCreate() error
- func (r *Registry) ValidateDelete() error
- func (r *Registry) ValidateUpdate(old runtime.Object) error
- type RegistryList
- type RegistrySpec
- type RegistrySpecCredentials
- type RegistrySpecEventNotificationConfigs
- type RegistrySpecResource
- type RegistryStatus
Constants ¶
This section is empty.
Variables ¶
var ( // TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api. // localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes. SchemeBuilder runtime.SchemeBuilder AddToScheme = localSchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: cloudiot.GroupName, Version: "v1alpha1"}
Functions ¶
func GetDecoder ¶
func GetDecoder() map[string]jsoniter.ValDecoder
func GetEncoder ¶
func GetEncoder() map[string]jsoniter.ValEncoder
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type Device ¶
type Device struct {
metav1.TypeMeta `json:",inline,omitempty"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec DeviceSpec `json:"spec,omitempty"`
Status DeviceStatus `json:"status,omitempty"`
}
func (*Device) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Device.
func (*Device) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Device) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Device) SetupWebhookWithManager ¶
func (*Device) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Device) ValidateDelete ¶
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
type DeviceList ¶
type DeviceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
// Items is a list of Device CRD objects
Items []Device `json:"items,omitempty"`
}
DeviceList is a list of Devices
func (*DeviceList) DeepCopy ¶
func (in *DeviceList) DeepCopy() *DeviceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceList.
func (*DeviceList) DeepCopyInto ¶
func (in *DeviceList) DeepCopyInto(out *DeviceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DeviceList) DeepCopyObject ¶
func (in *DeviceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type DeviceSpec ¶
type DeviceSpec struct {
KubeformOutput *DeviceSpecResource `json:"kubeformOutput,omitempty" tf:"-"`
Resource DeviceSpecResource `json:"resource" tf:"resource"`
UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`
TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`
ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`
}
func (*DeviceSpec) DeepCopy ¶
func (in *DeviceSpec) DeepCopy() *DeviceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpec.
func (*DeviceSpec) DeepCopyInto ¶
func (in *DeviceSpec) DeepCopyInto(out *DeviceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecConfig ¶
type DeviceSpecConfig struct {
// The device configuration data.
// +optional
BinaryData *string `json:"binaryData,omitempty" tf:"binary_data"`
// The time at which this configuration version was updated in Cloud IoT Core.
// +optional
CloudUpdateTime *string `json:"cloudUpdateTime,omitempty" tf:"cloud_update_time"`
// The time at which Cloud IoT Core received the acknowledgment from the device,
// indicating that the device has received this configuration version.
// +optional
DeviceACKTime *string `json:"deviceACKTime,omitempty" tf:"device_ack_time"`
// The version of this update.
// +optional
Version *string `json:"version,omitempty" tf:"version"`
}
func (*DeviceSpecConfig) DeepCopy ¶
func (in *DeviceSpecConfig) DeepCopy() *DeviceSpecConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecConfig.
func (*DeviceSpecConfig) DeepCopyInto ¶
func (in *DeviceSpecConfig) DeepCopyInto(out *DeviceSpecConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecCredentials ¶
type DeviceSpecCredentials struct {
// The time at which this credential becomes invalid.
// +optional
ExpirationTime *string `json:"expirationTime,omitempty" tf:"expiration_time"`
// A public key used to verify the signature of JSON Web Tokens (JWTs).
PublicKey *DeviceSpecCredentialsPublicKey `json:"publicKey" tf:"public_key"`
}
func (*DeviceSpecCredentials) DeepCopy ¶
func (in *DeviceSpecCredentials) DeepCopy() *DeviceSpecCredentials
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecCredentials.
func (*DeviceSpecCredentials) DeepCopyInto ¶
func (in *DeviceSpecCredentials) DeepCopyInto(out *DeviceSpecCredentials)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecCredentialsPublicKey ¶
type DeviceSpecCredentialsPublicKey struct {
// The format of the key. Possible values: ["RSA_PEM", "RSA_X509_PEM", "ES256_PEM", "ES256_X509_PEM"]
Format *string `json:"format" tf:"format"`
// The key data.
Key *string `json:"key" tf:"key"`
}
func (*DeviceSpecCredentialsPublicKey) DeepCopy ¶
func (in *DeviceSpecCredentialsPublicKey) DeepCopy() *DeviceSpecCredentialsPublicKey
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecCredentialsPublicKey.
func (*DeviceSpecCredentialsPublicKey) DeepCopyInto ¶
func (in *DeviceSpecCredentialsPublicKey) DeepCopyInto(out *DeviceSpecCredentialsPublicKey)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecCredentialsPublicKeyCodec ¶
type DeviceSpecCredentialsPublicKeyCodec struct {
}
+k8s:deepcopy-gen=false
func (DeviceSpecCredentialsPublicKeyCodec) Decode ¶
func (DeviceSpecCredentialsPublicKeyCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type DeviceSpecGatewayConfig ¶
type DeviceSpecGatewayConfig struct {
// Indicates whether the device is a gateway. Possible values: ["ASSOCIATION_ONLY", "DEVICE_AUTH_TOKEN_ONLY", "ASSOCIATION_AND_DEVICE_AUTH_TOKEN"]
// +optional
GatewayAuthMethod *string `json:"gatewayAuthMethod,omitempty" tf:"gateway_auth_method"`
// Indicates whether the device is a gateway. Default value: "NON_GATEWAY" Possible values: ["GATEWAY", "NON_GATEWAY"]
// +optional
GatewayType *string `json:"gatewayType,omitempty" tf:"gateway_type"`
// The ID of the gateway the device accessed most recently.
// +optional
LastAccessedGatewayID *string `json:"lastAccessedGatewayID,omitempty" tf:"last_accessed_gateway_id"`
// The most recent time at which the device accessed the gateway specified in last_accessed_gateway.
// +optional
LastAccessedGatewayTime *string `json:"lastAccessedGatewayTime,omitempty" tf:"last_accessed_gateway_time"`
}
func (*DeviceSpecGatewayConfig) DeepCopy ¶
func (in *DeviceSpecGatewayConfig) DeepCopy() *DeviceSpecGatewayConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecGatewayConfig.
func (*DeviceSpecGatewayConfig) DeepCopyInto ¶
func (in *DeviceSpecGatewayConfig) DeepCopyInto(out *DeviceSpecGatewayConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecGatewayConfigCodec ¶
type DeviceSpecGatewayConfigCodec struct {
}
+k8s:deepcopy-gen=false
func (DeviceSpecGatewayConfigCodec) Decode ¶
func (DeviceSpecGatewayConfigCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
type DeviceSpecLastErrorStatus ¶
type DeviceSpecLastErrorStatus struct {
// A list of messages that carry the error details.
// +optional
// A developer-facing error message, which should be in English.
// +optional
Message *string `json:"message,omitempty" tf:"message"`
// The status code, which should be an enum value of google.rpc.Code.
// +optional
Number *int64 `json:"number,omitempty" tf:"number"`
}
func (*DeviceSpecLastErrorStatus) DeepCopy ¶
func (in *DeviceSpecLastErrorStatus) DeepCopy() *DeviceSpecLastErrorStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecLastErrorStatus.
func (*DeviceSpecLastErrorStatus) DeepCopyInto ¶
func (in *DeviceSpecLastErrorStatus) DeepCopyInto(out *DeviceSpecLastErrorStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecResource ¶
type DeviceSpecResource struct {
Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`
ID string `json:"id,omitempty" tf:"id,omitempty"`
// If a device is blocked, connections or requests from this device will fail.
// +optional
Blocked *bool `json:"blocked,omitempty" tf:"blocked"`
// The most recent device configuration, which is eventually sent from Cloud IoT Core to the device.
// +optional
Config []DeviceSpecConfig `json:"config,omitempty" tf:"config"`
// The credentials used to authenticate this device.
// +optional
// +kubebuilder:validation:MaxItems=3
Credentials []DeviceSpecCredentials `json:"credentials,omitempty" tf:"credentials"`
// Gateway-related configuration and state.
// +optional
GatewayConfig *DeviceSpecGatewayConfig `json:"gatewayConfig,omitempty" tf:"gateway_config"`
// The last time a cloud-to-device config version acknowledgment was received from the device.
// +optional
LastConfigACKTime *string `json:"lastConfigACKTime,omitempty" tf:"last_config_ack_time"`
// The last time a cloud-to-device config version was sent to the device.
// +optional
LastConfigSendTime *string `json:"lastConfigSendTime,omitempty" tf:"last_config_send_time"`
// The error message of the most recent error, such as a failure to publish to Cloud Pub/Sub.
// +optional
LastErrorStatus []DeviceSpecLastErrorStatus `json:"lastErrorStatus,omitempty" tf:"last_error_status"`
// The time the most recent error occurred, such as a failure to publish to Cloud Pub/Sub.
// +optional
LastErrorTime *string `json:"lastErrorTime,omitempty" tf:"last_error_time"`
// The last time a telemetry event was received.
// +optional
LastEventTime *string `json:"lastEventTime,omitempty" tf:"last_event_time"`
// The last time an MQTT PINGREQ was received.
// +optional
LastHeartbeatTime *string `json:"lastHeartbeatTime,omitempty" tf:"last_heartbeat_time"`
// The last time a state event was received.
// +optional
LastStateTime *string `json:"lastStateTime,omitempty" tf:"last_state_time"`
// The logging verbosity for device activity. Possible values: ["NONE", "ERROR", "INFO", "DEBUG"]
// +optional
LogLevel *string `json:"logLevel,omitempty" tf:"log_level"`
// The metadata key-value pairs assigned to the device.
// +optional
Metadata *map[string]string `json:"metadata,omitempty" tf:"metadata"`
// A unique name for the resource.
Name *string `json:"name" tf:"name"`
// A server-defined unique numeric ID for the device.
// This is a more compact way to identify devices, and it is globally unique.
// +optional
NumID *string `json:"numID,omitempty" tf:"num_id"`
// The name of the device registry where this device should be created.
Registry *string `json:"registry" tf:"registry"`
// The state most recently received from the device.
// +optional
State []DeviceSpecState `json:"state,omitempty" tf:"state"`
}
func (*DeviceSpecResource) DeepCopy ¶
func (in *DeviceSpecResource) DeepCopy() *DeviceSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecResource.
func (*DeviceSpecResource) DeepCopyInto ¶
func (in *DeviceSpecResource) DeepCopyInto(out *DeviceSpecResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceSpecState ¶
type DeviceSpecState struct {
// The device state data.
// +optional
BinaryData *string `json:"binaryData,omitempty" tf:"binary_data"`
// The time at which this state version was updated in Cloud IoT Core.
// +optional
UpdateTime *string `json:"updateTime,omitempty" tf:"update_time"`
}
func (*DeviceSpecState) DeepCopy ¶
func (in *DeviceSpecState) DeepCopy() *DeviceSpecState
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceSpecState.
func (*DeviceSpecState) DeepCopyInto ¶
func (in *DeviceSpecState) DeepCopyInto(out *DeviceSpecState)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceStatus ¶
type DeviceStatus struct {
// Resource generation, which is updated on mutation by the API Server.
// +optional
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
// +optional
Phase status.Status `json:"phase,omitempty"`
// +optional
Conditions []kmapi.Condition `json:"conditions,omitempty"`
}
func (*DeviceStatus) DeepCopy ¶
func (in *DeviceStatus) DeepCopy() *DeviceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceStatus.
func (*DeviceStatus) DeepCopyInto ¶
func (in *DeviceStatus) DeepCopyInto(out *DeviceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Registry ¶
type Registry struct {
metav1.TypeMeta `json:",inline,omitempty"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec RegistrySpec `json:"spec,omitempty"`
Status RegistryStatus `json:"status,omitempty"`
}
func (*Registry) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Registry.
func (*Registry) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Registry) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Registry) SetupWebhookWithManager ¶
func (*Registry) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Registry) ValidateDelete ¶
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
type RegistryList ¶
type RegistryList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
// Items is a list of Registry CRD objects
Items []Registry `json:"items,omitempty"`
}
RegistryList is a list of Registrys
func (*RegistryList) DeepCopy ¶
func (in *RegistryList) DeepCopy() *RegistryList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistryList.
func (*RegistryList) DeepCopyInto ¶
func (in *RegistryList) DeepCopyInto(out *RegistryList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RegistryList) DeepCopyObject ¶
func (in *RegistryList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RegistrySpec ¶
type RegistrySpec struct {
KubeformOutput *RegistrySpecResource `json:"kubeformOutput,omitempty" tf:"-"`
Resource RegistrySpecResource `json:"resource" tf:"resource"`
UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`
TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`
ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`
}
func (*RegistrySpec) DeepCopy ¶
func (in *RegistrySpec) DeepCopy() *RegistrySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistrySpec.
func (*RegistrySpec) DeepCopyInto ¶
func (in *RegistrySpec) DeepCopyInto(out *RegistrySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RegistrySpecCredentials ¶
type RegistrySpecCredentials struct {
// A public key certificate format and data.
PublicKeyCertificate map[string]string `json:"publicKeyCertificate" tf:"public_key_certificate"`
}
func (*RegistrySpecCredentials) DeepCopy ¶
func (in *RegistrySpecCredentials) DeepCopy() *RegistrySpecCredentials
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistrySpecCredentials.
func (*RegistrySpecCredentials) DeepCopyInto ¶
func (in *RegistrySpecCredentials) DeepCopyInto(out *RegistrySpecCredentials)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RegistrySpecEventNotificationConfigs ¶
type RegistrySpecEventNotificationConfigs struct {
// PubSub topic name to publish device events.
PubsubTopicName *string `json:"pubsubTopicName" tf:"pubsub_topic_name"`
// If the subfolder name matches this string exactly, this
// configuration will be used. The string must not include the
// leading '/' character. If empty, all strings are matched. Empty
// value can only be used for the last 'event_notification_configs'
// item.
// +optional
SubfolderMatches *string `json:"subfolderMatches,omitempty" tf:"subfolder_matches"`
}
func (*RegistrySpecEventNotificationConfigs) DeepCopy ¶
func (in *RegistrySpecEventNotificationConfigs) DeepCopy() *RegistrySpecEventNotificationConfigs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistrySpecEventNotificationConfigs.
func (*RegistrySpecEventNotificationConfigs) DeepCopyInto ¶
func (in *RegistrySpecEventNotificationConfigs) DeepCopyInto(out *RegistrySpecEventNotificationConfigs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RegistrySpecResource ¶
type RegistrySpecResource struct {
Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`
ID string `json:"id,omitempty" tf:"id,omitempty"`
// List of public key certificates to authenticate devices.
// +optional
// +kubebuilder:validation:MaxItems=10
Credentials []RegistrySpecCredentials `json:"credentials,omitempty" tf:"credentials"`
// List of configurations for event notifications, such as PubSub topics
// to publish device events to.
// +optional
// +kubebuilder:validation:MaxItems=10
EventNotificationConfigs []RegistrySpecEventNotificationConfigs `json:"eventNotificationConfigs,omitempty" tf:"event_notification_configs"`
// Activate or deactivate HTTP.
// +optional
HttpConfig map[string]string `json:"httpConfig,omitempty" tf:"http_config"`
// The default logging verbosity for activity from devices in this
// registry. Specifies which events should be written to logs. For
// example, if the LogLevel is ERROR, only events that terminate in
// errors will be logged. LogLevel is inclusive; enabling INFO logging
// will also enable ERROR logging. Default value: "NONE" Possible values: ["NONE", "ERROR", "INFO", "DEBUG"]
// +optional
LogLevel *string `json:"logLevel,omitempty" tf:"log_level"`
// Activate or deactivate MQTT.
// +optional
MqttConfig map[string]string `json:"mqttConfig,omitempty" tf:"mqtt_config"`
// A unique name for the resource, required by device registry.
Name *string `json:"name" tf:"name"`
// +optional
Project *string `json:"project,omitempty" tf:"project"`
// The region in which the created registry should reside.
// If it is not provided, the provider region is used.
// +optional
Region *string `json:"region,omitempty" tf:"region"`
// A PubSub topic to publish device state updates.
// +optional
StateNotificationConfig map[string]string `json:"stateNotificationConfig,omitempty" tf:"state_notification_config"`
}
func (*RegistrySpecResource) DeepCopy ¶
func (in *RegistrySpecResource) DeepCopy() *RegistrySpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistrySpecResource.
func (*RegistrySpecResource) DeepCopyInto ¶
func (in *RegistrySpecResource) DeepCopyInto(out *RegistrySpecResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RegistryStatus ¶
type RegistryStatus struct {
// Resource generation, which is updated on mutation by the API Server.
// +optional
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
// +optional
Phase status.Status `json:"phase,omitempty"`
// +optional
Conditions []kmapi.Condition `json:"conditions,omitempty"`
}
func (*RegistryStatus) DeepCopy ¶
func (in *RegistryStatus) DeepCopy() *RegistryStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistryStatus.
func (*RegistryStatus) DeepCopyInto ¶
func (in *RegistryStatus) DeepCopyInto(out *RegistryStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.