provider

Documentation

Overview

Package provider provider.go

Package provider.go

Package provider.go

Package provider.go

Index

• func New(version string) func() provider.Provider
• func NewSchemaDataSource() datasource.DataSource
• func NewSchemaResource() resource.Resource
• type ClientSchema
  • func NewClientSchema(apiURL string) *ClientSchema
  • func (c *ClientSchema) CreateSchema(schema *SchemaModel) error
  • func (c *ClientSchema) DeleteSchema(subject string) error
  • func (c *ClientSchema) GetLatestVersion(subject string) (int64, error)
  • func (c *ClientSchema) GetSchema(subject string, version int64) (*SchemaModel, error)
  • func (c *ClientSchema) UpdateSchema(schema *SchemaModel) error
• type SchemaDataSource
  • func (d *SchemaDataSource) Configure(_ context.Context, req datasource.ConfigureRequest, ...)
  • func (d *SchemaDataSource) Metadata(_ context.Context, req datasource.MetadataRequest, ...)
  • func (d *SchemaDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse)
  • func (d *SchemaDataSource) Schema(_ context.Context, _ datasource.SchemaRequest, resp *datasource.SchemaResponse)
• type SchemaInfo
• type SchemaModel
• type SchemaProvider
  • func (p *SchemaProvider) Configure(ctx context.Context, req provider.ConfigureRequest, ...)
  • func (p *SchemaProvider) DataSources(_ context.Context) []func() datasource.DataSource
  • func (p *SchemaProvider) Metadata(_ context.Context, _ provider.MetadataRequest, resp *provider.MetadataResponse)
  • func (p *SchemaProvider) Resources(_ context.Context) []func() resource.Resource
  • func (p *SchemaProvider) Schema(_ context.Context, _ provider.SchemaRequest, resp *provider.SchemaResponse)
• type SchemaProviderModel
• type SchemaResource
  • func (r *SchemaResource) Configure(_ context.Context, req resource.ConfigureRequest, ...)
  • func (r *SchemaResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse)
  • func (r *SchemaResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse)
  • func (r *SchemaResource) ImportState(ctx context.Context, req resource.ImportStateRequest, ...)
  • func (r *SchemaResource) Metadata(_ context.Context, req resource.MetadataRequest, ...)
  • func (r *SchemaResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse)
  • func (r *SchemaResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)
  • func (r *SchemaResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse)

Functions

func New

func New(version string) func() provider.Provider

func NewSchemaDataSource

func NewSchemaDataSource() datasource.DataSource

func NewSchemaResource

func NewSchemaResource() resource.Resource

Types

type ClientSchema

type ClientSchema struct {
	APIURL string
}

func NewClientSchema

func NewClientSchema(apiURL string) *ClientSchema

func (*ClientSchema) CreateSchema

func (c *ClientSchema) CreateSchema(schema *SchemaModel) error

func (*ClientSchema) DeleteSchema

func (c *ClientSchema) DeleteSchema(subject string) error

func (*ClientSchema) GetLatestVersion

func (c *ClientSchema) GetLatestVersion(subject string) (int64, error)

func (*ClientSchema) GetSchema

func (c *ClientSchema) GetSchema(subject string, version int64) (*SchemaModel, error)

func (*ClientSchema) UpdateSchema

func (c *ClientSchema) UpdateSchema(schema *SchemaModel) error

type SchemaDataSource

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

SchemaDataSource defines the data source implementation.

func (*SchemaDataSource) Configure

func (d *SchemaDataSource) Configure(_ context.Context, req datasource.ConfigureRequest, resp *datasource.ConfigureResponse)

func (*SchemaDataSource) Metadata

func (d *SchemaDataSource) Metadata(_ context.Context, req datasource.MetadataRequest, resp *datasource.MetadataResponse)

func (*SchemaDataSource) Read

func (d *SchemaDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse)

func (*SchemaDataSource) Schema

func (d *SchemaDataSource) Schema(_ context.Context, _ datasource.SchemaRequest, resp *datasource.SchemaResponse)

type SchemaInfo

type SchemaInfo struct {
	Schema     string `json:"schema"`
	SchemaType string `json:"schemaType"`
}

type SchemaModel

type SchemaModel struct {
	Subject    types.String `tfsdk:"subject"`
	Schema     types.String `tfsdk:"schema"`
	SchemaType types.String `tfsdk:"schema_type"`
	Version    types.Int64  `tfsdk:"version"`
	Id         types.Int64  `tfsdk:"id"`
}

type SchemaProvider

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

func (*SchemaProvider) Configure

func (p *SchemaProvider) Configure(ctx context.Context, req provider.ConfigureRequest, resp *provider.ConfigureResponse)

func (*SchemaProvider) DataSources

func (p *SchemaProvider) DataSources(_ context.Context) []func() datasource.DataSource

func (*SchemaProvider) Metadata

func (p *SchemaProvider) Metadata(_ context.Context, _ provider.MetadataRequest, resp *provider.MetadataResponse)

func (*SchemaProvider) Resources

func (p *SchemaProvider) Resources(_ context.Context) []func() resource.Resource

func (*SchemaProvider) Schema

func (p *SchemaProvider) Schema(_ context.Context, _ provider.SchemaRequest, resp *provider.SchemaResponse)

type SchemaProviderModel

type SchemaProviderModel struct {
	SchemaApiUrl types.String `tfsdk:"schema_api_url"`
}

SchemaProviderModel describes the provider data model.

type SchemaResource

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

SchemaResource defines the resource implementation.

func (*SchemaResource) Configure

func (r *SchemaResource) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse)

func (*SchemaResource) Create

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

func (*SchemaResource) Delete

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

func (*SchemaResource) ImportState

func (r *SchemaResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse)

func (*SchemaResource) Metadata

func (r *SchemaResource) Metadata(_ context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse)

func (*SchemaResource) Read

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

func (*SchemaResource) Schema

func (r *SchemaResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse)

func (*SchemaResource) Update

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