configdelivery

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 31, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

Package configdelivery is an auto-generated package for the Config Delivery API.

ConfigDelivery service manages the deployment of kubernetes configuration to a fleet of kubernetes clusters.

NOTE: This package is in beta. It is not stable, and may be subject to changes.

General documentation

For information that is relevant for all client libraries please reference https://pkg.go.dev/cloud.google.com/go#pkg-overview. Some information on this page includes:

Example usage

To get started with this package, create a client.

// go get cloud.google.com/go/configdelivery/apiv1beta@latest
ctx := context.Background()
// This snippet has been automatically generated and should be regarded as a code template only.
// It will require modifications to work:
// - It may require correct/in-range values for request initialization.
// - It may require specifying regional endpoints when creating the service client as shown in:
//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
c, err := configdelivery.NewClient(ctx)
if err != nil {
	// TODO: Handle error.
}
defer c.Close()

The client will use your default application credentials. Clients should be reused instead of created as needed. The methods of Client are safe for concurrent use by multiple goroutines. The returned client must be Closed when it is done being used.

Using the Client

The following is an example of making an API call with the newly created client, mentioned above.

req := &configdeliverypb.AbortRolloutRequest{
	// TODO: Fill request struct fields.
	// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#AbortRolloutRequest.
}
op, err := c.AbortRollout(ctx, req)
if err != nil {
	// TODO: Handle error.
}

resp, err := op.Wait(ctx)
if err != nil {
	// TODO: Handle error.
}
// TODO: Use resp.
_ = resp

Use of Context

The ctx passed to NewClient is used for authentication requests and for creating the underlying connection, but is not used for subsequent calls. Individual methods on the client use the ctx given to them.

To close the open connection, use the Close() method.

Index

Examples

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultAuthScopes

func DefaultAuthScopes() []string

DefaultAuthScopes reports the default set of authentication scopes to use with this package.

Types

type AbortRolloutOperation

type AbortRolloutOperation struct {
	// contains filtered or unexported fields
}

AbortRolloutOperation manages a long-running operation from AbortRollout.

func (*AbortRolloutOperation) Done

func (op *AbortRolloutOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*AbortRolloutOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*AbortRolloutOperation) Name

func (op *AbortRolloutOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*AbortRolloutOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*AbortRolloutOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type CallOptions

type CallOptions struct {
	ListResourceBundles  []gax.CallOption
	GetResourceBundle    []gax.CallOption
	CreateResourceBundle []gax.CallOption
	UpdateResourceBundle []gax.CallOption
	DeleteResourceBundle []gax.CallOption
	ListFleetPackages    []gax.CallOption
	GetFleetPackage      []gax.CallOption
	CreateFleetPackage   []gax.CallOption
	UpdateFleetPackage   []gax.CallOption
	DeleteFleetPackage   []gax.CallOption
	ListReleases         []gax.CallOption
	GetRelease           []gax.CallOption
	CreateRelease        []gax.CallOption
	UpdateRelease        []gax.CallOption
	DeleteRelease        []gax.CallOption
	ListVariants         []gax.CallOption
	GetVariant           []gax.CallOption
	CreateVariant        []gax.CallOption
	UpdateVariant        []gax.CallOption
	DeleteVariant        []gax.CallOption
	ListRollouts         []gax.CallOption
	GetRollout           []gax.CallOption
	SuspendRollout       []gax.CallOption
	ResumeRollout        []gax.CallOption
	AbortRollout         []gax.CallOption
	GetLocation          []gax.CallOption
	ListLocations        []gax.CallOption
	CancelOperation      []gax.CallOption
	DeleteOperation      []gax.CallOption
	GetOperation         []gax.CallOption
	ListOperations       []gax.CallOption
}

CallOptions contains the retry settings for each method of Client.

type Client

type Client struct {

	// The call options for this service.
	CallOptions *CallOptions

	// LROClient is used internally to handle long-running operations.
	// It is exposed so that its CallOptions can be modified if required.
	// Users should not Close this client.
	LROClient *lroauto.OperationsClient
	// contains filtered or unexported fields
}

Client is a client for interacting with Config Delivery API. Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.

ConfigDelivery service manages the deployment of kubernetes configuration to a fleet of kubernetes clusters.

func NewClient

func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

NewClient creates a new config delivery client based on gRPC. The returned client must be Closed when it is done being used to clean up its underlying connections.

ConfigDelivery service manages the deployment of kubernetes configuration to a fleet of kubernetes clusters.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	// TODO: Use client.
	_ = c
}

