Documentation
¶
Index ¶
- func GenerateBrokers(in *arv1.ReplicaAssignmentBrokers) *v1alpha1.ReplicaAssignmentBrokers
- func GenerateConfigUpdate(in []v1alpha1.ConfigCreate) []arv1.ConfigUpdate
- func GenerateCreateTopicOptions(in v1alpha1.TopicParameters, o *arv1.CreateTopicOptions) error
- func GenerateObservation(in *arv1.TopicDetail) (v1alpha1.TopicObservation, error)
- func GenerateReplicaAssignments(in []arv1.ReplicaAssignment) []v1alpha1.ReplicaAssignment
- func GenerateTopicParameters(in *arv1.TopicDetail) (*v1alpha1.TopicParameters, error)
- func GenerateUpdateTopicOptions(currentPartitions *int64, in v1alpha1.TopicParameters, ...) error
- func Generatearv1ConfigCreate(in []v1alpha1.ConfigCreate) []arv1.ConfigCreate
- func Generatev1alpha1ConfigCreate(in *arv1.TopicConfigs) []v1alpha1.ConfigCreate
- func Generatev1alpha1ConfigCreateLateInitializeSpec(specConfigs []v1alpha1.ConfigCreate, in *arv1.TopicConfigs) []v1alpha1.ConfigCreate
- func Generatev1alpha1TopicConfigs(in *arv1.TopicConfigs) *v1alpha1.TopicConfigs
- func IsUpToDate(in *v1alpha1.TopicParameters, observed *arv1.TopicDetail, l logging.Logger) (bool, error)
- func LateInitializeSpec(spec *v1alpha1.TopicParameters, in *arv1.TopicDetail) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenerateBrokers ¶
func GenerateBrokers(in *arv1.ReplicaAssignmentBrokers) *v1alpha1.ReplicaAssignmentBrokers
GenerateBrokers generates *v1alpha1.ReplicaAssignmentBrokers from *arv1.ReplicaAssignmentBrokers
func GenerateConfigUpdate ¶
func GenerateConfigUpdate(in []v1alpha1.ConfigCreate) []arv1.ConfigUpdate
GenerateConfigUpdate generates []arv1.ConfigUpdate from []v1alpha1.ConfigCreate
func GenerateCreateTopicOptions ¶
func GenerateCreateTopicOptions(in v1alpha1.TopicParameters, o *arv1.CreateTopicOptions) error
GenerateCreateTopicOptions produces CreateTopicOptions object from TopicParameters object.
func GenerateObservation ¶
func GenerateObservation(in *arv1.TopicDetail) (v1alpha1.TopicObservation, error)
GenerateObservation produces TopicObservation object from *arv1.TopicDetail object.
func GenerateReplicaAssignments ¶
func GenerateReplicaAssignments(in []arv1.ReplicaAssignment) []v1alpha1.ReplicaAssignment
GenerateReplicaAssignments generates []v1alpha1.ReplicaAssignment from []arv1.ReplicaAssignment
func GenerateTopicParameters ¶
func GenerateTopicParameters(in *arv1.TopicDetail) (*v1alpha1.TopicParameters, error)
GenerateTopicParameters generates *v1alpha1.TopicParameters from *arv1.TopicDetail
func GenerateUpdateTopicOptions ¶
func GenerateUpdateTopicOptions(currentPartitions *int64, in v1alpha1.TopicParameters, o *arv1.UpdateTopicOptions) error
GenerateUpdateTopicOptions produces UpdateTopicOptions object from TopicParameters object.
func Generatearv1ConfigCreate ¶
func Generatearv1ConfigCreate(in []v1alpha1.ConfigCreate) []arv1.ConfigCreate
Generatearv1ConfigCreate generates []arv1.ConfigCreate from []v1alpha1.ConfigCreate
func Generatev1alpha1ConfigCreate ¶
func Generatev1alpha1ConfigCreate(in *arv1.TopicConfigs) []v1alpha1.ConfigCreate
Generatev1alpha1ConfigCreate generates []v1alpha1.ConfigCreate from *arv1.TopicConfigs
func Generatev1alpha1ConfigCreateLateInitializeSpec ¶
func Generatev1alpha1ConfigCreateLateInitializeSpec(specConfigs []v1alpha1.ConfigCreate, in *arv1.TopicConfigs) []v1alpha1.ConfigCreate
Generatev1alpha1ConfigCreateLateInitializeSpec generates []v1alpha1.ConfigCreate from *arv1.TopicConfigs, only adding configs that aren't already in specConfigs
func Generatev1alpha1TopicConfigs ¶
func Generatev1alpha1TopicConfigs(in *arv1.TopicConfigs) *v1alpha1.TopicConfigs
Generatev1alpha1TopicConfigs generates *v1alpha1.TopicConfigs from *arv1.TopicConfigs
func IsUpToDate ¶
func IsUpToDate(in *v1alpha1.TopicParameters, observed *arv1.TopicDetail, l logging.Logger) (bool, error)
IsUpToDate checks whether current state is up-to-date compared to the given set of parameters.
func LateInitializeSpec ¶
func LateInitializeSpec(spec *v1alpha1.TopicParameters, in *arv1.TopicDetail) error
LateInitializeSpec fills optional and unassigned fields with the values in *arv1.TopicDetail object.
Types ¶
This section is empty.
Source Files