queue_consumer

Documentation

Index

• func NewResource() resource.Resource
• func ResourceSchema(ctx context.Context) schema.Schema
• type QueueConsumerModel
  • func (m QueueConsumerModel) MarshalJSON() (data []byte, err error)
  • func (m QueueConsumerModel) MarshalJSONForUpdate(state QueueConsumerModel) (data []byte, err error)
• type QueueConsumerResource
  • func (r *QueueConsumerResource) ConfigValidators(_ context.Context) []resource.ConfigValidator
  • func (r *QueueConsumerResource) Configure(ctx context.Context, req resource.ConfigureRequest, ...)
  • func (r *QueueConsumerResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)
  • func (r *QueueConsumerResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)
  • func (r *QueueConsumerResource) Metadata(ctx context.Context, req resource.MetadataRequest, ...)
  • func (r *QueueConsumerResource) ModifyPlan(_ context.Context, _ resource.ModifyPlanRequest, ...)
  • func (r *QueueConsumerResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)
  • func (r *QueueConsumerResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)
  • func (r *QueueConsumerResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)
• type QueueConsumerResultEnvelope
• type QueueConsumerSettingsModel

Functions

func NewResource

func NewResource() resource.Resource

func ResourceSchema

func ResourceSchema(ctx context.Context) schema.Schema

Types

type QueueConsumerModel

type QueueConsumerModel struct {
	AccountID       types.String                                         `tfsdk:"account_id" path:"account_id,required"`
	QueueID         types.String                                         `tfsdk:"queue_id" path:"queue_id,required"`
	ScriptName      types.String                                         `tfsdk:"script_name" json:"script_name,optional"`
	ConsumerID      types.String                                         `tfsdk:"consumer_id" json:"consumer_id,computed"`
	CreatedOn       types.String                                         `tfsdk:"created_on" json:"created_on,computed"`
	DeadLetterQueue types.String                                         `tfsdk:"dead_letter_queue" json:"dead_letter_queue,optional"`
	Environment     types.String                                         `tfsdk:"environment" json:"environment,computed_optional"`
	QueueName       types.String                                         `tfsdk:"queue_name" json:"queue_name,computed"`
	Settings        customfield.NestedObject[QueueConsumerSettingsModel] `tfsdk:"settings" json:"settings,computed_optional"`
	Type            types.String                                         `tfsdk:"type" json:"type,required"`
}

func (QueueConsumerModel) MarshalJSON

func (m QueueConsumerModel) MarshalJSON() (data []byte, err error)

func (QueueConsumerModel) MarshalJSONForUpdate

func (m QueueConsumerModel) MarshalJSONForUpdate(state QueueConsumerModel) (data []byte, err error)

type QueueConsumerResource

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

QueueConsumerResource defines the resource implementation.

func (*QueueConsumerResource) ConfigValidators

func (r *QueueConsumerResource) ConfigValidators(_ context.Context) []resource.ConfigValidator

func (*QueueConsumerResource) Configure

func (r *QueueConsumerResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*QueueConsumerResource) Create

func (r *QueueConsumerResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)

func (*QueueConsumerResource) Delete

func (r *QueueConsumerResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)

func (*QueueConsumerResource) Metadata

func (r *QueueConsumerResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*QueueConsumerResource) ModifyPlan

func (r *QueueConsumerResource) ModifyPlan(_ context.Context, _ resource.ModifyPlanRequest, _ *resource.ModifyPlanResponse)

func (*QueueConsumerResource) Read

func (r *QueueConsumerResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)

func (*QueueConsumerResource) Schema

func (r *QueueConsumerResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse)

func (*QueueConsumerResource) Update

func (r *QueueConsumerResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

type QueueConsumerResultEnvelope

type QueueConsumerResultEnvelope struct {
	Result QueueConsumerModel `json:"result"`
}

type QueueConsumerSettingsModel

type QueueConsumerSettingsModel struct {
	BatchSize     types.Float64 `tfsdk:"batch_size" json:"batch_size,computed_optional"`
	MaxRetries    types.Float64 `tfsdk:"max_retries" json:"max_retries,computed_optional"`
	MaxWaitTimeMs types.Float64 `tfsdk:"max_wait_time_ms" json:"max_wait_time_ms,computed_optional"`
}