func NewRESTClient

func NewRESTClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

NewRESTClient creates a new config delivery rest client.

ConfigDelivery service manages the deployment of kubernetes configuration to a fleet of kubernetes clusters.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewRESTClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	// TODO: Use client.
	_ = c
}

func (*Client) AbortRollout

AbortRollout abort a Rollout.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.AbortRolloutRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#AbortRolloutRequest.
	}
	op, err := c.AbortRollout(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) AbortRolloutOperation

func (c *Client) AbortRolloutOperation(name string) *AbortRolloutOperation

AbortRolloutOperation returns a new AbortRolloutOperation from a given name. The name must be that of a previously created AbortRolloutOperation, possibly from a different process.

func (*Client) CancelOperation

func (c *Client) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, opts ...gax.CallOption) error

CancelOperation is a utility method from google.longrunning.Operations.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &longrunningpb.CancelOperationRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/longrunning/autogen/longrunningpb#CancelOperationRequest.
	}
	err = c.CancelOperation(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
}

func (*Client) Close

func (c *Client) Close() error

Close closes the connection to the API service. The user should invoke this when the client is no longer required.

func (*Client) Connection deprecated

func (c *Client) Connection() *grpc.ClientConn

Connection returns a connection to the API service.

Deprecated: Connections are now pooled so this method does not always return the same resource.

func (*Client) CreateFleetPackage

CreateFleetPackage creates a new FleetPackage in a given project and location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.CreateFleetPackageRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#CreateFleetPackageRequest.
	}
	op, err := c.CreateFleetPackage(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) CreateFleetPackageOperation

func (c *Client) CreateFleetPackageOperation(name string) *CreateFleetPackageOperation

CreateFleetPackageOperation returns a new CreateFleetPackageOperation from a given name. The name must be that of a previously created CreateFleetPackageOperation, possibly from a different process.

func (*Client) CreateRelease

CreateRelease creates a new Release in a given project, location and resource bundle.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.CreateReleaseRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#CreateReleaseRequest.
	}
	op, err := c.CreateRelease(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) CreateReleaseOperation

func (c *Client) CreateReleaseOperation(name string) *CreateReleaseOperation

CreateReleaseOperation returns a new CreateReleaseOperation from a given name. The name must be that of a previously created CreateReleaseOperation, possibly from a different process.

func (*Client) CreateResourceBundle

CreateResourceBundle creates a new ResourceBundle in a given project and location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.CreateResourceBundleRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#CreateResourceBundleRequest.
	}
	op, err := c.CreateResourceBundle(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) CreateResourceBundleOperation

func (c *Client) CreateResourceBundleOperation(name string) *CreateResourceBundleOperation

CreateResourceBundleOperation returns a new CreateResourceBundleOperation from a given name. The name must be that of a previously created CreateResourceBundleOperation, possibly from a different process.

func (*Client) CreateVariant

CreateVariant creates a new Variant in a given project, location, resource bundle, and release.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.CreateVariantRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#CreateVariantRequest.
	}
	op, err := c.CreateVariant(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) CreateVariantOperation

func (c *Client) CreateVariantOperation(name string) *CreateVariantOperation

CreateVariantOperation returns a new CreateVariantOperation from a given name. The name must be that of a previously created CreateVariantOperation, possibly from a different process.

func (*Client) DeleteFleetPackage

DeleteFleetPackage deletes a single FleetPackage.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.DeleteFleetPackageRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#DeleteFleetPackageRequest.
	}
	op, err := c.DeleteFleetPackage(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	err = op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
}

func (*Client) DeleteFleetPackageOperation

func (c *Client) DeleteFleetPackageOperation(name string) *DeleteFleetPackageOperation

DeleteFleetPackageOperation returns a new DeleteFleetPackageOperation from a given name. The name must be that of a previously created DeleteFleetPackageOperation, possibly from a different process.

