datasource

Documentation

Index

• func NewDataSource[T any](d DataSource[T]) func() datasource.DataSourceWithConfigure
• type ConfigureRequest
• type DataSource
• type DataSourceWithValidation
• type MonadRequest
  • func (r MonadRequest) Then(f func()) utils.ErrorMonad
• type ReadRequest
• type ReadResponse
  • func (r *ReadResponse[TData]) SetState(state TData)
• type StateSetter
• type ValidateRequest
• type ValidateResponse

Functions

func NewDataSource

func NewDataSource[T any](d DataSource[T]) func() datasource.DataSourceWithConfigure

Types

type ConfigureRequest

type ConfigureRequest struct {
	Conn sql.Connection
}

type DataSource

type DataSource[TData any] interface {
	GetName() string
	GetSchema(ctx context.Context) tfsdk.Schema
	Read(ctx context.Context, req ReadRequest[TData], resp *ReadResponse[TData])
}

type DataSourceWithValidation

type DataSourceWithValidation[TData any] interface {
	Validate(ctx context.Context, req ValidateRequest[TData], resp *ValidateResponse[TData])
}

type MonadRequest

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

func (MonadRequest) Then

func (r MonadRequest) Then(f func()) utils.ErrorMonad

type ReadRequest

type ReadRequest[TData any] struct {
	MonadRequest
	Conn   sql.Connection
	Config TData
}

type ReadResponse

type ReadResponse[TData any] struct {
	// contains filtered or unexported fields
}

func (*ReadResponse[TData]) SetState

func (r *ReadResponse[TData]) SetState(state TData)

type StateSetter

type StateSetter[TData any] func(state TData)

type ValidateRequest

type ValidateRequest[TData any] struct {
	MonadRequest
	Config TData
}

type ValidateResponse

type ValidateResponse[TData any] struct{}