job.go

// *** WARNING: this file was generated by the Pulumi SDK Generator. ***
// *** Do not edit by hand unless you're certain you know what you are doing! ***

package v20180701

import (
	"context"
	"reflect"

	"github.com/pkg/errors"
	"github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)

// A Job resource type. The progress and state can be obtained by polling a Job or subscribing to events using EventGrid.
type Job struct {
	pulumi.CustomResourceState

	// Customer provided key, value pairs that will be returned in Job and JobOutput state events.
	CorrelationData pulumi.StringMapOutput `pulumi:"correlationData"`
	// The UTC date and time when the Job was created, in 'YYYY-MM-DDThh:mm:ssZ' format.
	Created pulumi.StringOutput `pulumi:"created"`
	// Optional customer supplied description of the Job.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// The UTC date and time at which this Job finished processing.
	EndTime pulumi.StringOutput `pulumi:"endTime"`
	// The inputs for the Job.
	Input pulumi.AnyOutput `pulumi:"input"`
	// The UTC date and time when the Job was last updated, in 'YYYY-MM-DDThh:mm:ssZ' format.
	LastModified pulumi.StringOutput `pulumi:"lastModified"`
	// The name of the resource.
	Name pulumi.StringOutput `pulumi:"name"`
	// The outputs for the Job.
	Outputs JobOutputAssetResponseArrayOutput `pulumi:"outputs"`
	// Priority with which the job should be processed. Higher priority jobs are processed before lower priority jobs. If not set, the default is normal.
	Priority pulumi.StringPtrOutput `pulumi:"priority"`
	// The UTC date and time at which this Job began processing.
	StartTime pulumi.StringOutput `pulumi:"startTime"`
	// The current state of the job.
	State pulumi.StringOutput `pulumi:"state"`
	// The type of the resource.
	Type pulumi.StringOutput `pulumi:"type"`
}

// NewJob registers a new resource with the given unique name, arguments, and options.
func NewJob(ctx *pulumi.Context,
	name string, args *JobArgs, opts ...pulumi.ResourceOption) (*Job, error) {
	if args == nil {
		return nil, errors.New("missing one or more required arguments")
	}

	if args.AccountName == nil {
		return nil, errors.New("invalid value for required argument 'AccountName'")
	}
	if args.Input == nil {
		return nil, errors.New("invalid value for required argument 'Input'")
	}
	if args.JobName == nil {
		return nil, errors.New("invalid value for required argument 'JobName'")
	}
	if args.Outputs == nil {
		return nil, errors.New("invalid value for required argument 'Outputs'")
	}
	if args.ResourceGroupName == nil {
		return nil, errors.New("invalid value for required argument 'ResourceGroupName'")
	}
	if args.TransformName == nil {
		return nil, errors.New("invalid value for required argument 'TransformName'")
	}
	aliases := pulumi.Aliases([]pulumi.Alias{
		{
			Type: pulumi.String("azure-nextgen:media/latest:Job"),
		},
		{
			Type: pulumi.String("azure-nextgen:media/v20180330preview:Job"),
		},
		{
			Type: pulumi.String("azure-nextgen:media/v20180601preview:Job"),
		},
		{
			Type: pulumi.String("azure-nextgen:media/v20200501:Job"),
		},
	})
	opts = append(opts, aliases)
	var resource Job
	err := ctx.RegisterResource("azure-nextgen:media/v20180701:Job", name, args, &resource, opts...)
	if err != nil {
		return nil, err
	}
	return &resource, nil
}

// GetJob gets an existing Job resource's state with the given name, ID, and optional
// state properties that are used to uniquely qualify the lookup (nil if not required).
func GetJob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *JobState, opts ...pulumi.ResourceOption) (*Job, error) {
	var resource Job
	err := ctx.ReadResource("azure-nextgen:media/v20180701:Job", name, id, state, &resource, opts...)
	if err != nil {
		return nil, err
	}
	return &resource, nil
}

// Input properties used for looking up and filtering Job resources.
type jobState struct {
	// Customer provided key, value pairs that will be returned in Job and JobOutput state events.
	CorrelationData map[string]string `pulumi:"correlationData"`
	// The UTC date and time when the Job was created, in 'YYYY-MM-DDThh:mm:ssZ' format.
	Created *string `pulumi:"created"`
	// Optional customer supplied description of the Job.
	Description *string `pulumi:"description"`
	// The UTC date and time at which this Job finished processing.
	EndTime *string `pulumi:"endTime"`
	// The inputs for the Job.
	Input interface{} `pulumi:"input"`
	// The UTC date and time when the Job was last updated, in 'YYYY-MM-DDThh:mm:ssZ' format.
	LastModified *string `pulumi:"lastModified"`
	// The name of the resource.
	Name *string `pulumi:"name"`
	// The outputs for the Job.
	Outputs []JobOutputAssetResponse `pulumi:"outputs"`
	// Priority with which the job should be processed. Higher priority jobs are processed before lower priority jobs. If not set, the default is normal.
	Priority *string `pulumi:"priority"`
	// The UTC date and time at which this Job began processing.
	StartTime *string `pulumi:"startTime"`
	// The current state of the job.
	State *string `pulumi:"state"`
	// The type of the resource.
	Type *string `pulumi:"type"`
}

