v1alpha1

type RedisConnection struct {
	// Address is the Redis TCP address
	Address string `json:"address"`

	// Options are the connection options
	// +optional
	Options *RedisConnectionOptions `json:"dialOptions,omitempty"`
}

type RedisConnectionOptions struct {
	// Password to use for connecting to Redis
	// +optional
	Password corev1.ObjectReference `json:"password,omitempty"`

	// UseTLS indicates whether to use TLS or not
	// +optional
	UseTLS bool `json:"useTLS,omitempty"`

	// SkipVerify indicates whether to skip TLS verification or not
	// +optional
	SkipVerify bool `json:"skipVerify,omitempty"`

	// Cert is the Kubernetes secret containing the client certificate.
	// +optional
	Cert RedisSecretValueFromSource `json:"cert,omitempty"`

	// Key is the Kubernetes secret containing the client key.
	// +optional
	Key RedisSecretValueFromSource `json:"key,omitempty"`

	// CACert is the Kubernetes secret containing the server CA cert.
	// +optional
	CACert RedisSecretValueFromSource `json:"caCert,omitempty"`
}

type RedisSecretValueFromSource struct {
	// The Secret key to select from.
	SecretKeyRef *corev1.SecretKeySelector `json:"secretKeyRef,omitempty"`
}

type RedisStreamSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   RedisStreamSourceSpec   `json:"spec,omitempty"`
	Status RedisStreamSourceStatus `json:"status,omitempty"`
}

type RedisStreamSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []RedisStreamSource `json:"items"`
}

type RedisStreamSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// RedisConnection represents the address and options to connect
	// to a Redis instance
	RedisConnection `json:",inline"`

	// Stream is the name of the stream.
	Stream string `json:"stream"`

	// Group is the name of the consumer group associated to this source.
	// When left empty, a group is automatically created for this source and
	// deleted when this source is deleted.
	// +optional
	Group string `json:"group,omitempty"`

	// Number of desired consumers running in the consumer group. Defaults to 1.
	//
	// This is a pointer to distinguish between explicit
	// zero and not specified.
	// +optional
	Consumers *int32 `json:"consumers,omitempty"`
}

type RedisStreamSourceStatus struct {
	// inherits duck/v1 SourceStatus, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last
	//   processed by the controller.
	// * Conditions - the latest available observations of a resource's current
	//   state.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	duckv1.SourceStatus `json:",inline"`

	// Total number of consumers actually running in the consumer group.
	// +optional
	Consumers int32 `json:"consumers,omitempty"`
}