resource

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 12, 2024 License: MPL-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDestinationResource

func NewDestinationResource() res.Resource

func NewPipelineResource

func NewPipelineResource() res.Resource

func NewSourceResource

func NewSourceResource() res.Resource

Types

type Destination

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

Destination defines the resource implementation.

func (*Destination) Configure

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

func (*Destination) Create

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

func (*Destination) Delete

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

func (*Destination) ImportState

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

func (*Destination) Metadata

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

func (*Destination) Read

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

func (*Destination) Schema

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

func (*Destination) Update

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

type DestinationModel

type DestinationModel struct {
	ID        types.String    `json:"id" tfsdk:"id"`
	Name      types.String    `json:"name" tfsdk:"name"`
	Connector types.String    `json:"connector" tfsdk:"connector"`
	Config    jsontypes.Exact `json:"config" tfsdk:"config"`
	Instance  jsontypes.Exact `json:"instance" tfsdk:"-"`
}

DestinationModel describes the resource data model.

type Pipeline

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

Pipeline defines the res implementation.

func (*Pipeline) Configure

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

func (*Pipeline) Create

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

func (*Pipeline) Delete

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

func (*Pipeline) ImportState

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

func (*Pipeline) Metadata

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

func (*Pipeline) Read

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

func (*Pipeline) Schema

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

func (*Pipeline) Update

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

type PipelineModel

type PipelineModel struct {
	ID         basetypes.StringValue `json:"id" tfsdk:"id"`
	Name       string                `json:"name" tfsdk:"name" tfsdk:"name"`
	SubID      string                `json:"sub_id" tfsdk:"-" tfsdk:"-"`
	TenantID   string                `json:"tenant_id" tfsdk:"-"`
	Transforms []string              `json:"transforms" tfsdk:"transforms"`
	TopicIDs   []string              `json:"topic_ids" tfsdk:"-"`
	Topics     []string              `json:"topics" tfsdk:"-"`
	Source     struct {
		ID struct {
			OID basetypes.StringValue `json:"oid" tfsdk:"oid"`
		} `json:"id" tfsdk:"id"`
		Name         string `json:"name" tfsdk:"name"`
		SubID        string `json:"sub_id" tfsdk:"-"`
		TenantID     string `json:"tenant_id" tfsdk:"-"`
		Connector    string `json:"connector" tfsdk:"connector"`
		TaskStatuses struct {
			Field1 struct {
				Status string `json:"status" tfsdk:"-"`
			} `json:"0" tfsdk:"-"`
		} `json:"task_statuses" tfsdk:"-"`
		Tasks           []int    `json:"tasks" tfsdk:"-"`
		ConnectorStatus string   `json:"connector_status" tfsdk:"-"`
		Topics          []string `json:"topics" tfsdk:"topics"`
	} `json:"source" tfsdk:"source"`
	Destination struct {
		ID struct {
			OID basetypes.StringValue `json:"oid" tfsdk:"oid"`
		} `json:"id" tfsdk:"id"`
		Name         string `json:"name" tfsdk:"name"`
		SubID        string `json:"sub_id" tfsdk:"-"`
		TenantID     string `json:"tenant_id" tfsdk:"-"`
		Connector    string `json:"connector" tfsdk:"connector"`
		TaskStatuses struct {
			Field1 struct {
				Status string `json:"status" tfsdk:"status"`
			} `json:"0" tfsdk:"-"`
		} `json:"task_statuses" tfsdk:"-"`
		Tasks           []int  `json:"tasks" tfsdk:"-"`
		ConnectorStatus string `json:"connector_status" tfsdk:"-"`
	} `json:"destination" tfsdk:"destination"`
	Instance jsontypes.Exact `json:"instance" tfsdk:"-"`
}

PipelineModel describes the res data model.

type Source

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

Source defines the resource implementation.

func (*Source) Configure

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

func (*Source) Create

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

func (*Source) Delete

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

func (*Source) ImportState

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

func (*Source) Metadata

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

func (*Source) Read

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

func (*Source) Schema

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

func (*Source) Update

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

type SourceModel

type SourceModel struct {
	ID        types.String    `json:"id" tfsdk:"id"`
	Name      types.String    `json:"name" tfsdk:"name"`
	Connector types.String    `json:"connector" tfsdk:"connector"`
	Config    jsontypes.Exact `json:"config" tfsdk:"config"`
	Instance  jsontypes.Exact `json:"instance" tfsdk:"-"`
}

SourceModel describes the resource data model.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL