scheduler

Documentation

Index

• Variables
• func CreateJobName(projectID string, location string, name string) string
• type Client
  • func NewClient(ctx context.Context, projectID string) (*Client, error)
  • func (c *Client) Create(ctx context.Context, req *scheduler.CreateJobRequest) (*scheduler.Job, error)
  • func (c *Client) Update(ctx context.Context, req *scheduler.UpdateJobRequest) (*scheduler.Job, error)
  • func (c *Client) Upsert(ctx context.Context, req *UpsertJobRequest) (*scheduler.Job, error)
• type JobHttpTarget
  • func (t *JobHttpTarget) JobHttpTarget() *scheduler.Job_HttpTarget
• type UpsertJobRequest
  • func (req *UpsertJobRequest) CreateJobRequest() (*scheduler.CreateJobRequest, error)
  • func (req *UpsertJobRequest) UpdateJobRequest() (*scheduler.UpdateJobRequest, error)

Variables

var ErrInvalidArgument failure.StringCode = "InvalidArgument"

Functions

func CreateJobName

func CreateJobName(projectID string, location string, name string) string

Types

type Client

type Client struct {
	C *cs.CloudSchedulerClient
}

func NewClient

func NewClient(ctx context.Context, projectID string) (*Client, error)

func (*Client) Create

func (c *Client) Create(ctx context.Context, req *scheduler.CreateJobRequest) (*scheduler.Job, error)

func (*Client) Update

func (c *Client) Update(ctx context.Context, req *scheduler.UpdateJobRequest) (*scheduler.Job, error)

func (*Client) Upsert

func (c *Client) Upsert(ctx context.Context, req *UpsertJobRequest) (*scheduler.Job, error)

type JobHttpTarget

type JobHttpTarget struct {
	Uri                string
	HttpMethod         scheduler.HttpMethod
	Headers            map[string]string
	Body               []byte
	OidcServiceAccount string
}

func (*JobHttpTarget) JobHttpTarget

func (t *JobHttpTarget) JobHttpTarget() *scheduler.Job_HttpTarget

type UpsertJobRequest

type UpsertJobRequest struct {
	ProjectID   string
	Location    string
	Name        string
	Description string
	Schedule    string
	TimeZone    string
	Target      *JobHttpTarget
}

func (*UpsertJobRequest) CreateJobRequest

func (req *UpsertJobRequest) CreateJobRequest() (*scheduler.CreateJobRequest, error)

func (*UpsertJobRequest) UpdateJobRequest

func (req *UpsertJobRequest) UpdateJobRequest() (*scheduler.UpdateJobRequest, error)