gcp

package

Go to main page

Versions in this module

v0

v0.31.1

Mar 23, 2021

v0.31.0

Mar 17, 2021

Changes in this version

type Client

+ func (c *Client) Disks() (*compute.DisksService, error)

+ func (c *Client) ListDisks(zone string) ([]compute.Disk, error)

v0.30.0

Mar 2, 2021

v0.29.0

Feb 16, 2021

v0.28.0

Feb 3, 2021

Changes in this version

+ func IsBucketDoesNotExist(err error) bool

type Client

+ func (c *Client) DoesBucketExist(bucket string) (bool, error)

v0.27.0

Jan 20, 2021

Changes in this version

+ func ConvertGCSObjectsToKeys(gcsObjects ...*storage.ObjectAttrs) []string

type Client

+ func (c *Client) ListGCSPrefix(bucket string, prefix string, maxResults *int64) ([]*storage.ObjectAttrs, error)

+ func (c *Client) UploadStringToGCS(str string, bucket string, key string) error

v0.26.0

Jan 6, 2021

v0.25.0

Dec 23, 2020

Changes in this version

+ const ErrClusterAlreadyExists

+ func ErrorClusterAlreadyExists(clusterName string) error

type Client

+ IsAnonymous bool

+ func NewAnonymousClient() *Client

+ func (c *Client) ClusterExists(clusterName string) (bool, error)

v0.24.1

Dec 13, 2020

v0.24.0

Dec 9, 2020

Changes in this version

+ const ErrCredentialsFileEnvVarNotSet

+ const ErrInvalidGCSPath

+ const ErrProjectIDMismatch

+ func ErrorCredentialsFileEnvVarNotSet() error

+ func ErrorInvalidGCSPath(provided string) error

+ func ErrorProjectIDMismatch(credsFileProject string, providedProject string, credsFilePath string) error

+ func GCSPath(bucket string, key string) string

+ func IsBucketAlreadyExistsError(err error) bool

+ func IsErrCode(err error, errorCode int, errorMessage *string) bool

+ func IsGCPError(err error) bool

+ func IsInvalidBucketNameError(err error) bool

+ func IsValidGCSPath(gcsPath string) bool

+ func NewGoogleAuthProvider(addr string, config map[string]string, ...) (rest.AuthProvider, error)

+ func SplitGCSPath(gcsPath string) (string, string, error)

+ func ZoneToRegion(zone string) string

+ type Client struct

+ ClientEmail string

+ ClientID string

+ CredentialsJSON []byte

+ HashedProjectID string

+ PrivateKey string

+ PrivateKeyID string

+ ProjectID string

+ func NewFromEnv() (*Client, error)

+ func NewFromEnvCheckProjectID(projectID string) (*Client, error)

+ func (c *Client) Compute() (*compute.Service, error)

+ func (c *Client) CreateBucket(bucket string, location string, ignoreErrorIfBucketExists bool) error

+ func (c *Client) CreateCluster(req *containerpb.CreateClusterRequest) (*containerpb.Operation, error)

+ func (c *Client) CreateK8SConfigFromCluster(cluster *containerpb.Cluster) (*rest.Config, error)

+ func (c *Client) DeleteBucket(bucket string) error

+ func (c *Client) DeleteCluster(clusterName string) (*containerpb.Operation, error)

+ func (c *Client) DeleteGCSDir(bucket string, gcsDir string, continueIfFailure bool) error

+ func (c *Client) DeleteGCSFile(bucket string, key string) error

+ func (c *Client) DeleteGCSPrefix(bucket string, gcsDir string, continueIfFailure bool) error

+ func (c *Client) GCS() (*storage.Client, error)

+ func (c *Client) GKE() (*container.ClusterManagerClient, error)

+ func (c *Client) GetAvailableAcceleratorTypes(zone string) ([]string, error)

+ func (c *Client) GetAvailableAcceleratorTypesForAllZones() ([]string, error)

+ func (c *Client) GetAvailableInstanceTypes(zone string) ([]string, error)

+ func (c *Client) GetAvailableInstanceTypesForAllZones() ([]string, error)

+ func (c *Client) GetAvailableZones() ([]string, error)

+ func (c *Client) GetAvailableZonesForAccelerator(acceleratorType string) ([]string, error)

+ func (c *Client) GetCluster(clusterName string) (*containerpb.Cluster, error)

+ func (c *Client) GetInstanceTypesMetadata(zone string) ([]compute.MachineType, error)

+ func (c *Client) GetInstanceTypesMetadataForAllZones() ([]compute.MachineType, error)

+ func (c *Client) GetInstanceTypesWithPrefix(prefix string, zone string) ([]string, error)

+ func (c *Client) IsAcceleratorTypeAvailable(acceleratorType string, zone string) (bool, error)

+ func (c *Client) IsGCSFile(bucket string, key string) (bool, error)

+ func (c *Client) IsInstanceTypeAvailable(instanceType string, zone string) (bool, error)

+ func (c *Client) IsProjectIDValid() (bool, error)

+ func (c *Client) IsZoneValid(zone string) (bool, error)

+ func (c *Client) ListGCSDir(bucket string, gcsDir string, maxResults *int64) ([]string, error)

+ func (c *Client) ListGCSDirOneLevel(bucket string, gcsDir string, maxResults *int64) ([]string, error)

+ func (c *Client) ListGCSPathDir(gcsDirPath string, maxResults *int64) ([]string, error)

+ func (c *Client) ReadBytesFromGCS(bucket string, key string) ([]byte, error)

+ func (c *Client) ReadJSONFromGCS(objPtr interface{}, bucket string, key string) error

+ func (c *Client) UploadBytesToGCS(data []byte, bucket string, key string) error

+ func (c *Client) UploadJSONToGCS(obj interface{}, bucket string, key string) error

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