gcp

Documentation

Index

• Variables
• func AddIncomingFile(fileName string, buff bytes.Buffer, pckg *packages.Package, v version.Version) error
• func GetStorageClient(ctx context.Context) (*storage.Client, error)
• func Inflate(gzipStream io.Reader, onFile func(string, io.Reader) error) error
• func ReadObject(ctx context.Context, bucket string, name string) ([]byte, error)
• type GCSEvent

Variables

var (
	GCS_BUCKET = os.Getenv("GCS_BUCKET")
)

Functions

func AddIncomingFile

func AddIncomingFile(fileName string, buff bytes.Buffer, pckg *packages.Package, v version.Version) error

func GetStorageClient

func GetStorageClient(ctx context.Context) (*storage.Client, error)

GetStorageClient gets the GCP Storage Client.

func Inflate

func Inflate(gzipStream io.Reader, onFile func(string, io.Reader) error) error

func ReadObject

func ReadObject(ctx context.Context, bucket string, name string) ([]byte, error)

Types

type GCSEvent

type GCSEvent struct {
	Kind                    string                 `json:"kind"`
	ID                      string                 `json:"id"`
	SelfLink                string                 `json:"selfLink"`
	Name                    string                 `json:"name"`
	Bucket                  string                 `json:"bucket"`
	Generation              string                 `json:"generation"`
	Metageneration          string                 `json:"metageneration"`
	ContentType             string                 `json:"contentType"`
	TimeCreated             time.Time              `json:"timeCreated"`
	Updated                 time.Time              `json:"updated"`
	TemporaryHold           bool                   `json:"temporaryHold"`
	EventBasedHold          bool                   `json:"eventBasedHold"`
	RetentionExpirationTime time.Time              `json:"retentionExpirationTime"`
	StorageClass            string                 `json:"storageClass"`
	TimeStorageClassUpdated time.Time              `json:"timeStorageClassUpdated"`
	Size                    string                 `json:"size"`
	MD5Hash                 string                 `json:"md5Hash"`
	MediaLink               string                 `json:"mediaLink"`
	ContentEncoding         string                 `json:"contentEncoding"`
	ContentDisposition      string                 `json:"contentDisposition"`
	CacheControl            string                 `json:"cacheControl"`
	Metadata                map[string]interface{} `json:"metadata"`
	CRC32C                  string                 `json:"crc32c"`
	ComponentCount          int                    `json:"componentCount"`
	Etag                    string                 `json:"etag"`
	CustomerEncryption      struct {
		EncryptionAlgorithm string `json:"encryptionAlgorithm"`
		KeySha256           string `json:"keySha256"`
	}
	KMSKeyName    string `json:"kmsKeyName"`
	ResourceState string `json:"resourceState"`
}

GCSEvent is the payload of a GCS event.