cloudscheduler

README

Google Kubernetes Engine Service

This service is google.golang.org/api/cloudscheduler/v1/Service proxy

To check all supported method run

     endly -s='gcp/cloudscheduler'

To check method contract run endly -s='gcp/cloudscheduler' -a=methodName

    endly -s='gcp/cloudscheduler:clustersGet' 

References:

• Google Kubernetes Engine API

Usage:

Deploying schedule job

endly deploy authWith=myGoogleSecret.json

@deploy.yaml

pipeline:
  deploy:
    action: gcp/cloudscheduler:deploy
    credentials: viant-e2e
    name: Replay
    schedule: 0 * * * *
    body: body comes here
    httpTarget:
      headers:
      "User-Agent": Google-Cloud-Scheduler"
      httpMethod: POST
      uri: https://us-central1-viant-e2e.cloudfunctions.net/BqTailReplay

Documentation

Index

• Constants
• func InitRequest(context *endly.Context, rawRequest map[string]interface{}) error
• func New() endly.Service
• type CtxClient
  • func GetClient(context *endly.Context) (*CtxClient, error)
  • func (s *CtxClient) Service() interface{}
  • func (s *CtxClient) SetService(service interface{}) error
• type DeployRequest
  • func (r *DeployRequest) Init() error
  • func (r *DeployRequest) Parent(context *endly.Context) string
  • func (r *DeployRequest) Validate() error
• type DeployResponse

Constants

const (
	//ServiceID Google cloudscheduler Service ID.
	ServiceID = "gcp/cloudscheduler"
)

Functions

func InitRequest

func InitRequest(context *endly.Context, rawRequest map[string]interface{}) error

func New

func New() endly.Service

New creates a new cloudscheduler service

Types

type CtxClient

type CtxClient struct {
	*gcp.AbstractClient
	// contains filtered or unexported fields
}

CtxClient represents context client

func GetClient

func GetClient(context *endly.Context) (*CtxClient, error)

func (*CtxClient) Service

func (s *CtxClient) Service() interface{}

func (*CtxClient) SetService

func (s *CtxClient) SetService(service interface{}) error

type DeployRequest

type DeployRequest struct {
	cloudscheduler.Job
	Region string
	Body   string
	// contains filtered or unexported fields
}

DeployJobRequest represents deploy job request

func (*DeployRequest) Init

func (r *DeployRequest) Init() error

func (*DeployRequest) Parent

func (r *DeployRequest) Parent(context *endly.Context) string

func (*DeployRequest) Validate

func (r *DeployRequest) Validate() error

type DeployResponse

type DeployResponse struct {
	*cloudscheduler.Job
}

DeployJobResponse represents deploy job response