service

Sep 19, 2024

Changes in this version

+ type CheckUpgradeOperation struct

+ func (op *CheckUpgradeOperation) Done() bool

+ func (op *CheckUpgradeOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *CheckUpgradeOperation) Name() string

+ func (op *CheckUpgradeOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*servicepb.CheckUpgradeResponse, error)

+ func (op *CheckUpgradeOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*servicepb.CheckUpgradeResponse, error)

type EnvironmentsCallOptions

+ CheckUpgrade []gax.CallOption

type EnvironmentsClient

+ func (c *EnvironmentsClient) CheckUpgrade(ctx context.Context, req *servicepb.CheckUpgradeRequest, ...) (*CheckUpgradeOperation, error)

+ func (c *EnvironmentsClient) CheckUpgradeOperation(name string) *CheckUpgradeOperation

Sep 12, 2024

Changes in this version

type EnvironmentIterator

+ func (it *EnvironmentIterator) All() iter.Seq2[*servicepb.Environment, error]

type ImageVersionIterator

+ func (it *ImageVersionIterator) All() iter.Seq2[*servicepb.ImageVersion, error]

type ListWorkloadsResponse_ComposerWorkloadIterator

+ func (it *ListWorkloadsResponse_ComposerWorkloadIterator) All() iter.Seq2[*servicepb.ListWorkloadsResponse_ComposerWorkload, error]

type OperationIterator

+ func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error]

type UserWorkloadsConfigMapIterator

+ func (it *UserWorkloadsConfigMapIterator) All() iter.Seq2[*servicepb.UserWorkloadsConfigMap, error]

type UserWorkloadsSecretIterator

+ func (it *UserWorkloadsSecretIterator) All() iter.Seq2[*servicepb.UserWorkloadsSecret, error]

Feb 21, 2024

Changes in this version

type EnvironmentsCallOptions

+ CreateUserWorkloadsConfigMap []gax.CallOption

+ CreateUserWorkloadsSecret []gax.CallOption

+ DeleteUserWorkloadsConfigMap []gax.CallOption

+ DeleteUserWorkloadsSecret []gax.CallOption

+ GetUserWorkloadsConfigMap []gax.CallOption

+ GetUserWorkloadsSecret []gax.CallOption

+ ListUserWorkloadsConfigMaps []gax.CallOption

+ ListUserWorkloadsSecrets []gax.CallOption

+ ListWorkloads []gax.CallOption

+ UpdateUserWorkloadsConfigMap []gax.CallOption

+ UpdateUserWorkloadsSecret []gax.CallOption

type EnvironmentsClient

+ func (c *EnvironmentsClient) CreateUserWorkloadsConfigMap(ctx context.Context, req *servicepb.CreateUserWorkloadsConfigMapRequest, ...) (*servicepb.UserWorkloadsConfigMap, error)

+ func (c *EnvironmentsClient) CreateUserWorkloadsSecret(ctx context.Context, req *servicepb.CreateUserWorkloadsSecretRequest, ...) (*servicepb.UserWorkloadsSecret, error)

+ func (c *EnvironmentsClient) DeleteUserWorkloadsConfigMap(ctx context.Context, req *servicepb.DeleteUserWorkloadsConfigMapRequest, ...) error

+ func (c *EnvironmentsClient) DeleteUserWorkloadsSecret(ctx context.Context, req *servicepb.DeleteUserWorkloadsSecretRequest, ...) error

+ func (c *EnvironmentsClient) GetUserWorkloadsConfigMap(ctx context.Context, req *servicepb.GetUserWorkloadsConfigMapRequest, ...) (*servicepb.UserWorkloadsConfigMap, error)

+ func (c *EnvironmentsClient) GetUserWorkloadsSecret(ctx context.Context, req *servicepb.GetUserWorkloadsSecretRequest, ...) (*servicepb.UserWorkloadsSecret, error)

+ func (c *EnvironmentsClient) ListUserWorkloadsConfigMaps(ctx context.Context, req *servicepb.ListUserWorkloadsConfigMapsRequest, ...) *UserWorkloadsConfigMapIterator

+ func (c *EnvironmentsClient) ListUserWorkloadsSecrets(ctx context.Context, req *servicepb.ListUserWorkloadsSecretsRequest, ...) *UserWorkloadsSecretIterator

+ func (c *EnvironmentsClient) ListWorkloads(ctx context.Context, req *servicepb.ListWorkloadsRequest, ...) *ListWorkloadsResponse_ComposerWorkloadIterator

+ func (c *EnvironmentsClient) UpdateUserWorkloadsConfigMap(ctx context.Context, req *servicepb.UpdateUserWorkloadsConfigMapRequest, ...) (*servicepb.UserWorkloadsConfigMap, error)

+ func (c *EnvironmentsClient) UpdateUserWorkloadsSecret(ctx context.Context, req *servicepb.UpdateUserWorkloadsSecretRequest, ...) (*servicepb.UserWorkloadsSecret, error)