func (*Client) DeleteOperation

func (c *Client) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, opts ...gax.CallOption) error

DeleteOperation is a utility method from google.longrunning.Operations.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &longrunningpb.DeleteOperationRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/longrunning/autogen/longrunningpb#DeleteOperationRequest.
	}
	err = c.DeleteOperation(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
}

func (*Client) DeleteRelease

DeleteRelease deletes a single Release.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.DeleteReleaseRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#DeleteReleaseRequest.
	}
	op, err := c.DeleteRelease(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	err = op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
}

func (*Client) DeleteReleaseOperation

func (c *Client) DeleteReleaseOperation(name string) *DeleteReleaseOperation

DeleteReleaseOperation returns a new DeleteReleaseOperation from a given name. The name must be that of a previously created DeleteReleaseOperation, possibly from a different process.

func (*Client) DeleteResourceBundle

DeleteResourceBundle deletes a single ResourceBundle.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.DeleteResourceBundleRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#DeleteResourceBundleRequest.
	}
	op, err := c.DeleteResourceBundle(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	err = op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
}

func (*Client) DeleteResourceBundleOperation

func (c *Client) DeleteResourceBundleOperation(name string) *DeleteResourceBundleOperation

DeleteResourceBundleOperation returns a new DeleteResourceBundleOperation from a given name. The name must be that of a previously created DeleteResourceBundleOperation, possibly from a different process.

func (*Client) DeleteVariant

DeleteVariant deletes a single Variant.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.DeleteVariantRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#DeleteVariantRequest.
	}
	op, err := c.DeleteVariant(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	err = op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
}

func (*Client) DeleteVariantOperation

func (c *Client) DeleteVariantOperation(name string) *DeleteVariantOperation

DeleteVariantOperation returns a new DeleteVariantOperation from a given name. The name must be that of a previously created DeleteVariantOperation, possibly from a different process.

func (*Client) GetFleetPackage

GetFleetPackage gets details of a single FleetPackage.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.GetFleetPackageRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#GetFleetPackageRequest.
	}
	resp, err := c.GetFleetPackage(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) GetLocation

func (c *Client) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, opts ...gax.CallOption) (*locationpb.Location, error)

GetLocation gets information about a location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	locationpb "google.golang.org/genproto/googleapis/cloud/location"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &locationpb.GetLocationRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/location#GetLocationRequest.
	}
	resp, err := c.GetLocation(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) GetOperation

GetOperation is a utility method from google.longrunning.Operations.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &longrunningpb.GetOperationRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/longrunning/autogen/longrunningpb#GetOperationRequest.
	}
	resp, err := c.GetOperation(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) GetRelease

GetRelease gets details of a single Release.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.GetReleaseRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#GetReleaseRequest.
	}
	resp, err := c.GetRelease(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) GetResourceBundle

GetResourceBundle gets details of a single ResourceBundle.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.GetResourceBundleRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#GetResourceBundleRequest.
	}
	resp, err := c.GetResourceBundle(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) GetRollout

GetRollout gets details of a single Rollout.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.GetRolloutRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#GetRolloutRequest.
	}
	resp, err := c.GetRollout(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) GetVariant

GetVariant gets details of a single Variant.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.GetVariantRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#GetVariantRequest.
	}
	resp, err := c.GetVariant(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) ListFleetPackages

ListFleetPackages lists FleetPackages in a given project and location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
	"google.golang.org/api/iterator"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListFleetPackagesRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListFleetPackagesRequest.
	}
	it := c.ListFleetPackages(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*configdeliverypb.ListFleetPackagesResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListFleetPackagesRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListFleetPackagesRequest.
	}
	for resp, err := range c.ListFleetPackages(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ListLocations

func (c *Client) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, opts ...gax.CallOption) *LocationIterator

