pipeline

Documentation

Index

• func NewPipelineResource() res.Resource
• type PipelineDestinationModel
• type PipelineResource
  • func (r *PipelineResource) Configure(ctx context.Context, req res.ConfigureRequest, resp *res.ConfigureResponse)
  • func (r *PipelineResource) Create(ctx context.Context, req res.CreateRequest, resp *res.CreateResponse)
  • func (r *PipelineResource) Delete(ctx context.Context, req res.DeleteRequest, resp *res.DeleteResponse)
  • func (r *PipelineResource) ImportState(ctx context.Context, req res.ImportStateRequest, resp *res.ImportStateResponse)
  • func (r *PipelineResource) Metadata(ctx context.Context, req res.MetadataRequest, resp *res.MetadataResponse)
  • func (r *PipelineResource) Read(ctx context.Context, req res.ReadRequest, resp *res.ReadResponse)
  • func (r *PipelineResource) Schema(ctx context.Context, req res.SchemaRequest, resp *res.SchemaResponse)
  • func (r *PipelineResource) Update(ctx context.Context, req res.UpdateRequest, resp *res.UpdateResponse)
• type PipelineResourceModel
• type PipelineSourceModel
• type PipelineTransformModel

Functions

func NewPipelineResource

func NewPipelineResource() res.Resource

Types

type PipelineDestinationModel

type PipelineDestinationModel struct {
	ID        types.String `tfsdk:"id"`
	Name      types.String `tfsdk:"name"`
	Connector types.String `tfsdk:"connector"`
}

type PipelineResource

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

PipelineResource defines the res implementation.

func (*PipelineResource) Configure

func (r *PipelineResource) Configure(ctx context.Context, req res.ConfigureRequest, resp *res.ConfigureResponse)

func (*PipelineResource) Create

func (r *PipelineResource) Create(ctx context.Context, req res.CreateRequest, resp *res.CreateResponse)

func (*PipelineResource) Delete

func (r *PipelineResource) Delete(ctx context.Context, req res.DeleteRequest, resp *res.DeleteResponse)

func (*PipelineResource) ImportState

func (r *PipelineResource) ImportState(ctx context.Context, req res.ImportStateRequest, resp *res.ImportStateResponse)

func (*PipelineResource) Metadata

func (r *PipelineResource) Metadata(ctx context.Context, req res.MetadataRequest, resp *res.MetadataResponse)

func (*PipelineResource) Read

func (r *PipelineResource) Read(ctx context.Context, req res.ReadRequest, resp *res.ReadResponse)

func (*PipelineResource) Schema

func (r *PipelineResource) Schema(ctx context.Context, req res.SchemaRequest, resp *res.SchemaResponse)

func (*PipelineResource) Update

func (r *PipelineResource) Update(ctx context.Context, req res.UpdateRequest, resp *res.UpdateResponse)

type PipelineResourceModel

type PipelineResourceModel struct {
	ID                types.String              `tfsdk:"id"`
	Name              types.String              `tfsdk:"name"`
	SnapshotNewTables types.Bool                `tfsdk:"snapshot_new_tables"`
	Source            *PipelineSourceModel      `tfsdk:"source"`
	Destination       *PipelineDestinationModel `tfsdk:"destination"`
	Transforms        []*PipelineTransformModel `tfsdk:"transforms"`
}

PipelineResourceModel describes the res data model.

type PipelineSourceModel

type PipelineSourceModel struct {
	ID        types.String `tfsdk:"id"`
	Name      types.String `tfsdk:"name"`
	Connector types.String `tfsdk:"connector"`
	Topics    types.Set    `tfsdk:"topics"`
}

type PipelineTransformModel

type PipelineTransformModel struct {
	ID     types.String `tfsdk:"id"`
	Topics types.Set    `tfsdk:"topics"`
}