type JobState struct {
	// Customer provided key, value pairs that will be returned in Job and JobOutput state events.
	CorrelationData pulumi.StringMapInput
	// The UTC date and time when the Job was created, in 'YYYY-MM-DDThh:mm:ssZ' format.
	Created pulumi.StringPtrInput
	// Optional customer supplied description of the Job.
	Description pulumi.StringPtrInput
	// The UTC date and time at which this Job finished processing.
	EndTime pulumi.StringPtrInput
	// The inputs for the Job.
	Input pulumi.Input
	// The UTC date and time when the Job was last updated, in 'YYYY-MM-DDThh:mm:ssZ' format.
	LastModified pulumi.StringPtrInput
	// The name of the resource.
	Name pulumi.StringPtrInput
	// The outputs for the Job.
	Outputs JobOutputAssetResponseArrayInput
	// Priority with which the job should be processed. Higher priority jobs are processed before lower priority jobs. If not set, the default is normal.
	Priority pulumi.StringPtrInput
	// The UTC date and time at which this Job began processing.
	StartTime pulumi.StringPtrInput
	// The current state of the job.
	State pulumi.StringPtrInput
	// The type of the resource.
	Type pulumi.StringPtrInput
}

func (JobState) ElementType() reflect.Type {
	return reflect.TypeOf((*jobState)(nil)).Elem()
}

type jobArgs struct {
	// The Media Services account name.
	AccountName string `pulumi:"accountName"`
	// Customer provided key, value pairs that will be returned in Job and JobOutput state events.
	CorrelationData map[string]string `pulumi:"correlationData"`
	// Optional customer supplied description of the Job.
	Description *string `pulumi:"description"`
	// The inputs for the Job.
	Input interface{} `pulumi:"input"`
	// The Job name.
	JobName string `pulumi:"jobName"`
	// The outputs for the Job.
	Outputs []JobOutputAsset `pulumi:"outputs"`
	// Priority with which the job should be processed. Higher priority jobs are processed before lower priority jobs. If not set, the default is normal.
	Priority *string `pulumi:"priority"`
	// The name of the resource group within the Azure subscription.
	ResourceGroupName string `pulumi:"resourceGroupName"`
	// The Transform name.
	TransformName string `pulumi:"transformName"`
}

// The set of arguments for constructing a Job resource.
type JobArgs struct {
	// The Media Services account name.
	AccountName pulumi.StringInput
	// Customer provided key, value pairs that will be returned in Job and JobOutput state events.
	CorrelationData pulumi.StringMapInput
	// Optional customer supplied description of the Job.
	Description pulumi.StringPtrInput
	// The inputs for the Job.
	Input pulumi.Input
	// The Job name.
	JobName pulumi.StringInput
	// The outputs for the Job.
	Outputs JobOutputAssetArrayInput
	// Priority with which the job should be processed. Higher priority jobs are processed before lower priority jobs. If not set, the default is normal.
	Priority pulumi.StringPtrInput
	// The name of the resource group within the Azure subscription.
	ResourceGroupName pulumi.StringInput
	// The Transform name.
	TransformName pulumi.StringInput
}

func (JobArgs) ElementType() reflect.Type {
	return reflect.TypeOf((*jobArgs)(nil)).Elem()
}

type JobInput interface {
	pulumi.Input

	ToJobOutput() JobOutput
	ToJobOutputWithContext(ctx context.Context) JobOutput
}

func (*Job) ElementType() reflect.Type {
	return reflect.TypeOf((*Job)(nil))
}

func (i *Job) ToJobOutput() JobOutput {
	return i.ToJobOutputWithContext(context.Background())
}

func (i *Job) ToJobOutputWithContext(ctx context.Context) JobOutput {
	return pulumi.ToOutputWithContext(ctx, i).(JobOutput)
}

type JobOutput struct {
	*pulumi.OutputState
}

func (JobOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*Job)(nil))
}

func (o JobOutput) ToJobOutput() JobOutput {
	return o
}

func (o JobOutput) ToJobOutputWithContext(ctx context.Context) JobOutput {
	return o
}

func init() {
	pulumi.RegisterOutputType(JobOutput{})
}