ListLocations lists information about the supported locations for this service.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	"google.golang.org/api/iterator"

	locationpb "google.golang.org/genproto/googleapis/cloud/location"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &locationpb.ListLocationsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/location#ListLocationsRequest.
	}
	it := c.ListLocations(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*locationpb.ListLocationsResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	locationpb "google.golang.org/genproto/googleapis/cloud/location"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &locationpb.ListLocationsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/location#ListLocationsRequest.
	}
	for resp, err := range c.ListLocations(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ListOperations

ListOperations is a utility method from google.longrunning.Operations.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
	"google.golang.org/api/iterator"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &longrunningpb.ListOperationsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/longrunning/autogen/longrunningpb#ListOperationsRequest.
	}
	it := c.ListOperations(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*longrunningpb.ListOperationsResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"

	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &longrunningpb.ListOperationsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/longrunning/autogen/longrunningpb#ListOperationsRequest.
	}
	for resp, err := range c.ListOperations(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ListReleases

ListReleases lists Releases in a given project and location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
	"google.golang.org/api/iterator"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListReleasesRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListReleasesRequest.
	}
	it := c.ListReleases(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*configdeliverypb.ListReleasesResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListReleasesRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListReleasesRequest.
	}
	for resp, err := range c.ListReleases(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ListResourceBundles

ListResourceBundles lists ResourceBundles in a given project and location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
	"google.golang.org/api/iterator"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListResourceBundlesRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListResourceBundlesRequest.
	}
	it := c.ListResourceBundles(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*configdeliverypb.ListResourceBundlesResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListResourceBundlesRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListResourceBundlesRequest.
	}
	for resp, err := range c.ListResourceBundles(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ListRollouts

ListRollouts lists Rollouts in a given project, location, and Fleet Package.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
	"google.golang.org/api/iterator"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListRolloutsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListRolloutsRequest.
	}
	it := c.ListRollouts(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*configdeliverypb.ListRolloutsResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListRolloutsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListRolloutsRequest.
	}
	for resp, err := range c.ListRollouts(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ListVariants

ListVariants lists Variants in a given project and location.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
	"google.golang.org/api/iterator"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListVariantsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListVariantsRequest.
	}
	it := c.ListVariants(ctx, req)
	for {
		resp, err := it.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			// TODO: Handle error.
		}
		// TODO: Use resp.
		_ = resp

		// If you need to access the underlying RPC response,
		// you can do so by casting the `Response` as below.
		// Otherwise, remove this line. Only populated after
		// first call to Next(). Not safe for concurrent access.
		_ = it.Response.(*configdeliverypb.ListVariantsResponse)
	}
}
Example (All)
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ListVariantsRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ListVariantsRequest.
	}
	for resp, err := range c.ListVariants(ctx, req).All() {
		if err != nil {
			// TODO: Handle error and break/return/continue. Iteration will stop after any error.
		}
		// TODO: Use resp.
		_ = resp
	}
}

func (*Client) ResumeRollout

ResumeRollout resume a Rollout.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.ResumeRolloutRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#ResumeRolloutRequest.
	}
	op, err := c.ResumeRollout(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) ResumeRolloutOperation

func (c *Client) ResumeRolloutOperation(name string) *ResumeRolloutOperation

ResumeRolloutOperation returns a new ResumeRolloutOperation from a given name. The name must be that of a previously created ResumeRolloutOperation, possibly from a different process.

func (*Client) SuspendRollout

SuspendRollout suspend a Rollout.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.SuspendRolloutRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#SuspendRolloutRequest.
	}
	op, err := c.SuspendRollout(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) SuspendRolloutOperation

func (c *Client) SuspendRolloutOperation(name string) *SuspendRolloutOperation

SuspendRolloutOperation returns a new SuspendRolloutOperation from a given name. The name must be that of a previously created SuspendRolloutOperation, possibly from a different process.

func (*Client) UpdateFleetPackage

UpdateFleetPackage updates the parameters of a single FleetPackage.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.UpdateFleetPackageRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#UpdateFleetPackageRequest.
	}
	op, err := c.UpdateFleetPackage(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) UpdateFleetPackageOperation

func (c *Client) UpdateFleetPackageOperation(name string) *UpdateFleetPackageOperation

UpdateFleetPackageOperation returns a new UpdateFleetPackageOperation from a given name. The name must be that of a previously created UpdateFleetPackageOperation, possibly from a different process.

func (*Client) UpdateRelease

UpdateRelease updates the parameters of a single Release.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.UpdateReleaseRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#UpdateReleaseRequest.
	}
	op, err := c.UpdateRelease(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) UpdateReleaseOperation