+ type ListWorkloadsResponse_ComposerWorkloadIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*servicepb.ListWorkloadsResponse_ComposerWorkload, ...)

+ Response interface{}

+ func (it *ListWorkloadsResponse_ComposerWorkloadIterator) Next() (*servicepb.ListWorkloadsResponse_ComposerWorkload, error)

+ func (it *ListWorkloadsResponse_ComposerWorkloadIterator) PageInfo() *iterator.PageInfo

+ type UserWorkloadsConfigMapIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*servicepb.UserWorkloadsConfigMap, nextPageToken string, err error)

+ Response interface{}

+ func (it *UserWorkloadsConfigMapIterator) Next() (*servicepb.UserWorkloadsConfigMap, error)

+ func (it *UserWorkloadsConfigMapIterator) PageInfo() *iterator.PageInfo

+ type UserWorkloadsSecretIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*servicepb.UserWorkloadsSecret, nextPageToken string, err error)

+ Response interface{}

+ func (it *UserWorkloadsSecretIterator) Next() (*servicepb.UserWorkloadsSecret, error)

+ func (it *UserWorkloadsSecretIterator) PageInfo() *iterator.PageInfo

Jun 13, 2023

Changes in this version

+ type DatabaseFailoverOperation struct

+ func (op *DatabaseFailoverOperation) Done() bool

+ func (op *DatabaseFailoverOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *DatabaseFailoverOperation) Name() string

+ func (op *DatabaseFailoverOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*servicepb.DatabaseFailoverResponse, error)

+ func (op *DatabaseFailoverOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*servicepb.DatabaseFailoverResponse, error)

type EnvironmentsCallOptions

+ DatabaseFailover []gax.CallOption

+ ExecuteAirflowCommand []gax.CallOption

+ FetchDatabaseProperties []gax.CallOption

+ PollAirflowCommand []gax.CallOption

+ StopAirflowCommand []gax.CallOption

type EnvironmentsClient

+ func (c *EnvironmentsClient) DatabaseFailover(ctx context.Context, req *servicepb.DatabaseFailoverRequest, ...) (*DatabaseFailoverOperation, error)

+ func (c *EnvironmentsClient) DatabaseFailoverOperation(name string) *DatabaseFailoverOperation

+ func (c *EnvironmentsClient) ExecuteAirflowCommand(ctx context.Context, req *servicepb.ExecuteAirflowCommandRequest, ...) (*servicepb.ExecuteAirflowCommandResponse, error)

+ func (c *EnvironmentsClient) FetchDatabaseProperties(ctx context.Context, req *servicepb.FetchDatabasePropertiesRequest, ...) (*servicepb.FetchDatabasePropertiesResponse, error)

+ func (c *EnvironmentsClient) PollAirflowCommand(ctx context.Context, req *servicepb.PollAirflowCommandRequest, ...) (*servicepb.PollAirflowCommandResponse, error)

+ func (c *EnvironmentsClient) StopAirflowCommand(ctx context.Context, req *servicepb.StopAirflowCommandRequest, ...) (*servicepb.StopAirflowCommandResponse, error)

Jan 5, 2023

Changes in this version

type EnvironmentsClient

+ func NewEnvironmentsRESTClient(ctx context.Context, opts ...option.ClientOption) (*EnvironmentsClient, error)

type ImageVersionsClient

+ func NewImageVersionsRESTClient(ctx context.Context, opts ...option.ClientOption) (*ImageVersionsClient, error)

Dec 15, 2022

Changes in this version

type EnvironmentsCallOptions

+ DeleteOperation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

+ LoadSnapshot []gax.CallOption

+ SaveSnapshot []gax.CallOption

type EnvironmentsClient

+ func (c *EnvironmentsClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *EnvironmentsClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *EnvironmentsClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *EnvironmentsClient) LoadSnapshot(ctx context.Context, req *servicepb.LoadSnapshotRequest, ...) (*LoadSnapshotOperation, error)

+ func (c *EnvironmentsClient) LoadSnapshotOperation(name string) *LoadSnapshotOperation

+ func (c *EnvironmentsClient) SaveSnapshot(ctx context.Context, req *servicepb.SaveSnapshotRequest, ...) (*SaveSnapshotOperation, error)

+ func (c *EnvironmentsClient) SaveSnapshotOperation(name string) *SaveSnapshotOperation

type ImageVersionsCallOptions

+ DeleteOperation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

type ImageVersionsClient

+ func (c *ImageVersionsClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *ImageVersionsClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *ImageVersionsClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ type LoadSnapshotOperation struct

+ func (op *LoadSnapshotOperation) Done() bool

+ func (op *LoadSnapshotOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *LoadSnapshotOperation) Name() string

+ func (op *LoadSnapshotOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*servicepb.LoadSnapshotResponse, error)

+ func (op *LoadSnapshotOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*servicepb.LoadSnapshotResponse, error)

+ type OperationIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*longrunningpb.Operation, nextPageToken string, err error)

