Package gkemulticloud is an auto-generated package for the GKE Multi-Cloud API.
GKE Multi-Cloud provides a way to manage Kubernetes clusters that run on AWS and Azure infrastructure using the GKE Multi-Cloud API. Combined with Connect, you can manage Kubernetes clusters on Google Cloud, AWS, and Azure from the Google Cloud Console. When you create a cluster with GKE Multi-Cloud, Google creates the resources needed and brings up a cluster on your behalf. You can deploy workloads with the GKE Multi-Cloud API or the gcloud and kubectl command-line tools.
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:
- Authentication and Authorization
- Timeouts and Cancellation
- Testing against Client Libraries
- Debugging Client Libraries
- Inspecting errors
Example usage
To get started with this package, create a client.
// go get cloud.google.com/go/gkemulticloud/apiv1@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 := gkemulticloud.NewAttachedClustersClient(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 := &gkemulticloudpb.CreateAttachedClusterRequest{ // TODO: Fill request struct fields. // See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAttachedClusterRequest. } op, err := c.CreateAttachedCluster(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 NewAttachedClustersClient 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.
Functions
func DefaultAuthScopes
func DefaultAuthScopes() []stringDefaultAuthScopes reports the default set of authentication scopes to use with this package.
AttachedClusterIterator
type AttachedClusterIterator 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 []*gkemulticloudpb.AttachedCluster, nextPageToken string, err error)
// contains filtered or unexported fields
}AttachedClusterIterator manages a stream of *gkemulticloudpb.AttachedCluster.
func (*AttachedClusterIterator) All
func (it *AttachedClusterIterator) All() iter.Seq2[*gkemulticloudpb.AttachedCluster, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*AttachedClusterIterator) Next
func (it *AttachedClusterIterator) Next() (*gkemulticloudpb.AttachedCluster, 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 (*AttachedClusterIterator) PageInfo
func (it *AttachedClusterIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
AttachedClustersCallOptions
type AttachedClustersCallOptions struct {
CreateAttachedCluster []gax.CallOption
UpdateAttachedCluster []gax.CallOption
ImportAttachedCluster []gax.CallOption
GetAttachedCluster []gax.CallOption
ListAttachedClusters []gax.CallOption
DeleteAttachedCluster []gax.CallOption
GetAttachedServerConfig []gax.CallOption
GenerateAttachedClusterInstallManifest []gax.CallOption
GenerateAttachedClusterAgentToken []gax.CallOption
CancelOperation []gax.CallOption
DeleteOperation []gax.CallOption
GetOperation []gax.CallOption
ListOperations []gax.CallOption
}AttachedClustersCallOptions contains the retry settings for each method of AttachedClustersClient.
AttachedClustersClient
type AttachedClustersClient struct {
// The call options for this service.
CallOptions *AttachedClustersCallOptions
// 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
}AttachedClustersClient is a client for interacting with GKE Multi-Cloud API. Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.
The AttachedClusters API provides a single centrally managed service to register and manage Anthos attached clusters that run on customer’s owned infrastructure.
func NewAttachedClustersClient
func NewAttachedClustersClient(ctx context.Context, opts ...option.ClientOption) (*AttachedClustersClient, error)NewAttachedClustersClient creates a new attached clusters client based on gRPC. The returned client must be Closed when it is done being used to clean up its underlying connections.
The AttachedClusters API provides a single centrally managed service to register and manage Anthos attached clusters that run on customer’s owned infrastructure.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
// TODO: Use client.
_ = c
}
func (*AttachedClustersClient) CancelOperation
func (c *AttachedClustersClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, opts ...gax.CallOption) errorCancelOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAttachedClustersClient(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 (*AttachedClustersClient) Close
func (c *AttachedClustersClient) Close() errorClose closes the connection to the API service. The user should invoke this when the client is no longer required.
func (*AttachedClustersClient) Connection (deprecated)
func (c *AttachedClustersClient) Connection() *grpc.ClientConnConnection returns a connection to the API service.
Deprecated: Connections are now pooled so this method does not always return the same resource.
func (*AttachedClustersClient) CreateAttachedCluster
func (c *AttachedClustersClient) CreateAttachedCluster(ctx context.Context, req *gkemulticloudpb.CreateAttachedClusterRequest, opts ...gax.CallOption) (*CreateAttachedClusterOperation, error)CreateAttachedCluster creates a new AttachedCluster resource on a given Google Cloud Platform project and region.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.CreateAttachedClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAttachedClusterRequest.
}
op, err := c.CreateAttachedCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) CreateAttachedClusterOperation
func (c *AttachedClustersClient) CreateAttachedClusterOperation(name string) *CreateAttachedClusterOperationCreateAttachedClusterOperation returns a new CreateAttachedClusterOperation from a given name. The name must be that of a previously created CreateAttachedClusterOperation, possibly from a different process.
func (*AttachedClustersClient) DeleteAttachedCluster
func (c *AttachedClustersClient) DeleteAttachedCluster(ctx context.Context, req *gkemulticloudpb.DeleteAttachedClusterRequest, opts ...gax.CallOption) (*DeleteAttachedClusterOperation, error)DeleteAttachedCluster deletes a specific AttachedCluster resource.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.DeleteAttachedClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#DeleteAttachedClusterRequest.
}
op, err := c.DeleteAttachedCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
err = op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
}
func (*AttachedClustersClient) DeleteAttachedClusterOperation
func (c *AttachedClustersClient) DeleteAttachedClusterOperation(name string) *DeleteAttachedClusterOperationDeleteAttachedClusterOperation returns a new DeleteAttachedClusterOperation from a given name. The name must be that of a previously created DeleteAttachedClusterOperation, possibly from a different process.
func (*AttachedClustersClient) DeleteOperation
func (c *AttachedClustersClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, opts ...gax.CallOption) errorDeleteOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAttachedClustersClient(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 (*AttachedClustersClient) GenerateAttachedClusterAgentToken
func (c *AttachedClustersClient) GenerateAttachedClusterAgentToken(ctx context.Context, req *gkemulticloudpb.GenerateAttachedClusterAgentTokenRequest, opts ...gax.CallOption) (*gkemulticloudpb.GenerateAttachedClusterAgentTokenResponse, error)GenerateAttachedClusterAgentToken generates an access token for a cluster agent.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GenerateAttachedClusterAgentTokenRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GenerateAttachedClusterAgentTokenRequest.
}
resp, err := c.GenerateAttachedClusterAgentToken(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) GenerateAttachedClusterInstallManifest
func (c *AttachedClustersClient) GenerateAttachedClusterInstallManifest(ctx context.Context, req *gkemulticloudpb.GenerateAttachedClusterInstallManifestRequest, opts ...gax.CallOption) (*gkemulticloudpb.GenerateAttachedClusterInstallManifestResponse, error)GenerateAttachedClusterInstallManifest generates the install manifest to be installed on the target cluster.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GenerateAttachedClusterInstallManifestRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GenerateAttachedClusterInstallManifestRequest.
}
resp, err := c.GenerateAttachedClusterInstallManifest(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) GetAttachedCluster
func (c *AttachedClustersClient) GetAttachedCluster(ctx context.Context, req *gkemulticloudpb.GetAttachedClusterRequest, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, error)GetAttachedCluster describes a specific AttachedCluster resource.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAttachedClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAttachedClusterRequest.
}
resp, err := c.GetAttachedCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) GetAttachedServerConfig
func (c *AttachedClustersClient) GetAttachedServerConfig(ctx context.Context, req *gkemulticloudpb.GetAttachedServerConfigRequest, opts ...gax.CallOption) (*gkemulticloudpb.AttachedServerConfig, error)GetAttachedServerConfig returns information, such as supported Kubernetes versions, on a given Google Cloud location.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAttachedServerConfigRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAttachedServerConfigRequest.
}
resp, err := c.GetAttachedServerConfig(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) GetOperation
func (c *AttachedClustersClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, opts ...gax.CallOption) (*longrunningpb.Operation, error)GetOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAttachedClustersClient(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 (*AttachedClustersClient) ImportAttachedCluster
func (c *AttachedClustersClient) ImportAttachedCluster(ctx context.Context, req *gkemulticloudpb.ImportAttachedClusterRequest, opts ...gax.CallOption) (*ImportAttachedClusterOperation, error)ImportAttachedCluster imports creates a new AttachedCluster resource by importing an existing Fleet Membership resource.
Attached Clusters created before the introduction of the Anthos Multi-Cloud API can be imported through this method.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ImportAttachedClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ImportAttachedClusterRequest.
}
op, err := c.ImportAttachedCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) ImportAttachedClusterOperation
func (c *AttachedClustersClient) ImportAttachedClusterOperation(name string) *ImportAttachedClusterOperationImportAttachedClusterOperation returns a new ImportAttachedClusterOperation from a given name. The name must be that of a previously created ImportAttachedClusterOperation, possibly from a different process.
func (*AttachedClustersClient) ListAttachedClusters
func (c *AttachedClustersClient) ListAttachedClusters(ctx context.Context, req *gkemulticloudpb.ListAttachedClustersRequest, opts ...gax.CallOption) *AttachedClusterIteratorListAttachedClusters lists all AttachedCluster resources on a given Google Cloud project and region.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
"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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAttachedClustersRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAttachedClustersRequest.
}
it := c.ListAttachedClusters(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.(*gkemulticloudpb.ListAttachedClustersResponse)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAttachedClustersRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAttachedClustersRequest.
}
for resp, err := range c.ListAttachedClusters(ctx, req).All() {
if err != nil {
// TODO: Handle error and break/return/continue. Iteration will stop after any error.
}
// TODO: Use resp.
_ = resp
}
}
func (*AttachedClustersClient) ListOperations
func (c *AttachedClustersClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, opts ...gax.CallOption) *OperationIteratorListOperations is a utility method from google.longrunning.Operations.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAttachedClustersClient(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)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAttachedClustersClient(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 (*AttachedClustersClient) UpdateAttachedCluster
func (c *AttachedClustersClient) UpdateAttachedCluster(ctx context.Context, req *gkemulticloudpb.UpdateAttachedClusterRequest, opts ...gax.CallOption) (*UpdateAttachedClusterOperation, error)UpdateAttachedCluster updates an AttachedCluster.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAttachedClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.UpdateAttachedClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#UpdateAttachedClusterRequest.
}
op, err := c.UpdateAttachedCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AttachedClustersClient) UpdateAttachedClusterOperation
func (c *AttachedClustersClient) UpdateAttachedClusterOperation(name string) *UpdateAttachedClusterOperationUpdateAttachedClusterOperation returns a new UpdateAttachedClusterOperation from a given name. The name must be that of a previously created UpdateAttachedClusterOperation, possibly from a different process.
AwsClusterIterator
type AwsClusterIterator 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 []*gkemulticloudpb.AwsCluster, nextPageToken string, err error)
// contains filtered or unexported fields
}AwsClusterIterator manages a stream of *gkemulticloudpb.AwsCluster.
func (*AwsClusterIterator) All
func (it *AwsClusterIterator) All() iter.Seq2[*gkemulticloudpb.AwsCluster, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*AwsClusterIterator) Next
func (it *AwsClusterIterator) Next() (*gkemulticloudpb.AwsCluster, 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 (*AwsClusterIterator) PageInfo
func (it *AwsClusterIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
AwsClustersCallOptions
type AwsClustersCallOptions struct {
CreateAwsCluster []gax.CallOption
UpdateAwsCluster []gax.CallOption
GetAwsCluster []gax.CallOption
ListAwsClusters []gax.CallOption
DeleteAwsCluster []gax.CallOption
GenerateAwsClusterAgentToken []gax.CallOption
GenerateAwsAccessToken []gax.CallOption
CreateAwsNodePool []gax.CallOption
UpdateAwsNodePool []gax.CallOption
RollbackAwsNodePoolUpdate []gax.CallOption
GetAwsNodePool []gax.CallOption
ListAwsNodePools []gax.CallOption
DeleteAwsNodePool []gax.CallOption
GetAwsOpenIdConfig []gax.CallOption
GetAwsJsonWebKeys []gax.CallOption
GetAwsServerConfig []gax.CallOption
CancelOperation []gax.CallOption
DeleteOperation []gax.CallOption
GetOperation []gax.CallOption
ListOperations []gax.CallOption
}AwsClustersCallOptions contains the retry settings for each method of AwsClustersClient.
AwsClustersClient (deprecated)
type AwsClustersClient struct {
// The call options for this service.
CallOptions *AwsClustersCallOptions
// 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
}AwsClustersClient is a client for interacting with GKE Multi-Cloud API. Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.
The AwsClusters API provides a single centrally managed service to create and manage Anthos clusters that run on AWS infrastructure.
Deprecated: AwsClusters may be removed in a future version.
func NewAwsClustersClient (deprecated)
func NewAwsClustersClient(ctx context.Context, opts ...option.ClientOption) (*AwsClustersClient, error)NewAwsClustersClient creates a new aws clusters client based on gRPC. The returned client must be Closed when it is done being used to clean up its underlying connections.
The AwsClusters API provides a single centrally managed service to create and manage Anthos clusters that run on AWS infrastructure.
Deprecated: AwsClusters may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
// TODO: Use client.
_ = c
}
func (*AwsClustersClient) CancelOperation (deprecated)
func (c *AwsClustersClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, opts ...gax.CallOption) errorCancelOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAwsClustersClient(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 (*AwsClustersClient) Close (deprecated)
func (c *AwsClustersClient) Close() errorClose closes the connection to the API service. The user should invoke this when the client is no longer required.
func (*AwsClustersClient) Connection (deprecated)
func (c *AwsClustersClient) Connection() *grpc.ClientConnConnection returns a connection to the API service.
Deprecated: Connections are now pooled so this method does not always return the same resource.
func (*AwsClustersClient) CreateAwsCluster (deprecated)
func (c *AwsClustersClient) CreateAwsCluster(ctx context.Context, req *gkemulticloudpb.CreateAwsClusterRequest, opts ...gax.CallOption) (*CreateAwsClusterOperation, error)CreateAwsCluster creates a new AwsCluster resource on a given Google Cloud Platform project and region.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: CreateAwsCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.CreateAwsClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAwsClusterRequest.
}
op, err := c.CreateAwsCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) CreateAwsClusterOperation (deprecated)
func (c *AwsClustersClient) CreateAwsClusterOperation(name string) *CreateAwsClusterOperationCreateAwsClusterOperation returns a new CreateAwsClusterOperation from a given name. The name must be that of a previously created CreateAwsClusterOperation, possibly from a different process.
func (*AwsClustersClient) CreateAwsNodePool (deprecated)
func (c *AwsClustersClient) CreateAwsNodePool(ctx context.Context, req *gkemulticloudpb.CreateAwsNodePoolRequest, opts ...gax.CallOption) (*CreateAwsNodePoolOperation, error)CreateAwsNodePool creates a new AwsNodePool, attached to a given AwsCluster.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: CreateAwsNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.CreateAwsNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAwsNodePoolRequest.
}
op, err := c.CreateAwsNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) CreateAwsNodePoolOperation (deprecated)
func (c *AwsClustersClient) CreateAwsNodePoolOperation(name string) *CreateAwsNodePoolOperationCreateAwsNodePoolOperation returns a new CreateAwsNodePoolOperation from a given name. The name must be that of a previously created CreateAwsNodePoolOperation, possibly from a different process.
func (*AwsClustersClient) DeleteAwsCluster (deprecated)
func (c *AwsClustersClient) DeleteAwsCluster(ctx context.Context, req *gkemulticloudpb.DeleteAwsClusterRequest, opts ...gax.CallOption) (*DeleteAwsClusterOperation, error)DeleteAwsCluster deletes a specific AwsCluster resource.
Fails if the cluster has one or more associated AwsNodePool resources.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: DeleteAwsCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.DeleteAwsClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#DeleteAwsClusterRequest.
}
op, err := c.DeleteAwsCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
err = op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
}
func (*AwsClustersClient) DeleteAwsClusterOperation (deprecated)
func (c *AwsClustersClient) DeleteAwsClusterOperation(name string) *DeleteAwsClusterOperationDeleteAwsClusterOperation returns a new DeleteAwsClusterOperation from a given name. The name must be that of a previously created DeleteAwsClusterOperation, possibly from a different process.
func (*AwsClustersClient) DeleteAwsNodePool (deprecated)
func (c *AwsClustersClient) DeleteAwsNodePool(ctx context.Context, req *gkemulticloudpb.DeleteAwsNodePoolRequest, opts ...gax.CallOption) (*DeleteAwsNodePoolOperation, error)DeleteAwsNodePool deletes a specific AwsNodePool resource.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: DeleteAwsNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.DeleteAwsNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#DeleteAwsNodePoolRequest.
}
op, err := c.DeleteAwsNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
err = op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
}
func (*AwsClustersClient) DeleteAwsNodePoolOperation (deprecated)
func (c *AwsClustersClient) DeleteAwsNodePoolOperation(name string) *DeleteAwsNodePoolOperationDeleteAwsNodePoolOperation returns a new DeleteAwsNodePoolOperation from a given name. The name must be that of a previously created DeleteAwsNodePoolOperation, possibly from a different process.
func (*AwsClustersClient) DeleteOperation (deprecated)
func (c *AwsClustersClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, opts ...gax.CallOption) errorDeleteOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAwsClustersClient(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 (*AwsClustersClient) GenerateAwsAccessToken (deprecated)
func (c *AwsClustersClient) GenerateAwsAccessToken(ctx context.Context, req *gkemulticloudpb.GenerateAwsAccessTokenRequest, opts ...gax.CallOption) (*gkemulticloudpb.GenerateAwsAccessTokenResponse, error)GenerateAwsAccessToken generates a short-lived access token to authenticate to a given AwsCluster resource.
Deprecated: GenerateAwsAccessToken may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GenerateAwsAccessTokenRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GenerateAwsAccessTokenRequest.
}
resp, err := c.GenerateAwsAccessToken(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GenerateAwsClusterAgentToken (deprecated)
func (c *AwsClustersClient) GenerateAwsClusterAgentToken(ctx context.Context, req *gkemulticloudpb.GenerateAwsClusterAgentTokenRequest, opts ...gax.CallOption) (*gkemulticloudpb.GenerateAwsClusterAgentTokenResponse, error)GenerateAwsClusterAgentToken generates an access token for a cluster agent.
Deprecated: GenerateAwsClusterAgentToken may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GenerateAwsClusterAgentTokenRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GenerateAwsClusterAgentTokenRequest.
}
resp, err := c.GenerateAwsClusterAgentToken(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GetAwsCluster (deprecated)
func (c *AwsClustersClient) GetAwsCluster(ctx context.Context, req *gkemulticloudpb.GetAwsClusterRequest, opts ...gax.CallOption) (*gkemulticloudpb.AwsCluster, error)GetAwsCluster describes a specific AwsCluster resource.
Deprecated: GetAwsCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAwsClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAwsClusterRequest.
}
resp, err := c.GetAwsCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GetAwsJsonWebKeys (deprecated)
func (c *AwsClustersClient) GetAwsJsonWebKeys(ctx context.Context, req *gkemulticloudpb.GetAwsJsonWebKeysRequest, opts ...gax.CallOption) (*gkemulticloudpb.AwsJsonWebKeys, error)GetAwsJsonWebKeys gets the public component of the cluster signing keys in JSON Web Key format.
Deprecated: GetAwsJsonWebKeys may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAwsJsonWebKeysRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAwsJsonWebKeysRequest.
}
resp, err := c.GetAwsJsonWebKeys(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GetAwsNodePool (deprecated)
func (c *AwsClustersClient) GetAwsNodePool(ctx context.Context, req *gkemulticloudpb.GetAwsNodePoolRequest, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, error)GetAwsNodePool describes a specific AwsNodePool resource.
Deprecated: GetAwsNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAwsNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAwsNodePoolRequest.
}
resp, err := c.GetAwsNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GetAwsOpenIdConfig (deprecated)
func (c *AwsClustersClient) GetAwsOpenIdConfig(ctx context.Context, req *gkemulticloudpb.GetAwsOpenIdConfigRequest, opts ...gax.CallOption) (*gkemulticloudpb.AwsOpenIdConfig, error)GetAwsOpenIdConfig gets the OIDC discovery document for the cluster. See the OpenID Connect Discovery 1.0 specification (at https://openid.net/specs/openid-connect-discovery-1_0.html) for details.
Deprecated: GetAwsOpenIdConfig may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAwsOpenIdConfigRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAwsOpenIdConfigRequest.
}
resp, err := c.GetAwsOpenIdConfig(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GetAwsServerConfig (deprecated)
func (c *AwsClustersClient) GetAwsServerConfig(ctx context.Context, req *gkemulticloudpb.GetAwsServerConfigRequest, opts ...gax.CallOption) (*gkemulticloudpb.AwsServerConfig, error)GetAwsServerConfig returns information, such as supported AWS regions and Kubernetes versions, on a given Google Cloud location.
Deprecated: GetAwsServerConfig may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAwsServerConfigRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAwsServerConfigRequest.
}
resp, err := c.GetAwsServerConfig(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) GetOperation (deprecated)
func (c *AwsClustersClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, opts ...gax.CallOption) (*longrunningpb.Operation, error)GetOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAwsClustersClient(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 (*AwsClustersClient) ListAwsClusters (deprecated)
func (c *AwsClustersClient) ListAwsClusters(ctx context.Context, req *gkemulticloudpb.ListAwsClustersRequest, opts ...gax.CallOption) *AwsClusterIteratorListAwsClusters lists all AwsCluster resources on a given Google Cloud project and region.
Deprecated: ListAwsClusters may be removed in a future version.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
"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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAwsClustersRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAwsClustersRequest.
}
it := c.ListAwsClusters(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.(*gkemulticloudpb.ListAwsClustersResponse)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAwsClustersRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAwsClustersRequest.
}
for resp, err := range c.ListAwsClusters(ctx, req).All() {
if err != nil {
// TODO: Handle error and break/return/continue. Iteration will stop after any error.
}
// TODO: Use resp.
_ = resp
}
}
func (*AwsClustersClient) ListAwsNodePools (deprecated)
func (c *AwsClustersClient) ListAwsNodePools(ctx context.Context, req *gkemulticloudpb.ListAwsNodePoolsRequest, opts ...gax.CallOption) *AwsNodePoolIteratorListAwsNodePools lists all AwsNodePool resources on a given AwsCluster.
Deprecated: ListAwsNodePools may be removed in a future version.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
"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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAwsNodePoolsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAwsNodePoolsRequest.
}
it := c.ListAwsNodePools(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.(*gkemulticloudpb.ListAwsNodePoolsResponse)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAwsNodePoolsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAwsNodePoolsRequest.
}
for resp, err := range c.ListAwsNodePools(ctx, req).All() {
if err != nil {
// TODO: Handle error and break/return/continue. Iteration will stop after any error.
}
// TODO: Use resp.
_ = resp
}
}
func (*AwsClustersClient) ListOperations (deprecated)
func (c *AwsClustersClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, opts ...gax.CallOption) *OperationIteratorListOperations is a utility method from google.longrunning.Operations.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAwsClustersClient(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)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAwsClustersClient(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 (*AwsClustersClient) RollbackAwsNodePoolUpdate (deprecated)
func (c *AwsClustersClient) RollbackAwsNodePoolUpdate(ctx context.Context, req *gkemulticloudpb.RollbackAwsNodePoolUpdateRequest, opts ...gax.CallOption) (*RollbackAwsNodePoolUpdateOperation, error)RollbackAwsNodePoolUpdate rolls back a previously aborted or failed AwsNodePool update request. Makes no changes if the last update request successfully finished. If an update request is in progress, you cannot rollback the update. You must first cancel or let it finish unsuccessfully before you can rollback.
Deprecated: RollbackAwsNodePoolUpdate may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.RollbackAwsNodePoolUpdateRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#RollbackAwsNodePoolUpdateRequest.
}
op, err := c.RollbackAwsNodePoolUpdate(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) RollbackAwsNodePoolUpdateOperation (deprecated)
func (c *AwsClustersClient) RollbackAwsNodePoolUpdateOperation(name string) *RollbackAwsNodePoolUpdateOperationRollbackAwsNodePoolUpdateOperation returns a new RollbackAwsNodePoolUpdateOperation from a given name. The name must be that of a previously created RollbackAwsNodePoolUpdateOperation, possibly from a different process.
func (*AwsClustersClient) UpdateAwsCluster (deprecated)
func (c *AwsClustersClient) UpdateAwsCluster(ctx context.Context, req *gkemulticloudpb.UpdateAwsClusterRequest, opts ...gax.CallOption) (*UpdateAwsClusterOperation, error)UpdateAwsCluster updates an AwsCluster.
Deprecated: UpdateAwsCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.UpdateAwsClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#UpdateAwsClusterRequest.
}
op, err := c.UpdateAwsCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) UpdateAwsClusterOperation (deprecated)
func (c *AwsClustersClient) UpdateAwsClusterOperation(name string) *UpdateAwsClusterOperationUpdateAwsClusterOperation returns a new UpdateAwsClusterOperation from a given name. The name must be that of a previously created UpdateAwsClusterOperation, possibly from a different process.
func (*AwsClustersClient) UpdateAwsNodePool (deprecated)
func (c *AwsClustersClient) UpdateAwsNodePool(ctx context.Context, req *gkemulticloudpb.UpdateAwsNodePoolRequest, opts ...gax.CallOption) (*UpdateAwsNodePoolOperation, error)UpdateAwsNodePool updates an AwsNodePool.
Deprecated: UpdateAwsNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAwsClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.UpdateAwsNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#UpdateAwsNodePoolRequest.
}
op, err := c.UpdateAwsNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AwsClustersClient) UpdateAwsNodePoolOperation (deprecated)
func (c *AwsClustersClient) UpdateAwsNodePoolOperation(name string) *UpdateAwsNodePoolOperationUpdateAwsNodePoolOperation returns a new UpdateAwsNodePoolOperation from a given name. The name must be that of a previously created UpdateAwsNodePoolOperation, possibly from a different process.
AwsNodePoolIterator
type AwsNodePoolIterator 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 []*gkemulticloudpb.AwsNodePool, nextPageToken string, err error)
// contains filtered or unexported fields
}AwsNodePoolIterator manages a stream of *gkemulticloudpb.AwsNodePool.
func (*AwsNodePoolIterator) All
func (it *AwsNodePoolIterator) All() iter.Seq2[*gkemulticloudpb.AwsNodePool, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*AwsNodePoolIterator) Next
func (it *AwsNodePoolIterator) Next() (*gkemulticloudpb.AwsNodePool, 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 (*AwsNodePoolIterator) PageInfo
func (it *AwsNodePoolIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
AzureClientIterator
type AzureClientIterator 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 []*gkemulticloudpb.AzureClient, nextPageToken string, err error)
// contains filtered or unexported fields
}AzureClientIterator manages a stream of *gkemulticloudpb.AzureClient.
func (*AzureClientIterator) All
func (it *AzureClientIterator) All() iter.Seq2[*gkemulticloudpb.AzureClient, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*AzureClientIterator) Next
func (it *AzureClientIterator) Next() (*gkemulticloudpb.AzureClient, 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 (*AzureClientIterator) PageInfo
func (it *AzureClientIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
AzureClusterIterator
type AzureClusterIterator 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 []*gkemulticloudpb.AzureCluster, nextPageToken string, err error)
// contains filtered or unexported fields
}AzureClusterIterator manages a stream of *gkemulticloudpb.AzureCluster.
func (*AzureClusterIterator) All
func (it *AzureClusterIterator) All() iter.Seq2[*gkemulticloudpb.AzureCluster, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*AzureClusterIterator) Next
func (it *AzureClusterIterator) Next() (*gkemulticloudpb.AzureCluster, 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 (*AzureClusterIterator) PageInfo
func (it *AzureClusterIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
AzureClustersCallOptions
type AzureClustersCallOptions struct {
CreateAzureClient []gax.CallOption
GetAzureClient []gax.CallOption
ListAzureClients []gax.CallOption
DeleteAzureClient []gax.CallOption
CreateAzureCluster []gax.CallOption
UpdateAzureCluster []gax.CallOption
GetAzureCluster []gax.CallOption
ListAzureClusters []gax.CallOption
DeleteAzureCluster []gax.CallOption
GenerateAzureClusterAgentToken []gax.CallOption
GenerateAzureAccessToken []gax.CallOption
CreateAzureNodePool []gax.CallOption
UpdateAzureNodePool []gax.CallOption
GetAzureNodePool []gax.CallOption
ListAzureNodePools []gax.CallOption
DeleteAzureNodePool []gax.CallOption
GetAzureOpenIdConfig []gax.CallOption
GetAzureJsonWebKeys []gax.CallOption
GetAzureServerConfig []gax.CallOption
CancelOperation []gax.CallOption
DeleteOperation []gax.CallOption
GetOperation []gax.CallOption
ListOperations []gax.CallOption
}AzureClustersCallOptions contains the retry settings for each method of AzureClustersClient.
AzureClustersClient (deprecated)
type AzureClustersClient struct {
// The call options for this service.
CallOptions *AzureClustersCallOptions
// 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
}AzureClustersClient is a client for interacting with GKE Multi-Cloud API. Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.
The AzureClusters API provides a single centrally managed service to create and manage Anthos clusters that run on Azure infrastructure.
Deprecated: AzureClusters may be removed in a future version.
func NewAzureClustersClient (deprecated)
func NewAzureClustersClient(ctx context.Context, opts ...option.ClientOption) (*AzureClustersClient, error)NewAzureClustersClient creates a new azure clusters client based on gRPC. The returned client must be Closed when it is done being used to clean up its underlying connections.
The AzureClusters API provides a single centrally managed service to create and manage Anthos clusters that run on Azure infrastructure.
Deprecated: AzureClusters may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
// TODO: Use client.
_ = c
}
func (*AzureClustersClient) CancelOperation (deprecated)
func (c *AzureClustersClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, opts ...gax.CallOption) errorCancelOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAzureClustersClient(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 (*AzureClustersClient) Close (deprecated)
func (c *AzureClustersClient) Close() errorClose closes the connection to the API service. The user should invoke this when the client is no longer required.
func (*AzureClustersClient) Connection (deprecated)
func (c *AzureClustersClient) Connection() *grpc.ClientConnConnection returns a connection to the API service.
Deprecated: Connections are now pooled so this method does not always return the same resource.
func (*AzureClustersClient) CreateAzureClient (deprecated)
func (c *AzureClustersClient) CreateAzureClient(ctx context.Context, req *gkemulticloudpb.CreateAzureClientRequest, opts ...gax.CallOption) (*CreateAzureClientOperation, error)CreateAzureClient creates a new AzureClient resource on a given Google Cloud project and region.
AzureClient resources hold client authentication information needed by the Anthos Multicloud API to manage Azure resources on your Azure subscription on your behalf.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: CreateAzureClient may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.CreateAzureClientRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAzureClientRequest.
}
op, err := c.CreateAzureClient(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) CreateAzureClientOperation (deprecated)
func (c *AzureClustersClient) CreateAzureClientOperation(name string) *CreateAzureClientOperationCreateAzureClientOperation returns a new CreateAzureClientOperation from a given name. The name must be that of a previously created CreateAzureClientOperation, possibly from a different process.
func (*AzureClustersClient) CreateAzureCluster (deprecated)
func (c *AzureClustersClient) CreateAzureCluster(ctx context.Context, req *gkemulticloudpb.CreateAzureClusterRequest, opts ...gax.CallOption) (*CreateAzureClusterOperation, error)CreateAzureCluster creates a new AzureCluster resource on a given Google Cloud Platform project and region.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: CreateAzureCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.CreateAzureClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAzureClusterRequest.
}
op, err := c.CreateAzureCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) CreateAzureClusterOperation (deprecated)
func (c *AzureClustersClient) CreateAzureClusterOperation(name string) *CreateAzureClusterOperationCreateAzureClusterOperation returns a new CreateAzureClusterOperation from a given name. The name must be that of a previously created CreateAzureClusterOperation, possibly from a different process.
func (*AzureClustersClient) CreateAzureNodePool (deprecated)
func (c *AzureClustersClient) CreateAzureNodePool(ctx context.Context, req *gkemulticloudpb.CreateAzureNodePoolRequest, opts ...gax.CallOption) (*CreateAzureNodePoolOperation, error)CreateAzureNodePool creates a new AzureNodePool, attached to a given AzureCluster.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: CreateAzureNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.CreateAzureNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#CreateAzureNodePoolRequest.
}
op, err := c.CreateAzureNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) CreateAzureNodePoolOperation (deprecated)
func (c *AzureClustersClient) CreateAzureNodePoolOperation(name string) *CreateAzureNodePoolOperationCreateAzureNodePoolOperation returns a new CreateAzureNodePoolOperation from a given name. The name must be that of a previously created CreateAzureNodePoolOperation, possibly from a different process.
func (*AzureClustersClient) DeleteAzureClient (deprecated)
func (c *AzureClustersClient) DeleteAzureClient(ctx context.Context, req *gkemulticloudpb.DeleteAzureClientRequest, opts ...gax.CallOption) (*DeleteAzureClientOperation, error)DeleteAzureClient deletes a specific AzureClient resource.
If the client is used by one or more clusters, deletion will fail and a FAILED_PRECONDITION error will be returned.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: DeleteAzureClient may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.DeleteAzureClientRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#DeleteAzureClientRequest.
}
op, err := c.DeleteAzureClient(ctx, req)
if err != nil {
// TODO: Handle error.
}
err = op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
}
func (*AzureClustersClient) DeleteAzureClientOperation (deprecated)
func (c *AzureClustersClient) DeleteAzureClientOperation(name string) *DeleteAzureClientOperationDeleteAzureClientOperation returns a new DeleteAzureClientOperation from a given name. The name must be that of a previously created DeleteAzureClientOperation, possibly from a different process.
func (*AzureClustersClient) DeleteAzureCluster (deprecated)
func (c *AzureClustersClient) DeleteAzureCluster(ctx context.Context, req *gkemulticloudpb.DeleteAzureClusterRequest, opts ...gax.CallOption) (*DeleteAzureClusterOperation, error)DeleteAzureCluster deletes a specific AzureCluster resource.
Fails if the cluster has one or more associated AzureNodePool resources.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: DeleteAzureCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.DeleteAzureClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#DeleteAzureClusterRequest.
}
op, err := c.DeleteAzureCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
err = op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
}
func (*AzureClustersClient) DeleteAzureClusterOperation (deprecated)
func (c *AzureClustersClient) DeleteAzureClusterOperation(name string) *DeleteAzureClusterOperationDeleteAzureClusterOperation returns a new DeleteAzureClusterOperation from a given name. The name must be that of a previously created DeleteAzureClusterOperation, possibly from a different process.
func (*AzureClustersClient) DeleteAzureNodePool (deprecated)
func (c *AzureClustersClient) DeleteAzureNodePool(ctx context.Context, req *gkemulticloudpb.DeleteAzureNodePoolRequest, opts ...gax.CallOption) (*DeleteAzureNodePoolOperation, error)DeleteAzureNodePool deletes a specific AzureNodePool resource.
If successful, the response contains a newly created Operation resource that can be described to track the status of the operation.
Deprecated: DeleteAzureNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.DeleteAzureNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#DeleteAzureNodePoolRequest.
}
op, err := c.DeleteAzureNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
err = op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
}
func (*AzureClustersClient) DeleteAzureNodePoolOperation (deprecated)
func (c *AzureClustersClient) DeleteAzureNodePoolOperation(name string) *DeleteAzureNodePoolOperationDeleteAzureNodePoolOperation returns a new DeleteAzureNodePoolOperation from a given name. The name must be that of a previously created DeleteAzureNodePoolOperation, possibly from a different process.
func (*AzureClustersClient) DeleteOperation (deprecated)
func (c *AzureClustersClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, opts ...gax.CallOption) errorDeleteOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAzureClustersClient(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 (*AzureClustersClient) GenerateAzureAccessToken (deprecated)
func (c *AzureClustersClient) GenerateAzureAccessToken(ctx context.Context, req *gkemulticloudpb.GenerateAzureAccessTokenRequest, opts ...gax.CallOption) (*gkemulticloudpb.GenerateAzureAccessTokenResponse, error)GenerateAzureAccessToken generates a short-lived access token to authenticate to a given AzureCluster resource.
Deprecated: GenerateAzureAccessToken may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GenerateAzureAccessTokenRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GenerateAzureAccessTokenRequest.
}
resp, err := c.GenerateAzureAccessToken(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GenerateAzureClusterAgentToken (deprecated)
func (c *AzureClustersClient) GenerateAzureClusterAgentToken(ctx context.Context, req *gkemulticloudpb.GenerateAzureClusterAgentTokenRequest, opts ...gax.CallOption) (*gkemulticloudpb.GenerateAzureClusterAgentTokenResponse, error)GenerateAzureClusterAgentToken generates an access token for a cluster agent.
Deprecated: GenerateAzureClusterAgentToken may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GenerateAzureClusterAgentTokenRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GenerateAzureClusterAgentTokenRequest.
}
resp, err := c.GenerateAzureClusterAgentToken(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetAzureClient (deprecated)
func (c *AzureClustersClient) GetAzureClient(ctx context.Context, req *gkemulticloudpb.GetAzureClientRequest, opts ...gax.CallOption) (*gkemulticloudpb.AzureClient, error)GetAzureClient describes a specific AzureClient resource.
Deprecated: GetAzureClient may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAzureClientRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAzureClientRequest.
}
resp, err := c.GetAzureClient(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetAzureCluster (deprecated)
func (c *AzureClustersClient) GetAzureCluster(ctx context.Context, req *gkemulticloudpb.GetAzureClusterRequest, opts ...gax.CallOption) (*gkemulticloudpb.AzureCluster, error)GetAzureCluster describes a specific AzureCluster resource.
Deprecated: GetAzureCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAzureClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAzureClusterRequest.
}
resp, err := c.GetAzureCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetAzureJsonWebKeys (deprecated)
func (c *AzureClustersClient) GetAzureJsonWebKeys(ctx context.Context, req *gkemulticloudpb.GetAzureJsonWebKeysRequest, opts ...gax.CallOption) (*gkemulticloudpb.AzureJsonWebKeys, error)GetAzureJsonWebKeys gets the public component of the cluster signing keys in JSON Web Key format.
Deprecated: GetAzureJsonWebKeys may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAzureJsonWebKeysRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAzureJsonWebKeysRequest.
}
resp, err := c.GetAzureJsonWebKeys(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetAzureNodePool (deprecated)
func (c *AzureClustersClient) GetAzureNodePool(ctx context.Context, req *gkemulticloudpb.GetAzureNodePoolRequest, opts ...gax.CallOption) (*gkemulticloudpb.AzureNodePool, error)GetAzureNodePool describes a specific AzureNodePool resource.
Deprecated: GetAzureNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAzureNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAzureNodePoolRequest.
}
resp, err := c.GetAzureNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetAzureOpenIdConfig (deprecated)
func (c *AzureClustersClient) GetAzureOpenIdConfig(ctx context.Context, req *gkemulticloudpb.GetAzureOpenIdConfigRequest, opts ...gax.CallOption) (*gkemulticloudpb.AzureOpenIdConfig, error)GetAzureOpenIdConfig gets the OIDC discovery document for the cluster. See the OpenID Connect Discovery 1.0 specification (at https://openid.net/specs/openid-connect-discovery-1_0.html) for details.
Deprecated: GetAzureOpenIdConfig may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAzureOpenIdConfigRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAzureOpenIdConfigRequest.
}
resp, err := c.GetAzureOpenIdConfig(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetAzureServerConfig (deprecated)
func (c *AzureClustersClient) GetAzureServerConfig(ctx context.Context, req *gkemulticloudpb.GetAzureServerConfigRequest, opts ...gax.CallOption) (*gkemulticloudpb.AzureServerConfig, error)GetAzureServerConfig returns information, such as supported Azure regions and Kubernetes versions, on a given Google Cloud location.
Deprecated: GetAzureServerConfig may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.GetAzureServerConfigRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#GetAzureServerConfigRequest.
}
resp, err := c.GetAzureServerConfig(ctx, req)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) GetOperation (deprecated)
func (c *AzureClustersClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, opts ...gax.CallOption) (*longrunningpb.Operation, error)GetOperation is a utility method from google.longrunning.Operations.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAzureClustersClient(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 (*AzureClustersClient) ListAzureClients (deprecated)
func (c *AzureClustersClient) ListAzureClients(ctx context.Context, req *gkemulticloudpb.ListAzureClientsRequest, opts ...gax.CallOption) *AzureClientIteratorListAzureClients lists all AzureClient resources on a given Google Cloud project and region.
Deprecated: ListAzureClients may be removed in a future version.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
"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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAzureClientsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAzureClientsRequest.
}
it := c.ListAzureClients(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.(*gkemulticloudpb.ListAzureClientsResponse)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAzureClientsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAzureClientsRequest.
}
for resp, err := range c.ListAzureClients(ctx, req).All() {
if err != nil {
// TODO: Handle error and break/return/continue. Iteration will stop after any error.
}
// TODO: Use resp.
_ = resp
}
}
func (*AzureClustersClient) ListAzureClusters (deprecated)
func (c *AzureClustersClient) ListAzureClusters(ctx context.Context, req *gkemulticloudpb.ListAzureClustersRequest, opts ...gax.CallOption) *AzureClusterIteratorListAzureClusters lists all AzureCluster resources on a given Google Cloud project and region.
Deprecated: ListAzureClusters may be removed in a future version.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
"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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAzureClustersRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAzureClustersRequest.
}
it := c.ListAzureClusters(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.(*gkemulticloudpb.ListAzureClustersResponse)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAzureClustersRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAzureClustersRequest.
}
for resp, err := range c.ListAzureClusters(ctx, req).All() {
if err != nil {
// TODO: Handle error and break/return/continue. Iteration will stop after any error.
}
// TODO: Use resp.
_ = resp
}
}
func (*AzureClustersClient) ListAzureNodePools (deprecated)
func (c *AzureClustersClient) ListAzureNodePools(ctx context.Context, req *gkemulticloudpb.ListAzureNodePoolsRequest, opts ...gax.CallOption) *AzureNodePoolIteratorListAzureNodePools lists all AzureNodePool resources on a given AzureCluster.
Deprecated: ListAzureNodePools may be removed in a future version.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
"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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAzureNodePoolsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAzureNodePoolsRequest.
}
it := c.ListAzureNodePools(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.(*gkemulticloudpb.ListAzureNodePoolsResponse)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.ListAzureNodePoolsRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#ListAzureNodePoolsRequest.
}
for resp, err := range c.ListAzureNodePools(ctx, req).All() {
if err != nil {
// TODO: Handle error and break/return/continue. Iteration will stop after any error.
}
// TODO: Use resp.
_ = resp
}
}
func (*AzureClustersClient) ListOperations (deprecated)
func (c *AzureClustersClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, opts ...gax.CallOption) *OperationIteratorListOperations is a utility method from google.longrunning.Operations.
Examples
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAzureClustersClient(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)
}
}
all
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
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 := gkemulticloud.NewAzureClustersClient(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 (*AzureClustersClient) UpdateAzureCluster (deprecated)
func (c *AzureClustersClient) UpdateAzureCluster(ctx context.Context, req *gkemulticloudpb.UpdateAzureClusterRequest, opts ...gax.CallOption) (*UpdateAzureClusterOperation, error)UpdateAzureCluster updates an AzureCluster.
Deprecated: UpdateAzureCluster may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.UpdateAzureClusterRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#UpdateAzureClusterRequest.
}
op, err := c.UpdateAzureCluster(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) UpdateAzureClusterOperation (deprecated)
func (c *AzureClustersClient) UpdateAzureClusterOperation(name string) *UpdateAzureClusterOperationUpdateAzureClusterOperation returns a new UpdateAzureClusterOperation from a given name. The name must be that of a previously created UpdateAzureClusterOperation, possibly from a different process.
func (*AzureClustersClient) UpdateAzureNodePool (deprecated)
func (c *AzureClustersClient) UpdateAzureNodePool(ctx context.Context, req *gkemulticloudpb.UpdateAzureNodePoolRequest, opts ...gax.CallOption) (*UpdateAzureNodePoolOperation, error)UpdateAzureNodePool updates an AzureNodePool.
Deprecated: UpdateAzureNodePool may be removed in a future version.
Example
package main
import (
"context"
gkemulticloud "cloud.google.com/go/gkemulticloud/apiv1"
gkemulticloudpb "cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb"
)
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 := gkemulticloud.NewAzureClustersClient(ctx)
if err != nil {
// TODO: Handle error.
}
defer c.Close()
req := &gkemulticloudpb.UpdateAzureNodePoolRequest{
// TODO: Fill request struct fields.
// See https://pkg.go.dev/cloud.google.com/go/gkemulticloud/apiv1/gkemulticloudpb#UpdateAzureNodePoolRequest.
}
op, err := c.UpdateAzureNodePool(ctx, req)
if err != nil {
// TODO: Handle error.
}
resp, err := op.Wait(ctx)
if err != nil {
// TODO: Handle error.
}
// TODO: Use resp.
_ = resp
}
func (*AzureClustersClient) UpdateAzureNodePoolOperation (deprecated)
func (c *AzureClustersClient) UpdateAzureNodePoolOperation(name string) *UpdateAzureNodePoolOperationUpdateAzureNodePoolOperation returns a new UpdateAzureNodePoolOperation from a given name. The name must be that of a previously created UpdateAzureNodePoolOperation, possibly from a different process.
AzureNodePoolIterator
type AzureNodePoolIterator 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 []*gkemulticloudpb.AzureNodePool, nextPageToken string, err error)
// contains filtered or unexported fields
}AzureNodePoolIterator manages a stream of *gkemulticloudpb.AzureNodePool.
func (*AzureNodePoolIterator) All
func (it *AzureNodePoolIterator) All() iter.Seq2[*gkemulticloudpb.AzureNodePool, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*AzureNodePoolIterator) Next
func (it *AzureNodePoolIterator) Next() (*gkemulticloudpb.AzureNodePool, 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 (*AzureNodePoolIterator) PageInfo
func (it *AzureNodePoolIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
CreateAttachedClusterOperation
type CreateAttachedClusterOperation struct {
// contains filtered or unexported fields
}CreateAttachedClusterOperation manages a long-running operation from CreateAttachedCluster.
func (*CreateAttachedClusterOperation) Done
func (op *CreateAttachedClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*CreateAttachedClusterOperation) Metadata
func (op *CreateAttachedClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*CreateAttachedClusterOperation) Name
func (op *CreateAttachedClusterOperation) Name() stringName 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 (*CreateAttachedClusterOperation) Poll
func (op *CreateAttachedClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, 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 (*CreateAttachedClusterOperation) Wait
func (op *CreateAttachedClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, 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.
CreateAwsClusterOperation
type CreateAwsClusterOperation struct {
// contains filtered or unexported fields
}CreateAwsClusterOperation manages a long-running operation from CreateAwsCluster.
func (*CreateAwsClusterOperation) Done
func (op *CreateAwsClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*CreateAwsClusterOperation) Metadata
func (op *CreateAwsClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*CreateAwsClusterOperation) Name
func (op *CreateAwsClusterOperation) Name() stringName 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 (*CreateAwsClusterOperation) Poll
func (op *CreateAwsClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsCluster, 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 (*CreateAwsClusterOperation) Wait
func (op *CreateAwsClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsCluster, 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.
CreateAwsNodePoolOperation
type CreateAwsNodePoolOperation struct {
// contains filtered or unexported fields
}CreateAwsNodePoolOperation manages a long-running operation from CreateAwsNodePool.
func (*CreateAwsNodePoolOperation) Done
func (op *CreateAwsNodePoolOperation) Done() boolDone reports whether the long-running operation has completed.
func (*CreateAwsNodePoolOperation) Metadata
func (op *CreateAwsNodePoolOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*CreateAwsNodePoolOperation) Name
func (op *CreateAwsNodePoolOperation) Name() stringName 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 (*CreateAwsNodePoolOperation) Poll
func (op *CreateAwsNodePoolOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, 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 (*CreateAwsNodePoolOperation) Wait
func (op *CreateAwsNodePoolOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, 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.
CreateAzureClientOperation
type CreateAzureClientOperation struct {
// contains filtered or unexported fields
}CreateAzureClientOperation manages a long-running operation from CreateAzureClient.
func (*CreateAzureClientOperation) Done
func (op *CreateAzureClientOperation) Done() boolDone reports whether the long-running operation has completed.
func (*CreateAzureClientOperation) Metadata
func (op *CreateAzureClientOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*CreateAzureClientOperation) Name
func (op *CreateAzureClientOperation) Name() stringName 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 (*CreateAzureClientOperation) Poll
func (op *CreateAzureClientOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureClient, 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 (*CreateAzureClientOperation) Wait
func (op *CreateAzureClientOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureClient, 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.
CreateAzureClusterOperation
type CreateAzureClusterOperation struct {
// contains filtered or unexported fields
}CreateAzureClusterOperation manages a long-running operation from CreateAzureCluster.
func (*CreateAzureClusterOperation) Done
func (op *CreateAzureClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*CreateAzureClusterOperation) Metadata
func (op *CreateAzureClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*CreateAzureClusterOperation) Name
func (op *CreateAzureClusterOperation) Name() stringName 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 (*CreateAzureClusterOperation) Poll
func (op *CreateAzureClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureCluster, 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 (*CreateAzureClusterOperation) Wait
func (op *CreateAzureClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureCluster, 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.
CreateAzureNodePoolOperation
type CreateAzureNodePoolOperation struct {
// contains filtered or unexported fields
}CreateAzureNodePoolOperation manages a long-running operation from CreateAzureNodePool.
func (*CreateAzureNodePoolOperation) Done
func (op *CreateAzureNodePoolOperation) Done() boolDone reports whether the long-running operation has completed.
func (*CreateAzureNodePoolOperation) Metadata
func (op *CreateAzureNodePoolOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*CreateAzureNodePoolOperation) Name
func (op *CreateAzureNodePoolOperation) Name() stringName 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 (*CreateAzureNodePoolOperation) Poll
func (op *CreateAzureNodePoolOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureNodePool, 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 (*CreateAzureNodePoolOperation) Wait
func (op *CreateAzureNodePoolOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureNodePool, 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.
DeleteAttachedClusterOperation
type DeleteAttachedClusterOperation struct {
// contains filtered or unexported fields
}DeleteAttachedClusterOperation manages a long-running operation from DeleteAttachedCluster.
func (*DeleteAttachedClusterOperation) Done
func (op *DeleteAttachedClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*DeleteAttachedClusterOperation) Metadata
func (op *DeleteAttachedClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*DeleteAttachedClusterOperation) Name
func (op *DeleteAttachedClusterOperation) Name() stringName 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 (*DeleteAttachedClusterOperation) Poll
func (op *DeleteAttachedClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) errorPoll 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 (*DeleteAttachedClusterOperation) Wait
func (op *DeleteAttachedClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) errorWait blocks until the long-running operation is completed, returning the response and any errors encountered.
See documentation of Poll for error-handling information.
DeleteAwsClusterOperation
type DeleteAwsClusterOperation struct {
// contains filtered or unexported fields
}DeleteAwsClusterOperation manages a long-running operation from DeleteAwsCluster.
func (*DeleteAwsClusterOperation) Done
func (op *DeleteAwsClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*DeleteAwsClusterOperation) Metadata
func (op *DeleteAwsClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*DeleteAwsClusterOperation) Name
func (op *DeleteAwsClusterOperation) Name() stringName 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 (*DeleteAwsClusterOperation) Poll
func (op *DeleteAwsClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) errorPoll 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 (*DeleteAwsClusterOperation) Wait
func (op *DeleteAwsClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) errorWait blocks until the long-running operation is completed, returning the response and any errors encountered.
See documentation of Poll for error-handling information.
DeleteAwsNodePoolOperation
type DeleteAwsNodePoolOperation struct {
// contains filtered or unexported fields
}DeleteAwsNodePoolOperation manages a long-running operation from DeleteAwsNodePool.
func (*DeleteAwsNodePoolOperation) Done
func (op *DeleteAwsNodePoolOperation) Done() boolDone reports whether the long-running operation has completed.
func (*DeleteAwsNodePoolOperation) Metadata
func (op *DeleteAwsNodePoolOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*DeleteAwsNodePoolOperation) Name
func (op *DeleteAwsNodePoolOperation) Name() stringName 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 (*DeleteAwsNodePoolOperation) Poll
func (op *DeleteAwsNodePoolOperation) Poll(ctx context.Context, opts ...gax.CallOption) errorPoll 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 (*DeleteAwsNodePoolOperation) Wait
func (op *DeleteAwsNodePoolOperation) Wait(ctx context.Context, opts ...gax.CallOption) errorWait blocks until the long-running operation is completed, returning the response and any errors encountered.
See documentation of Poll for error-handling information.
DeleteAzureClientOperation
type DeleteAzureClientOperation struct {
// contains filtered or unexported fields
}DeleteAzureClientOperation manages a long-running operation from DeleteAzureClient.
func (*DeleteAzureClientOperation) Done
func (op *DeleteAzureClientOperation) Done() boolDone reports whether the long-running operation has completed.
func (*DeleteAzureClientOperation) Metadata
func (op *DeleteAzureClientOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*DeleteAzureClientOperation) Name
func (op *DeleteAzureClientOperation) Name() stringName 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 (*DeleteAzureClientOperation) Poll
func (op *DeleteAzureClientOperation) Poll(ctx context.Context, opts ...gax.CallOption) errorPoll 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 (*DeleteAzureClientOperation) Wait
func (op *DeleteAzureClientOperation) Wait(ctx context.Context, opts ...gax.CallOption) errorWait blocks until the long-running operation is completed, returning the response and any errors encountered.
See documentation of Poll for error-handling information.
DeleteAzureClusterOperation
type DeleteAzureClusterOperation struct {
// contains filtered or unexported fields
}DeleteAzureClusterOperation manages a long-running operation from DeleteAzureCluster.
func (*DeleteAzureClusterOperation) Done
func (op *DeleteAzureClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*DeleteAzureClusterOperation) Metadata
func (op *DeleteAzureClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*DeleteAzureClusterOperation) Name
func (op *DeleteAzureClusterOperation) Name() stringName 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 (*DeleteAzureClusterOperation) Poll
func (op *DeleteAzureClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) errorPoll 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 (*DeleteAzureClusterOperation) Wait
func (op *DeleteAzureClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) errorWait blocks until the long-running operation is completed, returning the response and any errors encountered.
See documentation of Poll for error-handling information.
DeleteAzureNodePoolOperation
type DeleteAzureNodePoolOperation struct {
// contains filtered or unexported fields
}DeleteAzureNodePoolOperation manages a long-running operation from DeleteAzureNodePool.
func (*DeleteAzureNodePoolOperation) Done
func (op *DeleteAzureNodePoolOperation) Done() boolDone reports whether the long-running operation has completed.
func (*DeleteAzureNodePoolOperation) Metadata
func (op *DeleteAzureNodePoolOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*DeleteAzureNodePoolOperation) Name
func (op *DeleteAzureNodePoolOperation) Name() stringName 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 (*DeleteAzureNodePoolOperation) Poll
func (op *DeleteAzureNodePoolOperation) Poll(ctx context.Context, opts ...gax.CallOption) errorPoll 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 (*DeleteAzureNodePoolOperation) Wait
func (op *DeleteAzureNodePoolOperation) Wait(ctx context.Context, opts ...gax.CallOption) errorWait blocks until the long-running operation is completed, returning the response and any errors encountered.
See documentation of Poll for error-handling information.
ImportAttachedClusterOperation
type ImportAttachedClusterOperation struct {
// contains filtered or unexported fields
}ImportAttachedClusterOperation manages a long-running operation from ImportAttachedCluster.
func (*ImportAttachedClusterOperation) Done
func (op *ImportAttachedClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*ImportAttachedClusterOperation) Metadata
func (op *ImportAttachedClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*ImportAttachedClusterOperation) Name
func (op *ImportAttachedClusterOperation) Name() stringName 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 (*ImportAttachedClusterOperation) Poll
func (op *ImportAttachedClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, 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 (*ImportAttachedClusterOperation) Wait
func (op *ImportAttachedClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, 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.
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
func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error]All returns an iterator. If an error is returned by the iterator, the iterator will stop after that iteration.
func (*OperationIterator) Next
func (it *OperationIterator) Next() (*longrunningpb.Operation, 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 (*OperationIterator) PageInfo
func (it *OperationIterator) PageInfo() *iterator.PageInfoPageInfo supports pagination. See the [google.golang.org/api/iterator] package for details.
RollbackAwsNodePoolUpdateOperation
type RollbackAwsNodePoolUpdateOperation struct {
// contains filtered or unexported fields
}RollbackAwsNodePoolUpdateOperation manages a long-running operation from RollbackAwsNodePoolUpdate.
func (*RollbackAwsNodePoolUpdateOperation) Done
func (op *RollbackAwsNodePoolUpdateOperation) Done() boolDone reports whether the long-running operation has completed.
func (*RollbackAwsNodePoolUpdateOperation) Metadata
func (op *RollbackAwsNodePoolUpdateOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*RollbackAwsNodePoolUpdateOperation) Name
func (op *RollbackAwsNodePoolUpdateOperation) Name() stringName 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 (*RollbackAwsNodePoolUpdateOperation) Poll
func (op *RollbackAwsNodePoolUpdateOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, 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 (*RollbackAwsNodePoolUpdateOperation) Wait
func (op *RollbackAwsNodePoolUpdateOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, 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.
UpdateAttachedClusterOperation
type UpdateAttachedClusterOperation struct {
// contains filtered or unexported fields
}UpdateAttachedClusterOperation manages a long-running operation from UpdateAttachedCluster.
func (*UpdateAttachedClusterOperation) Done
func (op *UpdateAttachedClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*UpdateAttachedClusterOperation) Metadata
func (op *UpdateAttachedClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*UpdateAttachedClusterOperation) Name
func (op *UpdateAttachedClusterOperation) Name() stringName 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 (*UpdateAttachedClusterOperation) Poll
func (op *UpdateAttachedClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, 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 (*UpdateAttachedClusterOperation) Wait
func (op *UpdateAttachedClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AttachedCluster, 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.
UpdateAwsClusterOperation
type UpdateAwsClusterOperation struct {
// contains filtered or unexported fields
}UpdateAwsClusterOperation manages a long-running operation from UpdateAwsCluster.
func (*UpdateAwsClusterOperation) Done
func (op *UpdateAwsClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*UpdateAwsClusterOperation) Metadata
func (op *UpdateAwsClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*UpdateAwsClusterOperation) Name
func (op *UpdateAwsClusterOperation) Name() stringName 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 (*UpdateAwsClusterOperation) Poll
func (op *UpdateAwsClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsCluster, 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 (*UpdateAwsClusterOperation) Wait
func (op *UpdateAwsClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsCluster, 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.
UpdateAwsNodePoolOperation
type UpdateAwsNodePoolOperation struct {
// contains filtered or unexported fields
}UpdateAwsNodePoolOperation manages a long-running operation from UpdateAwsNodePool.
func (*UpdateAwsNodePoolOperation) Done
func (op *UpdateAwsNodePoolOperation) Done() boolDone reports whether the long-running operation has completed.
func (*UpdateAwsNodePoolOperation) Metadata
func (op *UpdateAwsNodePoolOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*UpdateAwsNodePoolOperation) Name
func (op *UpdateAwsNodePoolOperation) Name() stringName 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 (*UpdateAwsNodePoolOperation) Poll
func (op *UpdateAwsNodePoolOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, 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 (*UpdateAwsNodePoolOperation) Wait
func (op *UpdateAwsNodePoolOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AwsNodePool, 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.
UpdateAzureClusterOperation
type UpdateAzureClusterOperation struct {
// contains filtered or unexported fields
}UpdateAzureClusterOperation manages a long-running operation from UpdateAzureCluster.
func (*UpdateAzureClusterOperation) Done
func (op *UpdateAzureClusterOperation) Done() boolDone reports whether the long-running operation has completed.
func (*UpdateAzureClusterOperation) Metadata
func (op *UpdateAzureClusterOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*UpdateAzureClusterOperation) Name
func (op *UpdateAzureClusterOperation) Name() stringName 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 (*UpdateAzureClusterOperation) Poll
func (op *UpdateAzureClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureCluster, 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 (*UpdateAzureClusterOperation) Wait
func (op *UpdateAzureClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureCluster, 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.
UpdateAzureNodePoolOperation
type UpdateAzureNodePoolOperation struct {
// contains filtered or unexported fields
}UpdateAzureNodePoolOperation manages a long-running operation from UpdateAzureNodePool.
func (*UpdateAzureNodePoolOperation) Done
func (op *UpdateAzureNodePoolOperation) Done() boolDone reports whether the long-running operation has completed.
func (*UpdateAzureNodePoolOperation) Metadata
func (op *UpdateAzureNodePoolOperation) Metadata() (*gkemulticloudpb.OperationMetadata, error)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 (*UpdateAzureNodePoolOperation) Name
func (op *UpdateAzureNodePoolOperation) Name() stringName 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 (*UpdateAzureNodePoolOperation) Poll
func (op *UpdateAzureNodePoolOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureNodePool, 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 (*UpdateAzureNodePoolOperation) Wait
func (op *UpdateAzureNodePoolOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*gkemulticloudpb.AzureNodePool, 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.