func (c *Client) UpdateReleaseOperation(name string) *UpdateReleaseOperation

UpdateReleaseOperation returns a new UpdateReleaseOperation from a given name. The name must be that of a previously created UpdateReleaseOperation, possibly from a different process.

func (*Client) UpdateResourceBundle

UpdateResourceBundle updates the parameters of a single ResourceBundle.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.UpdateResourceBundleRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#UpdateResourceBundleRequest.
	}
	op, err := c.UpdateResourceBundle(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) UpdateResourceBundleOperation

func (c *Client) UpdateResourceBundleOperation(name string) *UpdateResourceBundleOperation

UpdateResourceBundleOperation returns a new UpdateResourceBundleOperation from a given name. The name must be that of a previously created UpdateResourceBundleOperation, possibly from a different process.

func (*Client) UpdateVariant

UpdateVariant updates the parameters of a single Variant.

Example
package main

import (
	"context"

	configdelivery "cloud.google.com/go/configdelivery/apiv1beta"
	configdeliverypb "cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb"
)

func main() {
	ctx := context.Background()
	// This snippet has been automatically generated and should be regarded as a code template only.
	// It will require modifications to work:
	// - It may require correct/in-range values for request initialization.
	// - It may require specifying regional endpoints when creating the service client as shown in:
	//   https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options
	c, err := configdelivery.NewClient(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	defer c.Close()

	req := &configdeliverypb.UpdateVariantRequest{
		// TODO: Fill request struct fields.
		// See https://pkg.go.dev/cloud.google.com/go/configdelivery/apiv1beta/configdeliverypb#UpdateVariantRequest.
	}
	op, err := c.UpdateVariant(ctx, req)
	if err != nil {
		// TODO: Handle error.
	}

	resp, err := op.Wait(ctx)
	if err != nil {
		// TODO: Handle error.
	}
	// TODO: Use resp.
	_ = resp
}

func (*Client) UpdateVariantOperation

func (c *Client) UpdateVariantOperation(name string) *UpdateVariantOperation

UpdateVariantOperation returns a new UpdateVariantOperation from a given name. The name must be that of a previously created UpdateVariantOperation, possibly from a different process.

type CreateFleetPackageOperation

type CreateFleetPackageOperation struct {
	// contains filtered or unexported fields
}

CreateFleetPackageOperation manages a long-running operation from CreateFleetPackage.

func (*CreateFleetPackageOperation) Done

func (op *CreateFleetPackageOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*CreateFleetPackageOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*CreateFleetPackageOperation) Name

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*CreateFleetPackageOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*CreateFleetPackageOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type CreateReleaseOperation

type CreateReleaseOperation struct {
	// contains filtered or unexported fields
}

CreateReleaseOperation manages a long-running operation from CreateRelease.

func (*CreateReleaseOperation) Done

func (op *CreateReleaseOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*CreateReleaseOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*CreateReleaseOperation) Name

func (op *CreateReleaseOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*CreateReleaseOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*CreateReleaseOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type CreateResourceBundleOperation

type CreateResourceBundleOperation struct {
	// contains filtered or unexported fields
}

CreateResourceBundleOperation manages a long-running operation from CreateResourceBundle.

func (*CreateResourceBundleOperation) Done

Done reports whether the long-running operation has completed.

func (*CreateResourceBundleOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*CreateResourceBundleOperation) Name

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*CreateResourceBundleOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*CreateResourceBundleOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type CreateVariantOperation

type CreateVariantOperation struct {
	// contains filtered or unexported fields
}

CreateVariantOperation manages a long-running operation from CreateVariant.

func (*CreateVariantOperation) Done

func (op *CreateVariantOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*CreateVariantOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*CreateVariantOperation) Name

func (op *CreateVariantOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*CreateVariantOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*CreateVariantOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type DeleteFleetPackageOperation

type DeleteFleetPackageOperation struct {
	// contains filtered or unexported fields
}

DeleteFleetPackageOperation manages a long-running operation from DeleteFleetPackage.

func (*DeleteFleetPackageOperation) Done

func (op *DeleteFleetPackageOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*DeleteFleetPackageOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*DeleteFleetPackageOperation) Name

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*DeleteFleetPackageOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*DeleteFleetPackageOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type DeleteReleaseOperation

type DeleteReleaseOperation struct {
	// contains filtered or unexported fields
}

DeleteReleaseOperation manages a long-running operation from DeleteRelease.

func (*DeleteReleaseOperation) Done

func (op *DeleteReleaseOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*DeleteReleaseOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*DeleteReleaseOperation) Name

func (op *DeleteReleaseOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*DeleteReleaseOperation) Poll

func (op *DeleteReleaseOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*DeleteReleaseOperation) Wait

func (op *DeleteReleaseOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type DeleteResourceBundleOperation

type DeleteResourceBundleOperation struct {
	// contains filtered or unexported fields
}

DeleteResourceBundleOperation manages a long-running operation from DeleteResourceBundle.

func (*DeleteResourceBundleOperation) Done

Done reports whether the long-running operation has completed.

func (*DeleteResourceBundleOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*DeleteResourceBundleOperation) Name

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*DeleteResourceBundleOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*DeleteResourceBundleOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type DeleteVariantOperation

type DeleteVariantOperation struct {
	// contains filtered or unexported fields
}

DeleteVariantOperation manages a long-running operation from DeleteVariant.

func (*DeleteVariantOperation) Done

func (op *DeleteVariantOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*DeleteVariantOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*DeleteVariantOperation) Name

func (op *DeleteVariantOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*DeleteVariantOperation) Poll

func (op *DeleteVariantOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*DeleteVariantOperation) Wait

func (op *DeleteVariantOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type FleetPackageIterator

type FleetPackageIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*configdeliverypb.FleetPackage, nextPageToken string, err error)
	// contains filtered or unexported fields
}

FleetPackageIterator manages a stream of *configdeliverypb.FleetPackage.

func (*FleetPackageIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*FleetPackageIterator) Next

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*FleetPackageIterator) PageInfo

func (it *FleetPackageIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

type LocationIterator

type LocationIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*locationpb.Location, nextPageToken string, err error)
	// contains filtered or unexported fields
}

LocationIterator manages a stream of *locationpb.Location.

func (*LocationIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*LocationIterator) Next

func (it *LocationIterator) Next() (*locationpb.Location, error)

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*LocationIterator) PageInfo