+ Response interface{}

+ func (it *OperationIterator) Next() (*longrunningpb.Operation, error)

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

+ type SaveSnapshotOperation struct

+ func (op *SaveSnapshotOperation) Done() bool

+ func (op *SaveSnapshotOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *SaveSnapshotOperation) Name() string

+ func (op *SaveSnapshotOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*servicepb.SaveSnapshotResponse, error)

+ func (op *SaveSnapshotOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*servicepb.SaveSnapshotResponse, error)

Sep 27, 2021

Changes in this version

+ func DefaultAuthScopes() []string

+ type CreateEnvironmentOperation struct

+ func (op *CreateEnvironmentOperation) Done() bool

+ func (op *CreateEnvironmentOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *CreateEnvironmentOperation) Name() string

+ func (op *CreateEnvironmentOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*servicepb.Environment, error)

+ func (op *CreateEnvironmentOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*servicepb.Environment, error)

+ type DeleteEnvironmentOperation struct

+ func (op *DeleteEnvironmentOperation) Done() bool

+ func (op *DeleteEnvironmentOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *DeleteEnvironmentOperation) Name() string

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

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

+ type EnvironmentIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*servicepb.Environment, nextPageToken string, err error)

+ Response interface{}

+ func (it *EnvironmentIterator) Next() (*servicepb.Environment, error)

+ func (it *EnvironmentIterator) PageInfo() *iterator.PageInfo

+ type EnvironmentsCallOptions struct

+ CreateEnvironment []gax.CallOption

+ DeleteEnvironment []gax.CallOption

+ GetEnvironment []gax.CallOption

+ ListEnvironments []gax.CallOption

+ UpdateEnvironment []gax.CallOption

+ type EnvironmentsClient struct

+ CallOptions *EnvironmentsCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewEnvironmentsClient(ctx context.Context, opts ...option.ClientOption) (*EnvironmentsClient, error)

+ func (c *EnvironmentsClient) Close() error

+ func (c *EnvironmentsClient) Connection() *grpc.ClientConn

+ func (c *EnvironmentsClient) CreateEnvironment(ctx context.Context, req *servicepb.CreateEnvironmentRequest, ...) (*CreateEnvironmentOperation, error)

+ func (c *EnvironmentsClient) CreateEnvironmentOperation(name string) *CreateEnvironmentOperation

+ func (c *EnvironmentsClient) DeleteEnvironment(ctx context.Context, req *servicepb.DeleteEnvironmentRequest, ...) (*DeleteEnvironmentOperation, error)

+ func (c *EnvironmentsClient) DeleteEnvironmentOperation(name string) *DeleteEnvironmentOperation

+ func (c *EnvironmentsClient) GetEnvironment(ctx context.Context, req *servicepb.GetEnvironmentRequest, ...) (*servicepb.Environment, error)

+ func (c *EnvironmentsClient) ListEnvironments(ctx context.Context, req *servicepb.ListEnvironmentsRequest, ...) *EnvironmentIterator

+ func (c *EnvironmentsClient) UpdateEnvironment(ctx context.Context, req *servicepb.UpdateEnvironmentRequest, ...) (*UpdateEnvironmentOperation, error)

+ func (c *EnvironmentsClient) UpdateEnvironmentOperation(name string) *UpdateEnvironmentOperation

+ type ImageVersionIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*servicepb.ImageVersion, nextPageToken string, err error)

+ Response interface{}

+ func (it *ImageVersionIterator) Next() (*servicepb.ImageVersion, error)

+ func (it *ImageVersionIterator) PageInfo() *iterator.PageInfo

+ type ImageVersionsCallOptions struct

+ ListImageVersions []gax.CallOption

+ type ImageVersionsClient struct

+ CallOptions *ImageVersionsCallOptions

+ func NewImageVersionsClient(ctx context.Context, opts ...option.ClientOption) (*ImageVersionsClient, error)

+ func (c *ImageVersionsClient) Close() error

+ func (c *ImageVersionsClient) Connection() *grpc.ClientConn

+ func (c *ImageVersionsClient) ListImageVersions(ctx context.Context, req *servicepb.ListImageVersionsRequest, ...) *ImageVersionIterator

+ type UpdateEnvironmentOperation struct

+ func (op *UpdateEnvironmentOperation) Done() bool

+ func (op *UpdateEnvironmentOperation) Metadata() (*servicepb.OperationMetadata, error)

+ func (op *UpdateEnvironmentOperation) Name() string

+ func (op *UpdateEnvironmentOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*servicepb.Environment, error)

+ func (op *UpdateEnvironmentOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*servicepb.Environment, error)