services/google/logging/log_metric_internal.go (2,704 lines of code) (raw):
// Copyright 2025 Google LLC. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package logging
import (
"bytes"
"context"
"encoding/json"
"fmt"
"io/ioutil"
"strings"
"github.com/GoogleCloudPlatform/declarative-resource-client-library/dcl"
)
func (r *LogMetric) validate() error {
if err := dcl.Required(r, "name"); err != nil {
return err
}
if err := dcl.Required(r, "filter"); err != nil {
return err
}
if err := dcl.RequiredParameter(r.Project, "Project"); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(r.MetricDescriptor) {
if err := r.MetricDescriptor.validate(); err != nil {
return err
}
}
if !dcl.IsEmptyValueIndirect(r.BucketOptions) {
if err := r.BucketOptions.validate(); err != nil {
return err
}
}
return nil
}
func (r *LogMetricMetricDescriptor) validate() error {
if !dcl.IsEmptyValueIndirect(r.Metadata) {
if err := r.Metadata.validate(); err != nil {
return err
}
}
return nil
}
func (r *LogMetricMetricDescriptorLabels) validate() error {
return nil
}
func (r *LogMetricMetricDescriptorMetadata) validate() error {
return nil
}
func (r *LogMetricBucketOptions) validate() error {
if err := dcl.ValidateAtMostOneOfFieldsSet([]string{"LinearBuckets", "ExponentialBuckets", "ExplicitBuckets"}, r.LinearBuckets, r.ExponentialBuckets, r.ExplicitBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(r.LinearBuckets) {
if err := r.LinearBuckets.validate(); err != nil {
return err
}
}
if !dcl.IsEmptyValueIndirect(r.ExponentialBuckets) {
if err := r.ExponentialBuckets.validate(); err != nil {
return err
}
}
if !dcl.IsEmptyValueIndirect(r.ExplicitBuckets) {
if err := r.ExplicitBuckets.validate(); err != nil {
return err
}
}
return nil
}
func (r *LogMetricBucketOptionsLinearBuckets) validate() error {
return nil
}
func (r *LogMetricBucketOptionsExponentialBuckets) validate() error {
return nil
}
func (r *LogMetricBucketOptionsExplicitBuckets) validate() error {
return nil
}
func (r *LogMetric) basePath() string {
params := map[string]interface{}{}
return dcl.Nprintf("https://logging.googleapis.com/v2/", params)
}
func (r *LogMetric) getURL(userBasePath string) (string, error) {
nr := r.urlNormalized()
params := map[string]interface{}{
"project": dcl.ValueOrEmptyString(nr.Project),
"name": dcl.ValueOrEmptyString(nr.Name),
}
return dcl.URL("projects/{{project}}/metrics/{{name}}", nr.basePath(), userBasePath, params), nil
}
func (r *LogMetric) listURL(userBasePath string) (string, error) {
nr := r.urlNormalized()
params := map[string]interface{}{
"project": dcl.ValueOrEmptyString(nr.Project),
}
return dcl.URL("projects/{{project}}/metrics", nr.basePath(), userBasePath, params), nil
}
func (r *LogMetric) createURL(userBasePath string) (string, error) {
nr := r.urlNormalized()
params := map[string]interface{}{
"project": dcl.ValueOrEmptyString(nr.Project),
}
return dcl.URL("projects/{{project}}/metrics", nr.basePath(), userBasePath, params), nil
}
func (r *LogMetric) deleteURL(userBasePath string) (string, error) {
nr := r.urlNormalized()
params := map[string]interface{}{
"project": dcl.ValueOrEmptyString(nr.Project),
"name": dcl.ValueOrEmptyString(nr.Name),
}
return dcl.URL("projects/{{project}}/metrics/{{name}}", nr.basePath(), userBasePath, params), nil
}
// logMetricApiOperation represents a mutable operation in the underlying REST
// API such as Create, Update, or Delete.
type logMetricApiOperation interface {
do(context.Context, *LogMetric, *Client) error
}
// newUpdateLogMetricUpdateRequest creates a request for an
// LogMetric resource's update update type by filling in the update
// fields based on the intended state of the resource.
func newUpdateLogMetricUpdateRequest(ctx context.Context, f *LogMetric, c *Client) (map[string]interface{}, error) {
req := map[string]interface{}{}
res := f
_ = res
if v := f.Description; !dcl.IsEmptyValueIndirect(v) {
req["description"] = v
}
if v := f.Filter; !dcl.IsEmptyValueIndirect(v) {
req["filter"] = v
}
if v := f.Disabled; !dcl.IsEmptyValueIndirect(v) {
req["disabled"] = v
}
if v, err := expandLogMetricMetricDescriptor(c, f.MetricDescriptor, res); err != nil {
return nil, fmt.Errorf("error expanding MetricDescriptor into metricDescriptor: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
req["metricDescriptor"] = v
}
if v := f.ValueExtractor; !dcl.IsEmptyValueIndirect(v) {
req["valueExtractor"] = v
}
if v := f.LabelExtractors; !dcl.IsEmptyValueIndirect(v) {
req["labelExtractors"] = v
}
if v, err := expandLogMetricBucketOptions(c, f.BucketOptions, res); err != nil {
return nil, fmt.Errorf("error expanding BucketOptions into bucketOptions: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
req["bucketOptions"] = v
}
return req, nil
}
// marshalUpdateLogMetricUpdateRequest converts the update into
// the final JSON request body.
func marshalUpdateLogMetricUpdateRequest(c *Client, m map[string]interface{}) ([]byte, error) {
return json.Marshal(m)
}
type updateLogMetricUpdateOperation struct {
// If the update operation has the REQUIRES_APPLY_OPTIONS trait, this will be populated.
// Usually it will be nil - this is to prevent us from accidentally depending on apply
// options, which should usually be unnecessary.
ApplyOptions []dcl.ApplyOption
FieldDiffs []*dcl.FieldDiff
}
// do creates a request and sends it to the appropriate URL. In most operations,
// do will transcribe a subset of the resource into a request object and send a
// PUT request to a single URL.
func (op *updateLogMetricUpdateOperation) do(ctx context.Context, r *LogMetric, c *Client) error {
_, err := c.GetLogMetric(ctx, r)
if err != nil {
return err
}
u, err := r.updateURL(c.Config.BasePath, "update")
if err != nil {
return err
}
req, err := newUpdateLogMetricUpdateRequest(ctx, r, c)
if err != nil {
return err
}
c.Config.Logger.InfoWithContextf(ctx, "Created update: %#v", req)
body, err := marshalUpdateLogMetricUpdateRequest(c, req)
if err != nil {
return err
}
_, err = dcl.SendRequest(ctx, c.Config, "PUT", u, bytes.NewBuffer(body), c.Config.RetryProvider)
if err != nil {
return err
}
return nil
}
func (c *Client) listLogMetricRaw(ctx context.Context, r *LogMetric, pageToken string, pageSize int32) ([]byte, error) {
u, err := r.urlNormalized().listURL(c.Config.BasePath)
if err != nil {
return nil, err
}
m := make(map[string]string)
if pageToken != "" {
m["pageToken"] = pageToken
}
if pageSize != LogMetricMaxPage {
m["pageSize"] = fmt.Sprintf("%v", pageSize)
}
u, err = dcl.AddQueryParams(u, m)
if err != nil {
return nil, err
}
resp, err := dcl.SendRequest(ctx, c.Config, "GET", u, &bytes.Buffer{}, c.Config.RetryProvider)
if err != nil {
return nil, err
}
defer resp.Response.Body.Close()
return ioutil.ReadAll(resp.Response.Body)
}
type listLogMetricOperation struct {
Metrics []map[string]interface{} `json:"metrics"`
Token string `json:"nextPageToken"`
}
func (c *Client) listLogMetric(ctx context.Context, r *LogMetric, pageToken string, pageSize int32) ([]*LogMetric, string, error) {
b, err := c.listLogMetricRaw(ctx, r, pageToken, pageSize)
if err != nil {
return nil, "", err
}
var m listLogMetricOperation
if err := json.Unmarshal(b, &m); err != nil {
return nil, "", err
}
var l []*LogMetric
for _, v := range m.Metrics {
res, err := unmarshalMapLogMetric(v, c, r)
if err != nil {
return nil, m.Token, err
}
res.Project = r.Project
l = append(l, res)
}
return l, m.Token, nil
}
func (c *Client) deleteAllLogMetric(ctx context.Context, f func(*LogMetric) bool, resources []*LogMetric) error {
var errors []string
for _, res := range resources {
if f(res) {
// We do not want deleteAll to fail on a deletion or else it will stop deleting other resources.
err := c.DeleteLogMetric(ctx, res)
if err != nil {
errors = append(errors, err.Error())
}
}
}
if len(errors) > 0 {
return fmt.Errorf("%v", strings.Join(errors, "\n"))
} else {
return nil
}
}
type deleteLogMetricOperation struct{}
func (op *deleteLogMetricOperation) do(ctx context.Context, r *LogMetric, c *Client) error {
r, err := c.GetLogMetric(ctx, r)
if err != nil {
if dcl.IsNotFound(err) {
c.Config.Logger.InfoWithContextf(ctx, "LogMetric not found, returning. Original error: %v", err)
return nil
}
c.Config.Logger.WarningWithContextf(ctx, "GetLogMetric checking for existence. error: %v", err)
return err
}
u, err := r.deleteURL(c.Config.BasePath)
if err != nil {
return err
}
// Delete should never have a body
body := &bytes.Buffer{}
_, err = dcl.SendRequest(ctx, c.Config, "DELETE", u, body, c.Config.RetryProvider)
if err != nil {
return fmt.Errorf("failed to delete LogMetric: %w", err)
}
// We saw a race condition where for some successful delete operation, the Get calls returned resources for a short duration.
// This is the reason we are adding retry to handle that case.
retriesRemaining := 10
dcl.Do(ctx, func(ctx context.Context) (*dcl.RetryDetails, error) {
_, err := c.GetLogMetric(ctx, r)
if dcl.IsNotFound(err) {
return nil, nil
}
if retriesRemaining > 0 {
retriesRemaining--
return &dcl.RetryDetails{}, dcl.OperationNotDone{}
}
return nil, dcl.NotDeletedError{ExistingResource: r}
}, c.Config.RetryProvider)
return nil
}
// Create operations are similar to Update operations, although they do not have
// specific request objects. The Create request object is the json encoding of
// the resource, which is modified by res.marshal to form the base request body.
type createLogMetricOperation struct {
response map[string]interface{}
}
func (op *createLogMetricOperation) FirstResponse() (map[string]interface{}, bool) {
return op.response, len(op.response) > 0
}
func (op *createLogMetricOperation) do(ctx context.Context, r *LogMetric, c *Client) error {
c.Config.Logger.InfoWithContextf(ctx, "Attempting to create %v", r)
u, err := r.createURL(c.Config.BasePath)
if err != nil {
return err
}
req, err := r.marshal(c)
if err != nil {
return err
}
resp, err := dcl.SendRequest(ctx, c.Config, "POST", u, bytes.NewBuffer(req), c.Config.RetryProvider)
if err != nil {
return err
}
o, err := dcl.ResponseBodyAsJSON(resp)
if err != nil {
return fmt.Errorf("error decoding response body into JSON: %w", err)
}
op.response = o
if _, err := c.GetLogMetric(ctx, r); err != nil {
c.Config.Logger.WarningWithContextf(ctx, "get returned error: %v", err)
return err
}
return nil
}
func (c *Client) getLogMetricRaw(ctx context.Context, r *LogMetric) ([]byte, error) {
u, err := r.getURL(c.Config.BasePath)
if err != nil {
return nil, err
}
resp, err := dcl.SendRequest(ctx, c.Config, "GET", u, &bytes.Buffer{}, c.Config.RetryProvider)
if err != nil {
return nil, err
}
defer resp.Response.Body.Close()
b, err := ioutil.ReadAll(resp.Response.Body)
if err != nil {
return nil, err
}
return b, nil
}
func (c *Client) logMetricDiffsForRawDesired(ctx context.Context, rawDesired *LogMetric, opts ...dcl.ApplyOption) (initial, desired *LogMetric, diffs []*dcl.FieldDiff, err error) {
c.Config.Logger.InfoWithContext(ctx, "Fetching initial state...")
// First, let us see if the user provided a state hint. If they did, we will start fetching based on that.
var fetchState *LogMetric
if sh := dcl.FetchStateHint(opts); sh != nil {
if r, ok := sh.(*LogMetric); !ok {
c.Config.Logger.WarningWithContextf(ctx, "Initial state hint was of the wrong type; expected LogMetric, got %T", sh)
} else {
fetchState = r
}
}
if fetchState == nil {
fetchState = rawDesired
}
// 1.2: Retrieval of raw initial state from API
rawInitial, err := c.GetLogMetric(ctx, fetchState)
if rawInitial == nil {
if !dcl.IsNotFound(err) {
c.Config.Logger.WarningWithContextf(ctx, "Failed to retrieve whether a LogMetric resource already exists: %s", err)
return nil, nil, nil, fmt.Errorf("failed to retrieve LogMetric resource: %v", err)
}
c.Config.Logger.InfoWithContext(ctx, "Found that LogMetric resource did not exist.")
// Perform canonicalization to pick up defaults.
desired, err = canonicalizeLogMetricDesiredState(rawDesired, rawInitial)
return nil, desired, nil, err
}
c.Config.Logger.InfoWithContextf(ctx, "Found initial state for LogMetric: %v", rawInitial)
c.Config.Logger.InfoWithContextf(ctx, "Initial desired state for LogMetric: %v", rawDesired)
// The Get call applies postReadExtract and so the result may contain fields that are not part of API version.
if err := extractLogMetricFields(rawInitial); err != nil {
return nil, nil, nil, err
}
// 1.3: Canonicalize raw initial state into initial state.
initial, err = canonicalizeLogMetricInitialState(rawInitial, rawDesired)
if err != nil {
return nil, nil, nil, err
}
c.Config.Logger.InfoWithContextf(ctx, "Canonicalized initial state for LogMetric: %v", initial)
// 1.4: Canonicalize raw desired state into desired state.
desired, err = canonicalizeLogMetricDesiredState(rawDesired, rawInitial, opts...)
if err != nil {
return nil, nil, nil, err
}
c.Config.Logger.InfoWithContextf(ctx, "Canonicalized desired state for LogMetric: %v", desired)
// 2.1: Comparison of initial and desired state.
diffs, err = diffLogMetric(c, desired, initial, opts...)
return initial, desired, diffs, err
}
func canonicalizeLogMetricInitialState(rawInitial, rawDesired *LogMetric) (*LogMetric, error) {
// TODO(magic-modules-eng): write canonicalizer once relevant traits are added.
return rawInitial, nil
}
/*
* Canonicalizers
*
* These are responsible for converting either a user-specified config or a
* GCP API response to a standard format that can be used for difference checking.
* */
func canonicalizeLogMetricDesiredState(rawDesired, rawInitial *LogMetric, opts ...dcl.ApplyOption) (*LogMetric, error) {
if rawInitial == nil {
// Since the initial state is empty, the desired state is all we have.
// We canonicalize the remaining nested objects with nil to pick up defaults.
rawDesired.MetricDescriptor = canonicalizeLogMetricMetricDescriptor(rawDesired.MetricDescriptor, nil, opts...)
rawDesired.BucketOptions = canonicalizeLogMetricBucketOptions(rawDesired.BucketOptions, nil, opts...)
return rawDesired, nil
}
canonicalDesired := &LogMetric{}
if dcl.StringCanonicalize(rawDesired.Name, rawInitial.Name) {
canonicalDesired.Name = rawInitial.Name
} else {
canonicalDesired.Name = rawDesired.Name
}
if dcl.StringCanonicalize(rawDesired.Description, rawInitial.Description) {
canonicalDesired.Description = rawInitial.Description
} else {
canonicalDesired.Description = rawDesired.Description
}
if dcl.StringCanonicalize(rawDesired.Filter, rawInitial.Filter) {
canonicalDesired.Filter = rawInitial.Filter
} else {
canonicalDesired.Filter = rawDesired.Filter
}
if dcl.BoolCanonicalize(rawDesired.Disabled, rawInitial.Disabled) {
canonicalDesired.Disabled = rawInitial.Disabled
} else {
canonicalDesired.Disabled = rawDesired.Disabled
}
canonicalDesired.MetricDescriptor = canonicalizeLogMetricMetricDescriptor(rawDesired.MetricDescriptor, rawInitial.MetricDescriptor, opts...)
if dcl.StringCanonicalize(rawDesired.ValueExtractor, rawInitial.ValueExtractor) {
canonicalDesired.ValueExtractor = rawInitial.ValueExtractor
} else {
canonicalDesired.ValueExtractor = rawDesired.ValueExtractor
}
if dcl.IsZeroValue(rawDesired.LabelExtractors) || (dcl.IsEmptyValueIndirect(rawDesired.LabelExtractors) && dcl.IsEmptyValueIndirect(rawInitial.LabelExtractors)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
canonicalDesired.LabelExtractors = rawInitial.LabelExtractors
} else {
canonicalDesired.LabelExtractors = rawDesired.LabelExtractors
}
canonicalDesired.BucketOptions = canonicalizeLogMetricBucketOptions(rawDesired.BucketOptions, rawInitial.BucketOptions, opts...)
if dcl.NameToSelfLink(rawDesired.Project, rawInitial.Project) {
canonicalDesired.Project = rawInitial.Project
} else {
canonicalDesired.Project = rawDesired.Project
}
return canonicalDesired, nil
}
func canonicalizeLogMetricNewState(c *Client, rawNew, rawDesired *LogMetric) (*LogMetric, error) {
if dcl.IsEmptyValueIndirect(rawNew.Name) && dcl.IsEmptyValueIndirect(rawDesired.Name) {
rawNew.Name = rawDesired.Name
} else {
if dcl.StringCanonicalize(rawDesired.Name, rawNew.Name) {
rawNew.Name = rawDesired.Name
}
}
if dcl.IsEmptyValueIndirect(rawNew.Description) && dcl.IsEmptyValueIndirect(rawDesired.Description) {
rawNew.Description = rawDesired.Description
} else {
if dcl.StringCanonicalize(rawDesired.Description, rawNew.Description) {
rawNew.Description = rawDesired.Description
}
}
if dcl.IsEmptyValueIndirect(rawNew.Filter) && dcl.IsEmptyValueIndirect(rawDesired.Filter) {
rawNew.Filter = rawDesired.Filter
} else {
if dcl.StringCanonicalize(rawDesired.Filter, rawNew.Filter) {
rawNew.Filter = rawDesired.Filter
}
}
if dcl.IsEmptyValueIndirect(rawNew.Disabled) && dcl.IsEmptyValueIndirect(rawDesired.Disabled) {
rawNew.Disabled = rawDesired.Disabled
} else {
if dcl.BoolCanonicalize(rawDesired.Disabled, rawNew.Disabled) {
rawNew.Disabled = rawDesired.Disabled
}
}
if dcl.IsEmptyValueIndirect(rawNew.MetricDescriptor) && dcl.IsEmptyValueIndirect(rawDesired.MetricDescriptor) {
rawNew.MetricDescriptor = rawDesired.MetricDescriptor
} else {
rawNew.MetricDescriptor = canonicalizeNewLogMetricMetricDescriptor(c, rawDesired.MetricDescriptor, rawNew.MetricDescriptor)
}
if dcl.IsEmptyValueIndirect(rawNew.ValueExtractor) && dcl.IsEmptyValueIndirect(rawDesired.ValueExtractor) {
rawNew.ValueExtractor = rawDesired.ValueExtractor
} else {
if dcl.StringCanonicalize(rawDesired.ValueExtractor, rawNew.ValueExtractor) {
rawNew.ValueExtractor = rawDesired.ValueExtractor
}
}
if dcl.IsEmptyValueIndirect(rawNew.LabelExtractors) && dcl.IsEmptyValueIndirect(rawDesired.LabelExtractors) {
rawNew.LabelExtractors = rawDesired.LabelExtractors
} else {
}
if dcl.IsEmptyValueIndirect(rawNew.BucketOptions) && dcl.IsEmptyValueIndirect(rawDesired.BucketOptions) {
rawNew.BucketOptions = rawDesired.BucketOptions
} else {
rawNew.BucketOptions = canonicalizeNewLogMetricBucketOptions(c, rawDesired.BucketOptions, rawNew.BucketOptions)
}
if dcl.IsEmptyValueIndirect(rawNew.CreateTime) && dcl.IsEmptyValueIndirect(rawDesired.CreateTime) {
rawNew.CreateTime = rawDesired.CreateTime
} else {
}
if dcl.IsEmptyValueIndirect(rawNew.UpdateTime) && dcl.IsEmptyValueIndirect(rawDesired.UpdateTime) {
rawNew.UpdateTime = rawDesired.UpdateTime
} else {
}
rawNew.Project = rawDesired.Project
return rawNew, nil
}
func canonicalizeLogMetricMetricDescriptor(des, initial *LogMetricMetricDescriptor, opts ...dcl.ApplyOption) *LogMetricMetricDescriptor {
if des == nil {
return initial
}
if des.empty {
return des
}
if initial == nil {
return des
}
cDes := &LogMetricMetricDescriptor{}
cDes.Labels = canonicalizeLogMetricMetricDescriptorLabelsSlice(des.Labels, initial.Labels, opts...)
if dcl.IsZeroValue(des.MetricKind) || (dcl.IsEmptyValueIndirect(des.MetricKind) && dcl.IsEmptyValueIndirect(initial.MetricKind)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.MetricKind = initial.MetricKind
} else {
cDes.MetricKind = des.MetricKind
}
if canonicalizeLogMetricMetricDescriptorValueType(des.ValueType, initial.ValueType) || dcl.IsZeroValue(des.ValueType) {
cDes.ValueType = initial.ValueType
} else {
cDes.ValueType = des.ValueType
}
if dcl.StringCanonicalize(des.Unit, initial.Unit) || dcl.IsZeroValue(des.Unit) {
cDes.Unit = initial.Unit
} else {
cDes.Unit = des.Unit
}
if dcl.StringCanonicalize(des.DisplayName, initial.DisplayName) || dcl.IsZeroValue(des.DisplayName) {
cDes.DisplayName = initial.DisplayName
} else {
cDes.DisplayName = des.DisplayName
}
cDes.Metadata = canonicalizeLogMetricMetricDescriptorMetadata(des.Metadata, initial.Metadata, opts...)
if dcl.IsZeroValue(des.LaunchStage) || (dcl.IsEmptyValueIndirect(des.LaunchStage) && dcl.IsEmptyValueIndirect(initial.LaunchStage)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.LaunchStage = initial.LaunchStage
} else {
cDes.LaunchStage = des.LaunchStage
}
return cDes
}
func canonicalizeLogMetricMetricDescriptorSlice(des, initial []LogMetricMetricDescriptor, opts ...dcl.ApplyOption) []LogMetricMetricDescriptor {
if dcl.IsEmptyValueIndirect(des) {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricMetricDescriptor, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricMetricDescriptor(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricMetricDescriptor, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricMetricDescriptor(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricMetricDescriptor(c *Client, des, nw *LogMetricMetricDescriptor) *LogMetricMetricDescriptor {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricMetricDescriptor while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
if dcl.StringCanonicalize(des.Name, nw.Name) {
nw.Name = des.Name
}
if dcl.StringCanonicalize(des.Type, nw.Type) {
nw.Type = des.Type
}
nw.Labels = canonicalizeNewLogMetricMetricDescriptorLabelsSet(c, des.Labels, nw.Labels)
if canonicalizeLogMetricMetricDescriptorValueType(des.ValueType, nw.ValueType) {
nw.ValueType = des.ValueType
}
if dcl.StringCanonicalize(des.Unit, nw.Unit) {
nw.Unit = des.Unit
}
if dcl.StringCanonicalize(des.Description, nw.Description) {
nw.Description = des.Description
}
if dcl.StringCanonicalize(des.DisplayName, nw.DisplayName) {
nw.DisplayName = des.DisplayName
}
nw.Metadata = des.Metadata
nw.LaunchStage = des.LaunchStage
if dcl.StringArrayCanonicalize(des.MonitoredResourceTypes, nw.MonitoredResourceTypes) {
nw.MonitoredResourceTypes = des.MonitoredResourceTypes
}
return nw
}
func canonicalizeNewLogMetricMetricDescriptorSet(c *Client, des, nw []LogMetricMetricDescriptor) []LogMetricMetricDescriptor {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricMetricDescriptor
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricMetricDescriptorNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricMetricDescriptor(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricMetricDescriptorSlice(c *Client, des, nw []LogMetricMetricDescriptor) []LogMetricMetricDescriptor {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricMetricDescriptor
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricMetricDescriptor(c, &d, &n))
}
return items
}
func canonicalizeLogMetricMetricDescriptorLabels(des, initial *LogMetricMetricDescriptorLabels, opts ...dcl.ApplyOption) *LogMetricMetricDescriptorLabels {
if des == nil {
return initial
}
if des.empty {
return des
}
if initial == nil {
return des
}
cDes := &LogMetricMetricDescriptorLabels{}
if dcl.StringCanonicalize(des.Key, initial.Key) || dcl.IsZeroValue(des.Key) {
cDes.Key = initial.Key
} else {
cDes.Key = des.Key
}
if canonicalizeLogMetricMetricDescriptorLabelsValueType(des.ValueType, initial.ValueType) || dcl.IsZeroValue(des.ValueType) {
cDes.ValueType = initial.ValueType
} else {
cDes.ValueType = des.ValueType
}
if dcl.StringCanonicalize(des.Description, initial.Description) || dcl.IsZeroValue(des.Description) {
cDes.Description = initial.Description
} else {
cDes.Description = des.Description
}
return cDes
}
func canonicalizeLogMetricMetricDescriptorLabelsSlice(des, initial []LogMetricMetricDescriptorLabels, opts ...dcl.ApplyOption) []LogMetricMetricDescriptorLabels {
if des == nil {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricMetricDescriptorLabels, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricMetricDescriptorLabels(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricMetricDescriptorLabels, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricMetricDescriptorLabels(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricMetricDescriptorLabels(c *Client, des, nw *LogMetricMetricDescriptorLabels) *LogMetricMetricDescriptorLabels {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricMetricDescriptorLabels while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
if dcl.StringCanonicalize(des.Key, nw.Key) {
nw.Key = des.Key
}
if canonicalizeLogMetricMetricDescriptorLabelsValueType(des.ValueType, nw.ValueType) {
nw.ValueType = des.ValueType
}
if dcl.StringCanonicalize(des.Description, nw.Description) {
nw.Description = des.Description
}
return nw
}
func canonicalizeNewLogMetricMetricDescriptorLabelsSet(c *Client, des, nw []LogMetricMetricDescriptorLabels) []LogMetricMetricDescriptorLabels {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricMetricDescriptorLabels
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricMetricDescriptorLabelsNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricMetricDescriptorLabels(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricMetricDescriptorLabelsSlice(c *Client, des, nw []LogMetricMetricDescriptorLabels) []LogMetricMetricDescriptorLabels {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricMetricDescriptorLabels
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricMetricDescriptorLabels(c, &d, &n))
}
return items
}
func canonicalizeLogMetricMetricDescriptorMetadata(des, initial *LogMetricMetricDescriptorMetadata, opts ...dcl.ApplyOption) *LogMetricMetricDescriptorMetadata {
if des == nil {
return initial
}
if des.empty {
return des
}
if initial == nil {
return des
}
cDes := &LogMetricMetricDescriptorMetadata{}
if dcl.StringCanonicalize(des.SamplePeriod, initial.SamplePeriod) || dcl.IsZeroValue(des.SamplePeriod) {
cDes.SamplePeriod = initial.SamplePeriod
} else {
cDes.SamplePeriod = des.SamplePeriod
}
if dcl.StringCanonicalize(des.IngestDelay, initial.IngestDelay) || dcl.IsZeroValue(des.IngestDelay) {
cDes.IngestDelay = initial.IngestDelay
} else {
cDes.IngestDelay = des.IngestDelay
}
return cDes
}
func canonicalizeLogMetricMetricDescriptorMetadataSlice(des, initial []LogMetricMetricDescriptorMetadata, opts ...dcl.ApplyOption) []LogMetricMetricDescriptorMetadata {
if dcl.IsEmptyValueIndirect(des) {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricMetricDescriptorMetadata, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricMetricDescriptorMetadata(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricMetricDescriptorMetadata, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricMetricDescriptorMetadata(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricMetricDescriptorMetadata(c *Client, des, nw *LogMetricMetricDescriptorMetadata) *LogMetricMetricDescriptorMetadata {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricMetricDescriptorMetadata while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
if dcl.StringCanonicalize(des.SamplePeriod, nw.SamplePeriod) {
nw.SamplePeriod = des.SamplePeriod
}
if dcl.StringCanonicalize(des.IngestDelay, nw.IngestDelay) {
nw.IngestDelay = des.IngestDelay
}
return nw
}
func canonicalizeNewLogMetricMetricDescriptorMetadataSet(c *Client, des, nw []LogMetricMetricDescriptorMetadata) []LogMetricMetricDescriptorMetadata {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricMetricDescriptorMetadata
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricMetricDescriptorMetadataNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricMetricDescriptorMetadata(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricMetricDescriptorMetadataSlice(c *Client, des, nw []LogMetricMetricDescriptorMetadata) []LogMetricMetricDescriptorMetadata {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricMetricDescriptorMetadata
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricMetricDescriptorMetadata(c, &d, &n))
}
return items
}
func canonicalizeLogMetricBucketOptions(des, initial *LogMetricBucketOptions, opts ...dcl.ApplyOption) *LogMetricBucketOptions {
if des == nil {
return initial
}
if des.empty {
return des
}
if des.LinearBuckets != nil || (initial != nil && initial.LinearBuckets != nil) {
// Check if anything else is set.
if dcl.AnySet(des.ExponentialBuckets, des.ExplicitBuckets) {
des.LinearBuckets = nil
if initial != nil {
initial.LinearBuckets = nil
}
}
}
if des.ExponentialBuckets != nil || (initial != nil && initial.ExponentialBuckets != nil) {
// Check if anything else is set.
if dcl.AnySet(des.LinearBuckets, des.ExplicitBuckets) {
des.ExponentialBuckets = nil
if initial != nil {
initial.ExponentialBuckets = nil
}
}
}
if des.ExplicitBuckets != nil || (initial != nil && initial.ExplicitBuckets != nil) {
// Check if anything else is set.
if dcl.AnySet(des.LinearBuckets, des.ExponentialBuckets) {
des.ExplicitBuckets = nil
if initial != nil {
initial.ExplicitBuckets = nil
}
}
}
if initial == nil {
return des
}
cDes := &LogMetricBucketOptions{}
cDes.LinearBuckets = canonicalizeLogMetricBucketOptionsLinearBuckets(des.LinearBuckets, initial.LinearBuckets, opts...)
cDes.ExponentialBuckets = canonicalizeLogMetricBucketOptionsExponentialBuckets(des.ExponentialBuckets, initial.ExponentialBuckets, opts...)
cDes.ExplicitBuckets = canonicalizeLogMetricBucketOptionsExplicitBuckets(des.ExplicitBuckets, initial.ExplicitBuckets, opts...)
return cDes
}
func canonicalizeLogMetricBucketOptionsSlice(des, initial []LogMetricBucketOptions, opts ...dcl.ApplyOption) []LogMetricBucketOptions {
if dcl.IsEmptyValueIndirect(des) {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricBucketOptions, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricBucketOptions(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricBucketOptions, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricBucketOptions(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricBucketOptions(c *Client, des, nw *LogMetricBucketOptions) *LogMetricBucketOptions {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricBucketOptions while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
nw.LinearBuckets = canonicalizeNewLogMetricBucketOptionsLinearBuckets(c, des.LinearBuckets, nw.LinearBuckets)
nw.ExponentialBuckets = canonicalizeNewLogMetricBucketOptionsExponentialBuckets(c, des.ExponentialBuckets, nw.ExponentialBuckets)
nw.ExplicitBuckets = canonicalizeNewLogMetricBucketOptionsExplicitBuckets(c, des.ExplicitBuckets, nw.ExplicitBuckets)
return nw
}
func canonicalizeNewLogMetricBucketOptionsSet(c *Client, des, nw []LogMetricBucketOptions) []LogMetricBucketOptions {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricBucketOptions
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricBucketOptionsNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricBucketOptions(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricBucketOptionsSlice(c *Client, des, nw []LogMetricBucketOptions) []LogMetricBucketOptions {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricBucketOptions
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricBucketOptions(c, &d, &n))
}
return items
}
func canonicalizeLogMetricBucketOptionsLinearBuckets(des, initial *LogMetricBucketOptionsLinearBuckets, opts ...dcl.ApplyOption) *LogMetricBucketOptionsLinearBuckets {
if des == nil {
return initial
}
if des.empty {
return des
}
if initial == nil {
return des
}
cDes := &LogMetricBucketOptionsLinearBuckets{}
if dcl.IsZeroValue(des.NumFiniteBuckets) || (dcl.IsEmptyValueIndirect(des.NumFiniteBuckets) && dcl.IsEmptyValueIndirect(initial.NumFiniteBuckets)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.NumFiniteBuckets = initial.NumFiniteBuckets
} else {
cDes.NumFiniteBuckets = des.NumFiniteBuckets
}
if dcl.IsZeroValue(des.Width) || (dcl.IsEmptyValueIndirect(des.Width) && dcl.IsEmptyValueIndirect(initial.Width)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.Width = initial.Width
} else {
cDes.Width = des.Width
}
if dcl.IsZeroValue(des.Offset) || (dcl.IsEmptyValueIndirect(des.Offset) && dcl.IsEmptyValueIndirect(initial.Offset)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.Offset = initial.Offset
} else {
cDes.Offset = des.Offset
}
return cDes
}
func canonicalizeLogMetricBucketOptionsLinearBucketsSlice(des, initial []LogMetricBucketOptionsLinearBuckets, opts ...dcl.ApplyOption) []LogMetricBucketOptionsLinearBuckets {
if dcl.IsEmptyValueIndirect(des) {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricBucketOptionsLinearBuckets, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricBucketOptionsLinearBuckets(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricBucketOptionsLinearBuckets, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricBucketOptionsLinearBuckets(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricBucketOptionsLinearBuckets(c *Client, des, nw *LogMetricBucketOptionsLinearBuckets) *LogMetricBucketOptionsLinearBuckets {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricBucketOptionsLinearBuckets while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
return nw
}
func canonicalizeNewLogMetricBucketOptionsLinearBucketsSet(c *Client, des, nw []LogMetricBucketOptionsLinearBuckets) []LogMetricBucketOptionsLinearBuckets {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricBucketOptionsLinearBuckets
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricBucketOptionsLinearBucketsNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricBucketOptionsLinearBuckets(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricBucketOptionsLinearBucketsSlice(c *Client, des, nw []LogMetricBucketOptionsLinearBuckets) []LogMetricBucketOptionsLinearBuckets {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricBucketOptionsLinearBuckets
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricBucketOptionsLinearBuckets(c, &d, &n))
}
return items
}
func canonicalizeLogMetricBucketOptionsExponentialBuckets(des, initial *LogMetricBucketOptionsExponentialBuckets, opts ...dcl.ApplyOption) *LogMetricBucketOptionsExponentialBuckets {
if des == nil {
return initial
}
if des.empty {
return des
}
if initial == nil {
return des
}
cDes := &LogMetricBucketOptionsExponentialBuckets{}
if dcl.IsZeroValue(des.NumFiniteBuckets) || (dcl.IsEmptyValueIndirect(des.NumFiniteBuckets) && dcl.IsEmptyValueIndirect(initial.NumFiniteBuckets)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.NumFiniteBuckets = initial.NumFiniteBuckets
} else {
cDes.NumFiniteBuckets = des.NumFiniteBuckets
}
if dcl.IsZeroValue(des.GrowthFactor) || (dcl.IsEmptyValueIndirect(des.GrowthFactor) && dcl.IsEmptyValueIndirect(initial.GrowthFactor)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.GrowthFactor = initial.GrowthFactor
} else {
cDes.GrowthFactor = des.GrowthFactor
}
if dcl.IsZeroValue(des.Scale) || (dcl.IsEmptyValueIndirect(des.Scale) && dcl.IsEmptyValueIndirect(initial.Scale)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.Scale = initial.Scale
} else {
cDes.Scale = des.Scale
}
return cDes
}
func canonicalizeLogMetricBucketOptionsExponentialBucketsSlice(des, initial []LogMetricBucketOptionsExponentialBuckets, opts ...dcl.ApplyOption) []LogMetricBucketOptionsExponentialBuckets {
if dcl.IsEmptyValueIndirect(des) {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricBucketOptionsExponentialBuckets, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricBucketOptionsExponentialBuckets(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricBucketOptionsExponentialBuckets, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricBucketOptionsExponentialBuckets(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricBucketOptionsExponentialBuckets(c *Client, des, nw *LogMetricBucketOptionsExponentialBuckets) *LogMetricBucketOptionsExponentialBuckets {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricBucketOptionsExponentialBuckets while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
return nw
}
func canonicalizeNewLogMetricBucketOptionsExponentialBucketsSet(c *Client, des, nw []LogMetricBucketOptionsExponentialBuckets) []LogMetricBucketOptionsExponentialBuckets {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricBucketOptionsExponentialBuckets
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricBucketOptionsExponentialBucketsNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricBucketOptionsExponentialBuckets(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricBucketOptionsExponentialBucketsSlice(c *Client, des, nw []LogMetricBucketOptionsExponentialBuckets) []LogMetricBucketOptionsExponentialBuckets {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricBucketOptionsExponentialBuckets
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricBucketOptionsExponentialBuckets(c, &d, &n))
}
return items
}
func canonicalizeLogMetricBucketOptionsExplicitBuckets(des, initial *LogMetricBucketOptionsExplicitBuckets, opts ...dcl.ApplyOption) *LogMetricBucketOptionsExplicitBuckets {
if des == nil {
return initial
}
if des.empty {
return des
}
if initial == nil {
return des
}
cDes := &LogMetricBucketOptionsExplicitBuckets{}
if dcl.IsZeroValue(des.Bounds) || (dcl.IsEmptyValueIndirect(des.Bounds) && dcl.IsEmptyValueIndirect(initial.Bounds)) {
// Desired and initial values are equivalent, so set canonical desired value to initial value.
cDes.Bounds = initial.Bounds
} else {
cDes.Bounds = des.Bounds
}
return cDes
}
func canonicalizeLogMetricBucketOptionsExplicitBucketsSlice(des, initial []LogMetricBucketOptionsExplicitBuckets, opts ...dcl.ApplyOption) []LogMetricBucketOptionsExplicitBuckets {
if dcl.IsEmptyValueIndirect(des) {
return initial
}
if len(des) != len(initial) {
items := make([]LogMetricBucketOptionsExplicitBuckets, 0, len(des))
for _, d := range des {
cd := canonicalizeLogMetricBucketOptionsExplicitBuckets(&d, nil, opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
items := make([]LogMetricBucketOptionsExplicitBuckets, 0, len(des))
for i, d := range des {
cd := canonicalizeLogMetricBucketOptionsExplicitBuckets(&d, &initial[i], opts...)
if cd != nil {
items = append(items, *cd)
}
}
return items
}
func canonicalizeNewLogMetricBucketOptionsExplicitBuckets(c *Client, des, nw *LogMetricBucketOptionsExplicitBuckets) *LogMetricBucketOptionsExplicitBuckets {
if des == nil {
return nw
}
if nw == nil {
if dcl.IsEmptyValueIndirect(des) {
c.Config.Logger.Info("Found explicitly empty value for LogMetricBucketOptionsExplicitBuckets while comparing non-nil desired to nil actual. Returning desired object.")
return des
}
return nil
}
return nw
}
func canonicalizeNewLogMetricBucketOptionsExplicitBucketsSet(c *Client, des, nw []LogMetricBucketOptionsExplicitBuckets) []LogMetricBucketOptionsExplicitBuckets {
if des == nil {
return nw
}
// Find the elements in des that are also in nw and canonicalize them. Remove matched elements from nw.
var items []LogMetricBucketOptionsExplicitBuckets
for _, d := range des {
matchedIndex := -1
for i, n := range nw {
if diffs, _ := compareLogMetricBucketOptionsExplicitBucketsNewStyle(&d, &n, dcl.FieldName{}); len(diffs) == 0 {
matchedIndex = i
break
}
}
if matchedIndex != -1 {
items = append(items, *canonicalizeNewLogMetricBucketOptionsExplicitBuckets(c, &d, &nw[matchedIndex]))
nw = append(nw[:matchedIndex], nw[matchedIndex+1:]...)
}
}
// Also include elements in nw that are not matched in des.
items = append(items, nw...)
return items
}
func canonicalizeNewLogMetricBucketOptionsExplicitBucketsSlice(c *Client, des, nw []LogMetricBucketOptionsExplicitBuckets) []LogMetricBucketOptionsExplicitBuckets {
if des == nil {
return nw
}
// Lengths are unequal. A diff will occur later, so we shouldn't canonicalize.
// Return the original array.
if len(des) != len(nw) {
return nw
}
var items []LogMetricBucketOptionsExplicitBuckets
for i, d := range des {
n := nw[i]
items = append(items, *canonicalizeNewLogMetricBucketOptionsExplicitBuckets(c, &d, &n))
}
return items
}
// The differ returns a list of diffs, along with a list of operations that should be taken
// to remedy them. Right now, it does not attempt to consolidate operations - if several
// fields can be fixed with a patch update, it will perform the patch several times.
// Diffs on some fields will be ignored if the `desired` state has an empty (nil)
// value. This empty value indicates that the user does not care about the state for
// the field. Empty fields on the actual object will cause diffs.
// TODO(magic-modules-eng): for efficiency in some resources, add batching.
func diffLogMetric(c *Client, desired, actual *LogMetric, opts ...dcl.ApplyOption) ([]*dcl.FieldDiff, error) {
if desired == nil || actual == nil {
return nil, fmt.Errorf("nil resource passed to diff - always a programming error: %#v, %#v", desired, actual)
}
c.Config.Logger.Infof("Diff function called with desired state: %v", desired)
c.Config.Logger.Infof("Diff function called with actual state: %v", actual)
var fn dcl.FieldName
var newDiffs []*dcl.FieldDiff
// New style diffs.
if ds, err := dcl.Diff(desired.Name, actual.Name, dcl.DiffInfo{OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("Name")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.Description, actual.Description, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Description")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.Filter, actual.Filter, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Filter")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.Disabled, actual.Disabled, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Disabled")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.MetricDescriptor, actual.MetricDescriptor, dcl.DiffInfo{ObjectFunction: compareLogMetricMetricDescriptorNewStyle, EmptyObject: EmptyLogMetricMetricDescriptor, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("MetricDescriptor")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.ValueExtractor, actual.ValueExtractor, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("ValueExtractor")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.LabelExtractors, actual.LabelExtractors, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("LabelExtractors")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.BucketOptions, actual.BucketOptions, dcl.DiffInfo{ObjectFunction: compareLogMetricBucketOptionsNewStyle, EmptyObject: EmptyLogMetricBucketOptions, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("BucketOptions")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.CreateTime, actual.CreateTime, dcl.DiffInfo{OutputOnly: true, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("CreateTime")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.UpdateTime, actual.UpdateTime, dcl.DiffInfo{OutputOnly: true, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("UpdateTime")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if ds, err := dcl.Diff(desired.Project, actual.Project, dcl.DiffInfo{Type: "ReferenceType", OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("Project")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
newDiffs = append(newDiffs, ds...)
}
if len(newDiffs) > 0 {
c.Config.Logger.Infof("Diff function found diffs: %v", newDiffs)
}
return newDiffs, nil
}
func compareLogMetricMetricDescriptorNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricMetricDescriptor)
if !ok {
desiredNotPointer, ok := d.(LogMetricMetricDescriptor)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricMetricDescriptor or *LogMetricMetricDescriptor", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricMetricDescriptor)
if !ok {
actualNotPointer, ok := a.(LogMetricMetricDescriptor)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricMetricDescriptor", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.Name, actual.Name, dcl.DiffInfo{OutputOnly: true, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("Name")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Type, actual.Type, dcl.DiffInfo{OutputOnly: true, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("Type")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Labels, actual.Labels, dcl.DiffInfo{Type: "Set", ObjectFunction: compareLogMetricMetricDescriptorLabelsNewStyle, EmptyObject: EmptyLogMetricMetricDescriptorLabels, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Labels")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.MetricKind, actual.MetricKind, dcl.DiffInfo{Type: "EnumType", OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("MetricKind")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.ValueType, actual.ValueType, dcl.DiffInfo{Type: "EnumType", CustomDiff: canonicalizeLogMetricMetricDescriptorValueType, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("ValueType")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Unit, actual.Unit, dcl.DiffInfo{ServerDefault: true, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Unit")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Description, actual.Description, dcl.DiffInfo{OutputOnly: true, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Description")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.DisplayName, actual.DisplayName, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("DisplayName")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Metadata, actual.Metadata, dcl.DiffInfo{Ignore: true, ObjectFunction: compareLogMetricMetricDescriptorMetadataNewStyle, EmptyObject: EmptyLogMetricMetricDescriptorMetadata, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Metadata")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.LaunchStage, actual.LaunchStage, dcl.DiffInfo{Ignore: true, Type: "EnumType", OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("LaunchStage")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.MonitoredResourceTypes, actual.MonitoredResourceTypes, dcl.DiffInfo{OutputOnly: true, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("MonitoredResourceTypes")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
func compareLogMetricMetricDescriptorLabelsNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricMetricDescriptorLabels)
if !ok {
desiredNotPointer, ok := d.(LogMetricMetricDescriptorLabels)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricMetricDescriptorLabels or *LogMetricMetricDescriptorLabels", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricMetricDescriptorLabels)
if !ok {
actualNotPointer, ok := a.(LogMetricMetricDescriptorLabels)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricMetricDescriptorLabels", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.Key, actual.Key, dcl.DiffInfo{OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("Key")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.ValueType, actual.ValueType, dcl.DiffInfo{Type: "EnumType", CustomDiff: canonicalizeLogMetricMetricDescriptorLabelsValueType, OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("ValueType")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Description, actual.Description, dcl.DiffInfo{OperationSelector: dcl.RequiresRecreate()}, fn.AddNest("Description")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
func compareLogMetricMetricDescriptorMetadataNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricMetricDescriptorMetadata)
if !ok {
desiredNotPointer, ok := d.(LogMetricMetricDescriptorMetadata)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricMetricDescriptorMetadata or *LogMetricMetricDescriptorMetadata", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricMetricDescriptorMetadata)
if !ok {
actualNotPointer, ok := a.(LogMetricMetricDescriptorMetadata)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricMetricDescriptorMetadata", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.SamplePeriod, actual.SamplePeriod, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("SamplePeriod")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.IngestDelay, actual.IngestDelay, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("IngestDelay")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
func compareLogMetricBucketOptionsNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricBucketOptions)
if !ok {
desiredNotPointer, ok := d.(LogMetricBucketOptions)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptions or *LogMetricBucketOptions", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricBucketOptions)
if !ok {
actualNotPointer, ok := a.(LogMetricBucketOptions)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptions", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.LinearBuckets, actual.LinearBuckets, dcl.DiffInfo{ObjectFunction: compareLogMetricBucketOptionsLinearBucketsNewStyle, EmptyObject: EmptyLogMetricBucketOptionsLinearBuckets, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("LinearBuckets")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.ExponentialBuckets, actual.ExponentialBuckets, dcl.DiffInfo{ObjectFunction: compareLogMetricBucketOptionsExponentialBucketsNewStyle, EmptyObject: EmptyLogMetricBucketOptionsExponentialBuckets, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("ExponentialBuckets")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.ExplicitBuckets, actual.ExplicitBuckets, dcl.DiffInfo{ObjectFunction: compareLogMetricBucketOptionsExplicitBucketsNewStyle, EmptyObject: EmptyLogMetricBucketOptionsExplicitBuckets, OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("ExplicitBuckets")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
func compareLogMetricBucketOptionsLinearBucketsNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricBucketOptionsLinearBuckets)
if !ok {
desiredNotPointer, ok := d.(LogMetricBucketOptionsLinearBuckets)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptionsLinearBuckets or *LogMetricBucketOptionsLinearBuckets", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricBucketOptionsLinearBuckets)
if !ok {
actualNotPointer, ok := a.(LogMetricBucketOptionsLinearBuckets)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptionsLinearBuckets", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.NumFiniteBuckets, actual.NumFiniteBuckets, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("NumFiniteBuckets")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Width, actual.Width, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Width")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Offset, actual.Offset, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Offset")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
func compareLogMetricBucketOptionsExponentialBucketsNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricBucketOptionsExponentialBuckets)
if !ok {
desiredNotPointer, ok := d.(LogMetricBucketOptionsExponentialBuckets)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptionsExponentialBuckets or *LogMetricBucketOptionsExponentialBuckets", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricBucketOptionsExponentialBuckets)
if !ok {
actualNotPointer, ok := a.(LogMetricBucketOptionsExponentialBuckets)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptionsExponentialBuckets", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.NumFiniteBuckets, actual.NumFiniteBuckets, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("NumFiniteBuckets")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.GrowthFactor, actual.GrowthFactor, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("GrowthFactor")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
if ds, err := dcl.Diff(desired.Scale, actual.Scale, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Scale")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
func compareLogMetricBucketOptionsExplicitBucketsNewStyle(d, a interface{}, fn dcl.FieldName) ([]*dcl.FieldDiff, error) {
var diffs []*dcl.FieldDiff
desired, ok := d.(*LogMetricBucketOptionsExplicitBuckets)
if !ok {
desiredNotPointer, ok := d.(LogMetricBucketOptionsExplicitBuckets)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptionsExplicitBuckets or *LogMetricBucketOptionsExplicitBuckets", d)
}
desired = &desiredNotPointer
}
actual, ok := a.(*LogMetricBucketOptionsExplicitBuckets)
if !ok {
actualNotPointer, ok := a.(LogMetricBucketOptionsExplicitBuckets)
if !ok {
return nil, fmt.Errorf("obj %v is not a LogMetricBucketOptionsExplicitBuckets", a)
}
actual = &actualNotPointer
}
if ds, err := dcl.Diff(desired.Bounds, actual.Bounds, dcl.DiffInfo{OperationSelector: dcl.TriggersOperation("updateLogMetricUpdateOperation")}, fn.AddNest("Bounds")); len(ds) != 0 || err != nil {
if err != nil {
return nil, err
}
diffs = append(diffs, ds...)
}
return diffs, nil
}
// urlNormalized returns a copy of the resource struct with values normalized
// for URL substitutions. For instance, it converts long-form self-links to
// short-form so they can be substituted in.
func (r *LogMetric) urlNormalized() *LogMetric {
normalized := dcl.Copy(*r).(LogMetric)
normalized.Name = dcl.SelfLinkToName(r.Name)
normalized.Description = dcl.SelfLinkToName(r.Description)
normalized.Filter = dcl.SelfLinkToName(r.Filter)
normalized.ValueExtractor = dcl.SelfLinkToName(r.ValueExtractor)
normalized.Project = dcl.SelfLinkToName(r.Project)
return &normalized
}
func (r *LogMetric) updateURL(userBasePath, updateName string) (string, error) {
nr := r.urlNormalized()
if updateName == "update" {
fields := map[string]interface{}{
"project": dcl.ValueOrEmptyString(nr.Project),
"name": dcl.ValueOrEmptyString(nr.Name),
}
return dcl.URL("projects/{{project}}/metrics/{{name}}", nr.basePath(), userBasePath, fields), nil
}
return "", fmt.Errorf("unknown update name: %s", updateName)
}
// marshal encodes the LogMetric resource into JSON for a Create request, and
// performs transformations from the resource schema to the API schema if
// necessary.
func (r *LogMetric) marshal(c *Client) ([]byte, error) {
m, err := expandLogMetric(c, r)
if err != nil {
return nil, fmt.Errorf("error marshalling LogMetric: %w", err)
}
return json.Marshal(m)
}
// unmarshalLogMetric decodes JSON responses into the LogMetric resource schema.
func unmarshalLogMetric(b []byte, c *Client, res *LogMetric) (*LogMetric, error) {
var m map[string]interface{}
if err := json.Unmarshal(b, &m); err != nil {
return nil, err
}
return unmarshalMapLogMetric(m, c, res)
}
func unmarshalMapLogMetric(m map[string]interface{}, c *Client, res *LogMetric) (*LogMetric, error) {
flattened := flattenLogMetric(c, m, res)
if flattened == nil {
return nil, fmt.Errorf("attempted to flatten empty json object")
}
return flattened, nil
}
// expandLogMetric expands LogMetric into a JSON request object.
func expandLogMetric(c *Client, f *LogMetric) (map[string]interface{}, error) {
m := make(map[string]interface{})
res := f
_ = res
if v := f.Name; dcl.ValueShouldBeSent(v) {
m["name"] = v
}
if v := f.Description; dcl.ValueShouldBeSent(v) {
m["description"] = v
}
if v := f.Filter; dcl.ValueShouldBeSent(v) {
m["filter"] = v
}
if v := f.Disabled; dcl.ValueShouldBeSent(v) {
m["disabled"] = v
}
if v, err := expandLogMetricMetricDescriptor(c, f.MetricDescriptor, res); err != nil {
return nil, fmt.Errorf("error expanding MetricDescriptor into metricDescriptor: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["metricDescriptor"] = v
}
if v := f.ValueExtractor; dcl.ValueShouldBeSent(v) {
m["valueExtractor"] = v
}
if v := f.LabelExtractors; dcl.ValueShouldBeSent(v) {
m["labelExtractors"] = v
}
if v, err := expandLogMetricBucketOptions(c, f.BucketOptions, res); err != nil {
return nil, fmt.Errorf("error expanding BucketOptions into bucketOptions: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["bucketOptions"] = v
}
if v, err := dcl.EmptyValue(); err != nil {
return nil, fmt.Errorf("error expanding Project into project: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["project"] = v
}
return m, nil
}
// flattenLogMetric flattens LogMetric from a JSON request object into the
// LogMetric type.
func flattenLogMetric(c *Client, i interface{}, res *LogMetric) *LogMetric {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
if len(m) == 0 {
return nil
}
resultRes := &LogMetric{}
resultRes.Name = dcl.FlattenString(m["name"])
resultRes.Description = dcl.FlattenString(m["description"])
resultRes.Filter = dcl.FlattenString(m["filter"])
resultRes.Disabled = dcl.FlattenBool(m["disabled"])
resultRes.MetricDescriptor = flattenLogMetricMetricDescriptor(c, m["metricDescriptor"], res)
resultRes.ValueExtractor = dcl.FlattenString(m["valueExtractor"])
resultRes.LabelExtractors = dcl.FlattenKeyValuePairs(m["labelExtractors"])
resultRes.BucketOptions = flattenLogMetricBucketOptions(c, m["bucketOptions"], res)
resultRes.CreateTime = dcl.FlattenString(m["createTime"])
resultRes.UpdateTime = dcl.FlattenString(m["updateTime"])
resultRes.Project = dcl.FlattenString(m["project"])
return resultRes
}
// expandLogMetricMetricDescriptorMap expands the contents of LogMetricMetricDescriptor into a JSON
// request object.
func expandLogMetricMetricDescriptorMap(c *Client, f map[string]LogMetricMetricDescriptor, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricMetricDescriptor(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricMetricDescriptorSlice expands the contents of LogMetricMetricDescriptor into a JSON
// request object.
func expandLogMetricMetricDescriptorSlice(c *Client, f []LogMetricMetricDescriptor, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricMetricDescriptor(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricMetricDescriptorMap flattens the contents of LogMetricMetricDescriptor from a JSON
// response object.
func flattenLogMetricMetricDescriptorMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptor {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptor{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptor{}
}
items := make(map[string]LogMetricMetricDescriptor)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptor(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricMetricDescriptorSlice flattens the contents of LogMetricMetricDescriptor from a JSON
// response object.
func flattenLogMetricMetricDescriptorSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptor {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptor{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptor{}
}
items := make([]LogMetricMetricDescriptor, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptor(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricMetricDescriptor expands an instance of LogMetricMetricDescriptor into a JSON
// request object.
func expandLogMetricMetricDescriptor(c *Client, f *LogMetricMetricDescriptor, res *LogMetric) (map[string]interface{}, error) {
if dcl.IsEmptyValueIndirect(f) {
return nil, nil
}
m := make(map[string]interface{})
if v, err := expandLogMetricMetricDescriptorLabelsSlice(c, f.Labels, res); err != nil {
return nil, fmt.Errorf("error expanding Labels into labels: %w", err)
} else if v != nil {
m["labels"] = v
}
if v := f.MetricKind; !dcl.IsEmptyValueIndirect(v) {
m["metricKind"] = v
}
if v := f.ValueType; !dcl.IsEmptyValueIndirect(v) {
m["valueType"] = v
}
if v := f.Unit; !dcl.IsEmptyValueIndirect(v) {
m["unit"] = v
}
if v := f.DisplayName; !dcl.IsEmptyValueIndirect(v) {
m["displayName"] = v
}
if v, err := expandLogMetricMetricDescriptorMetadata(c, f.Metadata, res); err != nil {
return nil, fmt.Errorf("error expanding Metadata into metadata: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["metadata"] = v
}
if v := f.LaunchStage; !dcl.IsEmptyValueIndirect(v) {
m["launchStage"] = v
}
return m, nil
}
// flattenLogMetricMetricDescriptor flattens an instance of LogMetricMetricDescriptor from a JSON
// response object.
func flattenLogMetricMetricDescriptor(c *Client, i interface{}, res *LogMetric) *LogMetricMetricDescriptor {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricMetricDescriptor{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricMetricDescriptor
}
r.Name = dcl.FlattenString(m["name"])
r.Type = dcl.FlattenString(m["type"])
r.Labels = flattenLogMetricMetricDescriptorLabelsSlice(c, m["labels"], res)
r.MetricKind = flattenLogMetricMetricDescriptorMetricKindEnum(m["metricKind"])
r.ValueType = flattenLogMetricMetricDescriptorValueTypeEnum(m["valueType"])
r.Unit = dcl.FlattenString(m["unit"])
r.Description = dcl.FlattenString(m["description"])
r.DisplayName = dcl.FlattenString(m["displayName"])
r.Metadata = flattenLogMetricMetricDescriptorMetadata(c, m["metadata"], res)
r.LaunchStage = flattenLogMetricMetricDescriptorLaunchStageEnum(m["launchStage"])
r.MonitoredResourceTypes = dcl.FlattenStringSlice(m["monitoredResourceTypes"])
return r
}
// expandLogMetricMetricDescriptorLabelsMap expands the contents of LogMetricMetricDescriptorLabels into a JSON
// request object.
func expandLogMetricMetricDescriptorLabelsMap(c *Client, f map[string]LogMetricMetricDescriptorLabels, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricMetricDescriptorLabels(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricMetricDescriptorLabelsSlice expands the contents of LogMetricMetricDescriptorLabels into a JSON
// request object.
func expandLogMetricMetricDescriptorLabelsSlice(c *Client, f []LogMetricMetricDescriptorLabels, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricMetricDescriptorLabels(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricMetricDescriptorLabelsMap flattens the contents of LogMetricMetricDescriptorLabels from a JSON
// response object.
func flattenLogMetricMetricDescriptorLabelsMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptorLabels {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptorLabels{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptorLabels{}
}
items := make(map[string]LogMetricMetricDescriptorLabels)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptorLabels(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricMetricDescriptorLabelsSlice flattens the contents of LogMetricMetricDescriptorLabels from a JSON
// response object.
func flattenLogMetricMetricDescriptorLabelsSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptorLabels {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptorLabels{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptorLabels{}
}
items := make([]LogMetricMetricDescriptorLabels, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptorLabels(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricMetricDescriptorLabels expands an instance of LogMetricMetricDescriptorLabels into a JSON
// request object.
func expandLogMetricMetricDescriptorLabels(c *Client, f *LogMetricMetricDescriptorLabels, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
m := make(map[string]interface{})
if v := f.Key; !dcl.IsEmptyValueIndirect(v) {
m["key"] = v
}
if v := f.ValueType; !dcl.IsEmptyValueIndirect(v) {
m["valueType"] = v
}
if v := f.Description; !dcl.IsEmptyValueIndirect(v) {
m["description"] = v
}
return m, nil
}
// flattenLogMetricMetricDescriptorLabels flattens an instance of LogMetricMetricDescriptorLabels from a JSON
// response object.
func flattenLogMetricMetricDescriptorLabels(c *Client, i interface{}, res *LogMetric) *LogMetricMetricDescriptorLabels {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricMetricDescriptorLabels{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricMetricDescriptorLabels
}
r.Key = dcl.FlattenString(m["key"])
r.ValueType = flattenLogMetricMetricDescriptorLabelsValueTypeEnum(m["valueType"])
r.Description = dcl.FlattenString(m["description"])
return r
}
// expandLogMetricMetricDescriptorMetadataMap expands the contents of LogMetricMetricDescriptorMetadata into a JSON
// request object.
func expandLogMetricMetricDescriptorMetadataMap(c *Client, f map[string]LogMetricMetricDescriptorMetadata, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricMetricDescriptorMetadata(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricMetricDescriptorMetadataSlice expands the contents of LogMetricMetricDescriptorMetadata into a JSON
// request object.
func expandLogMetricMetricDescriptorMetadataSlice(c *Client, f []LogMetricMetricDescriptorMetadata, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricMetricDescriptorMetadata(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricMetricDescriptorMetadataMap flattens the contents of LogMetricMetricDescriptorMetadata from a JSON
// response object.
func flattenLogMetricMetricDescriptorMetadataMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptorMetadata {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptorMetadata{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptorMetadata{}
}
items := make(map[string]LogMetricMetricDescriptorMetadata)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptorMetadata(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricMetricDescriptorMetadataSlice flattens the contents of LogMetricMetricDescriptorMetadata from a JSON
// response object.
func flattenLogMetricMetricDescriptorMetadataSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptorMetadata {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptorMetadata{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptorMetadata{}
}
items := make([]LogMetricMetricDescriptorMetadata, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptorMetadata(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricMetricDescriptorMetadata expands an instance of LogMetricMetricDescriptorMetadata into a JSON
// request object.
func expandLogMetricMetricDescriptorMetadata(c *Client, f *LogMetricMetricDescriptorMetadata, res *LogMetric) (map[string]interface{}, error) {
if dcl.IsEmptyValueIndirect(f) {
return nil, nil
}
m := make(map[string]interface{})
if v := f.SamplePeriod; !dcl.IsEmptyValueIndirect(v) {
m["samplePeriod"] = v
}
if v := f.IngestDelay; !dcl.IsEmptyValueIndirect(v) {
m["ingestDelay"] = v
}
return m, nil
}
// flattenLogMetricMetricDescriptorMetadata flattens an instance of LogMetricMetricDescriptorMetadata from a JSON
// response object.
func flattenLogMetricMetricDescriptorMetadata(c *Client, i interface{}, res *LogMetric) *LogMetricMetricDescriptorMetadata {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricMetricDescriptorMetadata{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricMetricDescriptorMetadata
}
r.SamplePeriod = dcl.FlattenString(m["samplePeriod"])
r.IngestDelay = dcl.FlattenString(m["ingestDelay"])
return r
}
// expandLogMetricBucketOptionsMap expands the contents of LogMetricBucketOptions into a JSON
// request object.
func expandLogMetricBucketOptionsMap(c *Client, f map[string]LogMetricBucketOptions, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricBucketOptions(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricBucketOptionsSlice expands the contents of LogMetricBucketOptions into a JSON
// request object.
func expandLogMetricBucketOptionsSlice(c *Client, f []LogMetricBucketOptions, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricBucketOptions(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricBucketOptionsMap flattens the contents of LogMetricBucketOptions from a JSON
// response object.
func flattenLogMetricBucketOptionsMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricBucketOptions {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricBucketOptions{}
}
if len(a) == 0 {
return map[string]LogMetricBucketOptions{}
}
items := make(map[string]LogMetricBucketOptions)
for k, item := range a {
items[k] = *flattenLogMetricBucketOptions(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricBucketOptionsSlice flattens the contents of LogMetricBucketOptions from a JSON
// response object.
func flattenLogMetricBucketOptionsSlice(c *Client, i interface{}, res *LogMetric) []LogMetricBucketOptions {
a, ok := i.([]interface{})
if !ok {
return []LogMetricBucketOptions{}
}
if len(a) == 0 {
return []LogMetricBucketOptions{}
}
items := make([]LogMetricBucketOptions, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricBucketOptions(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricBucketOptions expands an instance of LogMetricBucketOptions into a JSON
// request object.
func expandLogMetricBucketOptions(c *Client, f *LogMetricBucketOptions, res *LogMetric) (map[string]interface{}, error) {
if dcl.IsEmptyValueIndirect(f) {
return nil, nil
}
m := make(map[string]interface{})
if v, err := expandLogMetricBucketOptionsLinearBuckets(c, f.LinearBuckets, res); err != nil {
return nil, fmt.Errorf("error expanding LinearBuckets into linearBuckets: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["linearBuckets"] = v
}
if v, err := expandLogMetricBucketOptionsExponentialBuckets(c, f.ExponentialBuckets, res); err != nil {
return nil, fmt.Errorf("error expanding ExponentialBuckets into exponentialBuckets: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["exponentialBuckets"] = v
}
if v, err := expandLogMetricBucketOptionsExplicitBuckets(c, f.ExplicitBuckets, res); err != nil {
return nil, fmt.Errorf("error expanding ExplicitBuckets into explicitBuckets: %w", err)
} else if !dcl.IsEmptyValueIndirect(v) {
m["explicitBuckets"] = v
}
return m, nil
}
// flattenLogMetricBucketOptions flattens an instance of LogMetricBucketOptions from a JSON
// response object.
func flattenLogMetricBucketOptions(c *Client, i interface{}, res *LogMetric) *LogMetricBucketOptions {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricBucketOptions{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricBucketOptions
}
r.LinearBuckets = flattenLogMetricBucketOptionsLinearBuckets(c, m["linearBuckets"], res)
r.ExponentialBuckets = flattenLogMetricBucketOptionsExponentialBuckets(c, m["exponentialBuckets"], res)
r.ExplicitBuckets = flattenLogMetricBucketOptionsExplicitBuckets(c, m["explicitBuckets"], res)
return r
}
// expandLogMetricBucketOptionsLinearBucketsMap expands the contents of LogMetricBucketOptionsLinearBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsLinearBucketsMap(c *Client, f map[string]LogMetricBucketOptionsLinearBuckets, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricBucketOptionsLinearBuckets(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricBucketOptionsLinearBucketsSlice expands the contents of LogMetricBucketOptionsLinearBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsLinearBucketsSlice(c *Client, f []LogMetricBucketOptionsLinearBuckets, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricBucketOptionsLinearBuckets(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricBucketOptionsLinearBucketsMap flattens the contents of LogMetricBucketOptionsLinearBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsLinearBucketsMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricBucketOptionsLinearBuckets {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricBucketOptionsLinearBuckets{}
}
if len(a) == 0 {
return map[string]LogMetricBucketOptionsLinearBuckets{}
}
items := make(map[string]LogMetricBucketOptionsLinearBuckets)
for k, item := range a {
items[k] = *flattenLogMetricBucketOptionsLinearBuckets(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricBucketOptionsLinearBucketsSlice flattens the contents of LogMetricBucketOptionsLinearBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsLinearBucketsSlice(c *Client, i interface{}, res *LogMetric) []LogMetricBucketOptionsLinearBuckets {
a, ok := i.([]interface{})
if !ok {
return []LogMetricBucketOptionsLinearBuckets{}
}
if len(a) == 0 {
return []LogMetricBucketOptionsLinearBuckets{}
}
items := make([]LogMetricBucketOptionsLinearBuckets, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricBucketOptionsLinearBuckets(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricBucketOptionsLinearBuckets expands an instance of LogMetricBucketOptionsLinearBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsLinearBuckets(c *Client, f *LogMetricBucketOptionsLinearBuckets, res *LogMetric) (map[string]interface{}, error) {
if dcl.IsEmptyValueIndirect(f) {
return nil, nil
}
m := make(map[string]interface{})
if v := f.NumFiniteBuckets; !dcl.IsEmptyValueIndirect(v) {
m["numFiniteBuckets"] = v
}
if v := f.Width; !dcl.IsEmptyValueIndirect(v) {
m["width"] = v
}
if v := f.Offset; !dcl.IsEmptyValueIndirect(v) {
m["offset"] = v
}
return m, nil
}
// flattenLogMetricBucketOptionsLinearBuckets flattens an instance of LogMetricBucketOptionsLinearBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsLinearBuckets(c *Client, i interface{}, res *LogMetric) *LogMetricBucketOptionsLinearBuckets {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricBucketOptionsLinearBuckets{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricBucketOptionsLinearBuckets
}
r.NumFiniteBuckets = dcl.FlattenInteger(m["numFiniteBuckets"])
r.Width = dcl.FlattenDouble(m["width"])
r.Offset = dcl.FlattenDouble(m["offset"])
return r
}
// expandLogMetricBucketOptionsExponentialBucketsMap expands the contents of LogMetricBucketOptionsExponentialBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsExponentialBucketsMap(c *Client, f map[string]LogMetricBucketOptionsExponentialBuckets, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricBucketOptionsExponentialBuckets(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricBucketOptionsExponentialBucketsSlice expands the contents of LogMetricBucketOptionsExponentialBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsExponentialBucketsSlice(c *Client, f []LogMetricBucketOptionsExponentialBuckets, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricBucketOptionsExponentialBuckets(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricBucketOptionsExponentialBucketsMap flattens the contents of LogMetricBucketOptionsExponentialBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsExponentialBucketsMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricBucketOptionsExponentialBuckets {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricBucketOptionsExponentialBuckets{}
}
if len(a) == 0 {
return map[string]LogMetricBucketOptionsExponentialBuckets{}
}
items := make(map[string]LogMetricBucketOptionsExponentialBuckets)
for k, item := range a {
items[k] = *flattenLogMetricBucketOptionsExponentialBuckets(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricBucketOptionsExponentialBucketsSlice flattens the contents of LogMetricBucketOptionsExponentialBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsExponentialBucketsSlice(c *Client, i interface{}, res *LogMetric) []LogMetricBucketOptionsExponentialBuckets {
a, ok := i.([]interface{})
if !ok {
return []LogMetricBucketOptionsExponentialBuckets{}
}
if len(a) == 0 {
return []LogMetricBucketOptionsExponentialBuckets{}
}
items := make([]LogMetricBucketOptionsExponentialBuckets, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricBucketOptionsExponentialBuckets(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricBucketOptionsExponentialBuckets expands an instance of LogMetricBucketOptionsExponentialBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsExponentialBuckets(c *Client, f *LogMetricBucketOptionsExponentialBuckets, res *LogMetric) (map[string]interface{}, error) {
if dcl.IsEmptyValueIndirect(f) {
return nil, nil
}
m := make(map[string]interface{})
if v := f.NumFiniteBuckets; !dcl.IsEmptyValueIndirect(v) {
m["numFiniteBuckets"] = v
}
if v := f.GrowthFactor; !dcl.IsEmptyValueIndirect(v) {
m["growthFactor"] = v
}
if v := f.Scale; !dcl.IsEmptyValueIndirect(v) {
m["scale"] = v
}
return m, nil
}
// flattenLogMetricBucketOptionsExponentialBuckets flattens an instance of LogMetricBucketOptionsExponentialBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsExponentialBuckets(c *Client, i interface{}, res *LogMetric) *LogMetricBucketOptionsExponentialBuckets {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricBucketOptionsExponentialBuckets{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricBucketOptionsExponentialBuckets
}
r.NumFiniteBuckets = dcl.FlattenInteger(m["numFiniteBuckets"])
r.GrowthFactor = dcl.FlattenDouble(m["growthFactor"])
r.Scale = dcl.FlattenDouble(m["scale"])
return r
}
// expandLogMetricBucketOptionsExplicitBucketsMap expands the contents of LogMetricBucketOptionsExplicitBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsExplicitBucketsMap(c *Client, f map[string]LogMetricBucketOptionsExplicitBuckets, res *LogMetric) (map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := make(map[string]interface{})
for k, item := range f {
i, err := expandLogMetricBucketOptionsExplicitBuckets(c, &item, res)
if err != nil {
return nil, err
}
if i != nil {
items[k] = i
}
}
return items, nil
}
// expandLogMetricBucketOptionsExplicitBucketsSlice expands the contents of LogMetricBucketOptionsExplicitBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsExplicitBucketsSlice(c *Client, f []LogMetricBucketOptionsExplicitBuckets, res *LogMetric) ([]map[string]interface{}, error) {
if f == nil {
return nil, nil
}
items := []map[string]interface{}{}
for _, item := range f {
i, err := expandLogMetricBucketOptionsExplicitBuckets(c, &item, res)
if err != nil {
return nil, err
}
items = append(items, i)
}
return items, nil
}
// flattenLogMetricBucketOptionsExplicitBucketsMap flattens the contents of LogMetricBucketOptionsExplicitBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsExplicitBucketsMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricBucketOptionsExplicitBuckets {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricBucketOptionsExplicitBuckets{}
}
if len(a) == 0 {
return map[string]LogMetricBucketOptionsExplicitBuckets{}
}
items := make(map[string]LogMetricBucketOptionsExplicitBuckets)
for k, item := range a {
items[k] = *flattenLogMetricBucketOptionsExplicitBuckets(c, item.(map[string]interface{}), res)
}
return items
}
// flattenLogMetricBucketOptionsExplicitBucketsSlice flattens the contents of LogMetricBucketOptionsExplicitBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsExplicitBucketsSlice(c *Client, i interface{}, res *LogMetric) []LogMetricBucketOptionsExplicitBuckets {
a, ok := i.([]interface{})
if !ok {
return []LogMetricBucketOptionsExplicitBuckets{}
}
if len(a) == 0 {
return []LogMetricBucketOptionsExplicitBuckets{}
}
items := make([]LogMetricBucketOptionsExplicitBuckets, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricBucketOptionsExplicitBuckets(c, item.(map[string]interface{}), res))
}
return items
}
// expandLogMetricBucketOptionsExplicitBuckets expands an instance of LogMetricBucketOptionsExplicitBuckets into a JSON
// request object.
func expandLogMetricBucketOptionsExplicitBuckets(c *Client, f *LogMetricBucketOptionsExplicitBuckets, res *LogMetric) (map[string]interface{}, error) {
if dcl.IsEmptyValueIndirect(f) {
return nil, nil
}
m := make(map[string]interface{})
if v := f.Bounds; v != nil {
m["bounds"] = v
}
return m, nil
}
// flattenLogMetricBucketOptionsExplicitBuckets flattens an instance of LogMetricBucketOptionsExplicitBuckets from a JSON
// response object.
func flattenLogMetricBucketOptionsExplicitBuckets(c *Client, i interface{}, res *LogMetric) *LogMetricBucketOptionsExplicitBuckets {
m, ok := i.(map[string]interface{})
if !ok {
return nil
}
r := &LogMetricBucketOptionsExplicitBuckets{}
if dcl.IsEmptyValueIndirect(i) {
return EmptyLogMetricBucketOptionsExplicitBuckets
}
r.Bounds = dcl.FlattenFloatSlice(m["bounds"])
return r
}
// flattenLogMetricMetricDescriptorLabelsValueTypeEnumMap flattens the contents of LogMetricMetricDescriptorLabelsValueTypeEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorLabelsValueTypeEnumMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptorLabelsValueTypeEnum {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptorLabelsValueTypeEnum{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptorLabelsValueTypeEnum{}
}
items := make(map[string]LogMetricMetricDescriptorLabelsValueTypeEnum)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptorLabelsValueTypeEnum(item.(interface{}))
}
return items
}
// flattenLogMetricMetricDescriptorLabelsValueTypeEnumSlice flattens the contents of LogMetricMetricDescriptorLabelsValueTypeEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorLabelsValueTypeEnumSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptorLabelsValueTypeEnum {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptorLabelsValueTypeEnum{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptorLabelsValueTypeEnum{}
}
items := make([]LogMetricMetricDescriptorLabelsValueTypeEnum, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptorLabelsValueTypeEnum(item.(interface{})))
}
return items
}
// flattenLogMetricMetricDescriptorLabelsValueTypeEnum asserts that an interface is a string, and returns a
// pointer to a *LogMetricMetricDescriptorLabelsValueTypeEnum with the same value as that string.
func flattenLogMetricMetricDescriptorLabelsValueTypeEnum(i interface{}) *LogMetricMetricDescriptorLabelsValueTypeEnum {
s, ok := i.(string)
if !ok {
return nil
}
return LogMetricMetricDescriptorLabelsValueTypeEnumRef(s)
}
// flattenLogMetricMetricDescriptorMetricKindEnumMap flattens the contents of LogMetricMetricDescriptorMetricKindEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorMetricKindEnumMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptorMetricKindEnum {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptorMetricKindEnum{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptorMetricKindEnum{}
}
items := make(map[string]LogMetricMetricDescriptorMetricKindEnum)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptorMetricKindEnum(item.(interface{}))
}
return items
}
// flattenLogMetricMetricDescriptorMetricKindEnumSlice flattens the contents of LogMetricMetricDescriptorMetricKindEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorMetricKindEnumSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptorMetricKindEnum {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptorMetricKindEnum{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptorMetricKindEnum{}
}
items := make([]LogMetricMetricDescriptorMetricKindEnum, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptorMetricKindEnum(item.(interface{})))
}
return items
}
// flattenLogMetricMetricDescriptorMetricKindEnum asserts that an interface is a string, and returns a
// pointer to a *LogMetricMetricDescriptorMetricKindEnum with the same value as that string.
func flattenLogMetricMetricDescriptorMetricKindEnum(i interface{}) *LogMetricMetricDescriptorMetricKindEnum {
s, ok := i.(string)
if !ok {
return nil
}
return LogMetricMetricDescriptorMetricKindEnumRef(s)
}
// flattenLogMetricMetricDescriptorValueTypeEnumMap flattens the contents of LogMetricMetricDescriptorValueTypeEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorValueTypeEnumMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptorValueTypeEnum {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptorValueTypeEnum{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptorValueTypeEnum{}
}
items := make(map[string]LogMetricMetricDescriptorValueTypeEnum)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptorValueTypeEnum(item.(interface{}))
}
return items
}
// flattenLogMetricMetricDescriptorValueTypeEnumSlice flattens the contents of LogMetricMetricDescriptorValueTypeEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorValueTypeEnumSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptorValueTypeEnum {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptorValueTypeEnum{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptorValueTypeEnum{}
}
items := make([]LogMetricMetricDescriptorValueTypeEnum, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptorValueTypeEnum(item.(interface{})))
}
return items
}
// flattenLogMetricMetricDescriptorValueTypeEnum asserts that an interface is a string, and returns a
// pointer to a *LogMetricMetricDescriptorValueTypeEnum with the same value as that string.
func flattenLogMetricMetricDescriptorValueTypeEnum(i interface{}) *LogMetricMetricDescriptorValueTypeEnum {
s, ok := i.(string)
if !ok {
return nil
}
return LogMetricMetricDescriptorValueTypeEnumRef(s)
}
// flattenLogMetricMetricDescriptorLaunchStageEnumMap flattens the contents of LogMetricMetricDescriptorLaunchStageEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorLaunchStageEnumMap(c *Client, i interface{}, res *LogMetric) map[string]LogMetricMetricDescriptorLaunchStageEnum {
a, ok := i.(map[string]interface{})
if !ok {
return map[string]LogMetricMetricDescriptorLaunchStageEnum{}
}
if len(a) == 0 {
return map[string]LogMetricMetricDescriptorLaunchStageEnum{}
}
items := make(map[string]LogMetricMetricDescriptorLaunchStageEnum)
for k, item := range a {
items[k] = *flattenLogMetricMetricDescriptorLaunchStageEnum(item.(interface{}))
}
return items
}
// flattenLogMetricMetricDescriptorLaunchStageEnumSlice flattens the contents of LogMetricMetricDescriptorLaunchStageEnum from a JSON
// response object.
func flattenLogMetricMetricDescriptorLaunchStageEnumSlice(c *Client, i interface{}, res *LogMetric) []LogMetricMetricDescriptorLaunchStageEnum {
a, ok := i.([]interface{})
if !ok {
return []LogMetricMetricDescriptorLaunchStageEnum{}
}
if len(a) == 0 {
return []LogMetricMetricDescriptorLaunchStageEnum{}
}
items := make([]LogMetricMetricDescriptorLaunchStageEnum, 0, len(a))
for _, item := range a {
items = append(items, *flattenLogMetricMetricDescriptorLaunchStageEnum(item.(interface{})))
}
return items
}
// flattenLogMetricMetricDescriptorLaunchStageEnum asserts that an interface is a string, and returns a
// pointer to a *LogMetricMetricDescriptorLaunchStageEnum with the same value as that string.
func flattenLogMetricMetricDescriptorLaunchStageEnum(i interface{}) *LogMetricMetricDescriptorLaunchStageEnum {
s, ok := i.(string)
if !ok {
return nil
}
return LogMetricMetricDescriptorLaunchStageEnumRef(s)
}
// This function returns a matcher that checks whether a serialized resource matches this resource
// in its parameters (as defined by the fields in a Get, which definitionally define resource
// identity). This is useful in extracting the element from a List call.
func (r *LogMetric) matcher(c *Client) func([]byte) bool {
return func(b []byte) bool {
cr, err := unmarshalLogMetric(b, c, r)
if err != nil {
c.Config.Logger.Warning("failed to unmarshal provided resource in matcher.")
return false
}
nr := r.urlNormalized()
ncr := cr.urlNormalized()
c.Config.Logger.Infof("looking for %v\nin %v", nr, ncr)
if nr.Project == nil && ncr.Project == nil {
c.Config.Logger.Info("Both Project fields null - considering equal.")
} else if nr.Project == nil || ncr.Project == nil {
c.Config.Logger.Info("Only one Project field is null - considering unequal.")
return false
} else if *nr.Project != *ncr.Project {
return false
}
if nr.Name == nil && ncr.Name == nil {
c.Config.Logger.Info("Both Name fields null - considering equal.")
} else if nr.Name == nil || ncr.Name == nil {
c.Config.Logger.Info("Only one Name field is null - considering unequal.")
return false
} else if *nr.Name != *ncr.Name {
return false
}
return true
}
}
type logMetricDiff struct {
// The diff should include one or the other of RequiresRecreate or UpdateOp.
RequiresRecreate bool
UpdateOp logMetricApiOperation
FieldName string // used for error logging
}
func convertFieldDiffsToLogMetricDiffs(config *dcl.Config, fds []*dcl.FieldDiff, opts []dcl.ApplyOption) ([]logMetricDiff, error) {
opNamesToFieldDiffs := make(map[string][]*dcl.FieldDiff)
// Map each operation name to the field diffs associated with it.
for _, fd := range fds {
for _, ro := range fd.ResultingOperation {
if fieldDiffs, ok := opNamesToFieldDiffs[ro]; ok {
fieldDiffs = append(fieldDiffs, fd)
opNamesToFieldDiffs[ro] = fieldDiffs
} else {
config.Logger.Infof("%s required due to diff: %v", ro, fd)
opNamesToFieldDiffs[ro] = []*dcl.FieldDiff{fd}
}
}
}
var diffs []logMetricDiff
// For each operation name, create a logMetricDiff which contains the operation.
for opName, fieldDiffs := range opNamesToFieldDiffs {
// Use the first field diff's field name for logging required recreate error.
diff := logMetricDiff{FieldName: fieldDiffs[0].FieldName}
if opName == "Recreate" {
diff.RequiresRecreate = true
} else {
apiOp, err := convertOpNameToLogMetricApiOperation(opName, fieldDiffs, opts...)
if err != nil {
return diffs, err
}
diff.UpdateOp = apiOp
}
diffs = append(diffs, diff)
}
return diffs, nil
}
func convertOpNameToLogMetricApiOperation(opName string, fieldDiffs []*dcl.FieldDiff, opts ...dcl.ApplyOption) (logMetricApiOperation, error) {
switch opName {
case "updateLogMetricUpdateOperation":
return &updateLogMetricUpdateOperation{FieldDiffs: fieldDiffs}, nil
default:
return nil, fmt.Errorf("no such operation with name: %v", opName)
}
}
func extractLogMetricFields(r *LogMetric) error {
vMetricDescriptor := r.MetricDescriptor
if vMetricDescriptor == nil {
// note: explicitly not the empty object.
vMetricDescriptor = &LogMetricMetricDescriptor{}
}
if err := extractLogMetricMetricDescriptorFields(r, vMetricDescriptor); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vMetricDescriptor) {
r.MetricDescriptor = vMetricDescriptor
}
vBucketOptions := r.BucketOptions
if vBucketOptions == nil {
// note: explicitly not the empty object.
vBucketOptions = &LogMetricBucketOptions{}
}
if err := extractLogMetricBucketOptionsFields(r, vBucketOptions); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vBucketOptions) {
r.BucketOptions = vBucketOptions
}
return nil
}
func extractLogMetricMetricDescriptorFields(r *LogMetric, o *LogMetricMetricDescriptor) error {
vMetadata := o.Metadata
if vMetadata == nil {
// note: explicitly not the empty object.
vMetadata = &LogMetricMetricDescriptorMetadata{}
}
if err := extractLogMetricMetricDescriptorMetadataFields(r, vMetadata); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vMetadata) {
o.Metadata = vMetadata
}
return nil
}
func extractLogMetricMetricDescriptorLabelsFields(r *LogMetric, o *LogMetricMetricDescriptorLabels) error {
return nil
}
func extractLogMetricMetricDescriptorMetadataFields(r *LogMetric, o *LogMetricMetricDescriptorMetadata) error {
return nil
}
func extractLogMetricBucketOptionsFields(r *LogMetric, o *LogMetricBucketOptions) error {
vLinearBuckets := o.LinearBuckets
if vLinearBuckets == nil {
// note: explicitly not the empty object.
vLinearBuckets = &LogMetricBucketOptionsLinearBuckets{}
}
if err := extractLogMetricBucketOptionsLinearBucketsFields(r, vLinearBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vLinearBuckets) {
o.LinearBuckets = vLinearBuckets
}
vExponentialBuckets := o.ExponentialBuckets
if vExponentialBuckets == nil {
// note: explicitly not the empty object.
vExponentialBuckets = &LogMetricBucketOptionsExponentialBuckets{}
}
if err := extractLogMetricBucketOptionsExponentialBucketsFields(r, vExponentialBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vExponentialBuckets) {
o.ExponentialBuckets = vExponentialBuckets
}
vExplicitBuckets := o.ExplicitBuckets
if vExplicitBuckets == nil {
// note: explicitly not the empty object.
vExplicitBuckets = &LogMetricBucketOptionsExplicitBuckets{}
}
if err := extractLogMetricBucketOptionsExplicitBucketsFields(r, vExplicitBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vExplicitBuckets) {
o.ExplicitBuckets = vExplicitBuckets
}
return nil
}
func extractLogMetricBucketOptionsLinearBucketsFields(r *LogMetric, o *LogMetricBucketOptionsLinearBuckets) error {
return nil
}
func extractLogMetricBucketOptionsExponentialBucketsFields(r *LogMetric, o *LogMetricBucketOptionsExponentialBuckets) error {
return nil
}
func extractLogMetricBucketOptionsExplicitBucketsFields(r *LogMetric, o *LogMetricBucketOptionsExplicitBuckets) error {
return nil
}
func postReadExtractLogMetricFields(r *LogMetric) error {
vMetricDescriptor := r.MetricDescriptor
if vMetricDescriptor == nil {
// note: explicitly not the empty object.
vMetricDescriptor = &LogMetricMetricDescriptor{}
}
if err := postReadExtractLogMetricMetricDescriptorFields(r, vMetricDescriptor); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vMetricDescriptor) {
r.MetricDescriptor = vMetricDescriptor
}
vBucketOptions := r.BucketOptions
if vBucketOptions == nil {
// note: explicitly not the empty object.
vBucketOptions = &LogMetricBucketOptions{}
}
if err := postReadExtractLogMetricBucketOptionsFields(r, vBucketOptions); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vBucketOptions) {
r.BucketOptions = vBucketOptions
}
return nil
}
func postReadExtractLogMetricMetricDescriptorFields(r *LogMetric, o *LogMetricMetricDescriptor) error {
vMetadata := o.Metadata
if vMetadata == nil {
// note: explicitly not the empty object.
vMetadata = &LogMetricMetricDescriptorMetadata{}
}
if err := extractLogMetricMetricDescriptorMetadataFields(r, vMetadata); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vMetadata) {
o.Metadata = vMetadata
}
return nil
}
func postReadExtractLogMetricMetricDescriptorLabelsFields(r *LogMetric, o *LogMetricMetricDescriptorLabels) error {
return nil
}
func postReadExtractLogMetricMetricDescriptorMetadataFields(r *LogMetric, o *LogMetricMetricDescriptorMetadata) error {
return nil
}
func postReadExtractLogMetricBucketOptionsFields(r *LogMetric, o *LogMetricBucketOptions) error {
vLinearBuckets := o.LinearBuckets
if vLinearBuckets == nil {
// note: explicitly not the empty object.
vLinearBuckets = &LogMetricBucketOptionsLinearBuckets{}
}
if err := extractLogMetricBucketOptionsLinearBucketsFields(r, vLinearBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vLinearBuckets) {
o.LinearBuckets = vLinearBuckets
}
vExponentialBuckets := o.ExponentialBuckets
if vExponentialBuckets == nil {
// note: explicitly not the empty object.
vExponentialBuckets = &LogMetricBucketOptionsExponentialBuckets{}
}
if err := extractLogMetricBucketOptionsExponentialBucketsFields(r, vExponentialBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vExponentialBuckets) {
o.ExponentialBuckets = vExponentialBuckets
}
vExplicitBuckets := o.ExplicitBuckets
if vExplicitBuckets == nil {
// note: explicitly not the empty object.
vExplicitBuckets = &LogMetricBucketOptionsExplicitBuckets{}
}
if err := extractLogMetricBucketOptionsExplicitBucketsFields(r, vExplicitBuckets); err != nil {
return err
}
if !dcl.IsEmptyValueIndirect(vExplicitBuckets) {
o.ExplicitBuckets = vExplicitBuckets
}
return nil
}
func postReadExtractLogMetricBucketOptionsLinearBucketsFields(r *LogMetric, o *LogMetricBucketOptionsLinearBuckets) error {
return nil
}
func postReadExtractLogMetricBucketOptionsExponentialBucketsFields(r *LogMetric, o *LogMetricBucketOptionsExponentialBuckets) error {
return nil
}
func postReadExtractLogMetricBucketOptionsExplicitBucketsFields(r *LogMetric, o *LogMetricBucketOptionsExplicitBuckets) error {
return nil
}