func (it *LocationIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

type OperationIterator

type OperationIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*longrunningpb.Operation, nextPageToken string, err error)
	// contains filtered or unexported fields
}

OperationIterator manages a stream of *longrunningpb.Operation.

func (*OperationIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*OperationIterator) Next

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*OperationIterator) PageInfo

func (it *OperationIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

type ReleaseIterator

type ReleaseIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*configdeliverypb.Release, nextPageToken string, err error)
	// contains filtered or unexported fields
}

ReleaseIterator manages a stream of *configdeliverypb.Release.

func (*ReleaseIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*ReleaseIterator) Next

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*ReleaseIterator) PageInfo

func (it *ReleaseIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

type ResourceBundleIterator

type ResourceBundleIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*configdeliverypb.ResourceBundle, nextPageToken string, err error)
	// contains filtered or unexported fields
}

ResourceBundleIterator manages a stream of *configdeliverypb.ResourceBundle.

func (*ResourceBundleIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*ResourceBundleIterator) Next

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*ResourceBundleIterator) PageInfo

func (it *ResourceBundleIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

type ResumeRolloutOperation

type ResumeRolloutOperation struct {
	// contains filtered or unexported fields
}

ResumeRolloutOperation manages a long-running operation from ResumeRollout.

func (*ResumeRolloutOperation) Done

func (op *ResumeRolloutOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*ResumeRolloutOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*ResumeRolloutOperation) Name

func (op *ResumeRolloutOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*ResumeRolloutOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*ResumeRolloutOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type RolloutIterator

type RolloutIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*configdeliverypb.Rollout, nextPageToken string, err error)
	// contains filtered or unexported fields
}

RolloutIterator manages a stream of *configdeliverypb.Rollout.

func (*RolloutIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*RolloutIterator) Next

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*RolloutIterator) PageInfo

