gcp

package
v0.0.0-...-2b2b6fc Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsValidUUID

func IsValidUUID(u string) bool

func NewFile

func NewFile(bucketName, base, cacheControl string) (gateway.File, error)

func NewTaskRunner

func NewTaskRunner(ctx context.Context, conf *TaskConfig) (gateway.TaskRunner, error)

Types

type TaskConfig

type TaskConfig struct {
	GCPProject              string `pp:",omitempty"`
	GCPRegion               string `pp:",omitempty"`
	Topic                   string `pp:",omitempty"`
	GCSHost                 string `pp:",omitempty"`
	GCSBucket               string `pp:",omitempty"`
	DecompressorImage       string `default:"reearth/reearth-cms-decompressor"`
	DecompressorTopic       string `default:"decompress"`
	DecompressorGzipExt     string `default:"gml"`
	DecompressorMachineType string `default:"E2_HIGHCPU_8"`
	DecompressorDiskSideGb  int64  `default:"2000"`
}

type TaskRunner

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

func (*TaskRunner) Retry

func (t *TaskRunner) Retry(ctx context.Context, id string) error

func (*TaskRunner) Run

func (t *TaskRunner) Run(ctx context.Context, p task.Payload) error

Run implements gateway.TaskRunner

Jump to

Keyboard shortcuts

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