resource

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2023 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.