func (it *RolloutIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

type SuspendRolloutOperation

type SuspendRolloutOperation struct {
	// contains filtered or unexported fields
}

SuspendRolloutOperation manages a long-running operation from SuspendRollout.

func (*SuspendRolloutOperation) Done

func (op *SuspendRolloutOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*SuspendRolloutOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*SuspendRolloutOperation) Name

func (op *SuspendRolloutOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*SuspendRolloutOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*SuspendRolloutOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type UpdateFleetPackageOperation

type UpdateFleetPackageOperation struct {
	// contains filtered or unexported fields
}

UpdateFleetPackageOperation manages a long-running operation from UpdateFleetPackage.

func (*UpdateFleetPackageOperation) Done

func (op *UpdateFleetPackageOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*UpdateFleetPackageOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*UpdateFleetPackageOperation) Name

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*UpdateFleetPackageOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*UpdateFleetPackageOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type UpdateReleaseOperation

type UpdateReleaseOperation struct {
	// contains filtered or unexported fields
}

UpdateReleaseOperation manages a long-running operation from UpdateRelease.

func (*UpdateReleaseOperation) Done

func (op *UpdateReleaseOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*UpdateReleaseOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*UpdateReleaseOperation) Name

func (op *UpdateReleaseOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*UpdateReleaseOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*UpdateReleaseOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type UpdateResourceBundleOperation

type UpdateResourceBundleOperation struct {
	// contains filtered or unexported fields
}

UpdateResourceBundleOperation manages a long-running operation from UpdateResourceBundle.

func (*UpdateResourceBundleOperation) Done

Done reports whether the long-running operation has completed.

func (*UpdateResourceBundleOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*UpdateResourceBundleOperation) Name

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*UpdateResourceBundleOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*UpdateResourceBundleOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type UpdateVariantOperation

type UpdateVariantOperation struct {
	// contains filtered or unexported fields
}

UpdateVariantOperation manages a long-running operation from UpdateVariant.

func (*UpdateVariantOperation) Done

func (op *UpdateVariantOperation) Done() bool

Done reports whether the long-running operation has completed.

func (*UpdateVariantOperation) Metadata

Metadata returns metadata associated with the long-running operation. Metadata itself does not contact the server, but Poll does. To get the latest metadata, call this method after a successful call to Poll. If the metadata is not available, the returned metadata and error are both nil.

func (*UpdateVariantOperation) Name

func (op *UpdateVariantOperation) Name() string

Name returns the name of the long-running operation. The name is assigned by the server and is unique within the service from which the operation is created.

func (*UpdateVariantOperation) Poll

Poll fetches the latest state of the long-running operation.

Poll also fetches the latest metadata, which can be retrieved by Metadata.

If Poll fails, the error is returned and op is unmodified. If Poll succeeds and the operation has completed with failure, the error is returned and op.Done will return true. If Poll succeeds and the operation has completed successfully, op.Done will return true, and the response of the operation is returned. If Poll succeeds and the operation has not completed, the returned response and error are both nil.

func (*UpdateVariantOperation) Wait

Wait blocks until the long-running operation is completed, returning the response and any errors encountered.

See documentation of Poll for error-handling information.

type VariantIterator

type VariantIterator struct {

	// Response is the raw response for the current page.
	// It must be cast to the RPC response type.
	// Calling Next() or InternalFetch() updates this value.
	Response interface{}

	// InternalFetch is for use by the Google Cloud Libraries only.
	// It is not part of the stable interface of this package.
	//
	// InternalFetch returns results from a single call to the underlying RPC.
	// The number of results is no greater than pageSize.
	// If there are no more results, nextPageToken is empty and err is nil.
	InternalFetch func(pageSize int, pageToken string) (results []*configdeliverypb.Variant, nextPageToken string, err error)
	// contains filtered or unexported fields
}

VariantIterator manages a stream of *configdeliverypb.Variant.

func (*VariantIterator) All

All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.

func (*VariantIterator) Next

Next returns the next result. Its second return value is iterator.Done if there are no more results. Once Next returns Done, all subsequent calls will return Done.

func (*VariantIterator) PageInfo

func (it *VariantIterator) PageInfo() *iterator.PageInfo

PageInfo supports pagination. See the google.golang.org/api/iterator package for details.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL