dataform

Documentation

Index

• func DataformRepositorySpec_FromProto(mapCtx *direct.MapContext, in *pb.Repository) *krm.DataformRepositorySpec
• func DataformRepositorySpec_ToProto(mapCtx *direct.MapContext, in *krm.DataformRepositorySpec) *pb.Repository
• func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
• func RepositoryGitRemoteSettings_FromProto(mapCtx *direct.MapContext, in *pb.Repository_GitRemoteSettings) *krm.RepositoryGitRemoteSettings
• func RepositoryGitRemoteSettings_ToProto(mapCtx *direct.MapContext, in *krm.RepositoryGitRemoteSettings) *pb.Repository_GitRemoteSettings
• func RepositoryWorkspaceCompilationOverrides_FromProto(mapCtx *direct.MapContext, in *pb.Repository_WorkspaceCompilationOverrides) *krm.RepositoryWorkspaceCompilationOverrides
• func RepositoryWorkspaceCompilationOverrides_ToProto(mapCtx *direct.MapContext, in *krm.RepositoryWorkspaceCompilationOverrides) *pb.Repository_WorkspaceCompilationOverrides
• type Adapter
  • func (a *Adapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
  • func (a *Adapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
  • func (a *Adapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
  • func (a *Adapter) Find(ctx context.Context) (bool, error)
  • func (a *Adapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Functions

func DataformRepositorySpec_FromProto

func DataformRepositorySpec_FromProto(mapCtx *direct.MapContext, in *pb.Repository) *krm.DataformRepositorySpec

func DataformRepositorySpec_ToProto

func DataformRepositorySpec_ToProto(mapCtx *direct.MapContext, in *krm.DataformRepositorySpec) *pb.Repository

func NewModel

func NewModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func RepositoryGitRemoteSettings_FromProto

func RepositoryGitRemoteSettings_FromProto(mapCtx *direct.MapContext, in *pb.Repository_GitRemoteSettings) *krm.RepositoryGitRemoteSettings

func RepositoryGitRemoteSettings_ToProto

func RepositoryGitRemoteSettings_ToProto(mapCtx *direct.MapContext, in *krm.RepositoryGitRemoteSettings) *pb.Repository_GitRemoteSettings

func RepositoryWorkspaceCompilationOverrides_FromProto

func RepositoryWorkspaceCompilationOverrides_FromProto(mapCtx *direct.MapContext, in *pb.Repository_WorkspaceCompilationOverrides) *krm.RepositoryWorkspaceCompilationOverrides

func RepositoryWorkspaceCompilationOverrides_ToProto

func RepositoryWorkspaceCompilationOverrides_ToProto(mapCtx *direct.MapContext, in *krm.RepositoryWorkspaceCompilationOverrides) *pb.Repository_WorkspaceCompilationOverrides

Types

type Adapter

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

func (*Adapter) Create

func (a *Adapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

func (*Adapter) Delete

func (a *Adapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete implements the Adapter interface.

func (*Adapter) Export

func (a *Adapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

func (*Adapter) Find

func (a *Adapter) Find(ctx context.Context) (bool, error)

func (*Adapter) Update

func (a *Adapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error