gcp

Documentation

Index

• func IsValidUUID(u string) bool
• func NewFile(bucketName, base, cacheControl string) (gateway.File, error)
• func NewTaskRunner(ctx context.Context, conf *TaskConfig) (gateway.TaskRunner, error)
• type TaskConfig
• type TaskRunner
  • func (t *TaskRunner) Retry(ctx context.Context, id string) error
  • func (t *TaskRunner) Run(ctx context.Context, p task.Payload) error

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"`
	CopierImage             string `default:"reearth/reearth-cms-copier"`
	DBSecretName            string `default:"reearth-cms-db"`
	AccountDBSecretName     string `default:"reearth-cms-db-users"`
	DBName                  string `pp:",omitempty"`
	AccountDBName           string `pp:",omitempty"`
	CmsImage                string `default:"reearth/reearth-cms"`
	BuildServiceAccount     string `pp:",omitempty"`
	WorkerPool              string `pp:",omitempty"`
}

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