sqlmesh

Documentation

Index

• func CollectAuditLog(output *sqlmeshv1.IngestExecutionRequest, filename string) error
• func CollectMetadata(url url.URL, fileContentGlobFilter GlobFilter) (*ingestsqlmeshv1.IngestMetadataRequest, error)
• func ModelNames(models json.RawMessage) ([]string, error)
• func NewSQLMeshMetadata() *ingestsqlmeshv1.IngestMetadataRequest
• func WaitForSQLMeshToStart(url url.URL)
• type Api
  • func NewAPIClient(url url.URL) Api
• type ApiImpl
  • func (a ApiImpl) GetEnvironments() (json.RawMessage, error)
  • func (a ApiImpl) GetFileContent(filePath string) (json.RawMessage, error)
  • func (a ApiImpl) GetFiles() (json.RawMessage, error)
  • func (a ApiImpl) GetLineage(modelName string) (json.RawMessage, error)
  • func (a ApiImpl) GetMeta() (json.RawMessage, error)
  • func (a ApiImpl) GetModel(modelName string) (json.RawMessage, error)
  • func (a ApiImpl) GetModels() (json.RawMessage, error)
  • func (a ApiImpl) Health() (json.RawMessage, error)
• type Directory
• type File
• type GlobFilter
  • func NewExcludeEverythingGlobFilter() GlobFilter
  • func NewGlobFilter(includePattern string, excludePattern string) GlobFilter
• type GlobFilterImpl
  • func (g GlobFilterImpl) Match(s string) (bool, error)

Functions

func CollectAuditLog

func CollectAuditLog(output *sqlmeshv1.IngestExecutionRequest, filename string) error

func CollectMetadata

func CollectMetadata(url url.URL, fileContentGlobFilter GlobFilter) (*ingestsqlmeshv1.IngestMetadataRequest, error)

func ModelNames

func ModelNames(models json.RawMessage) ([]string, error)

func NewSQLMeshMetadata

func NewSQLMeshMetadata() *ingestsqlmeshv1.IngestMetadataRequest

func WaitForSQLMeshToStart

func WaitForSQLMeshToStart(url url.URL)

Types

type Api

type Api interface {
	GetMeta() (json.RawMessage, error)
	GetModels() (json.RawMessage, error)
	GetModel(modelName string) (json.RawMessage, error)
	GetLineage(modelName string) (json.RawMessage, error)
	GetEnvironments() (json.RawMessage, error)
	GetFiles() (json.RawMessage, error)
	GetFileContent(filePath string) (json.RawMessage, error)
	Health() (json.RawMessage, error)
}

func NewAPIClient

func NewAPIClient(url url.URL) Api

type ApiImpl

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

func (ApiImpl) GetEnvironments

func (a ApiImpl) GetEnvironments() (json.RawMessage, error)

func (ApiImpl) GetFileContent

func (a ApiImpl) GetFileContent(filePath string) (json.RawMessage, error)

func (ApiImpl) GetFiles

func (a ApiImpl) GetFiles() (json.RawMessage, error)

func (ApiImpl) GetLineage

func (a ApiImpl) GetLineage(modelName string) (json.RawMessage, error)

func (ApiImpl) GetMeta

func (a ApiImpl) GetMeta() (json.RawMessage, error)

func (ApiImpl) GetModel

func (a ApiImpl) GetModel(modelName string) (json.RawMessage, error)

func (ApiImpl) GetModels

func (a ApiImpl) GetModels() (json.RawMessage, error)

func (ApiImpl) Health

func (a ApiImpl) Health() (json.RawMessage, error)

type Directory

type Directory struct {
	Name        string      `json:"name"`
	Path        string      `json:"path"`
	Directories []Directory `json:"directories,omitempty"`
	Files       []File      `json:"files,omitempty"`
}

type File

type File struct {
	Name      string  `json:"name"`
	Path      string  `json:"path"`
	Extension *string `json:"extension,omitempty"`
	Content   *string `json:"content,omitempty"`
}

type GlobFilter

type GlobFilter interface {
	Match(string) (bool, error)
}

func NewExcludeEverythingGlobFilter

func NewExcludeEverythingGlobFilter() GlobFilter

func NewGlobFilter

func NewGlobFilter(includePattern string, excludePattern string) GlobFilter

type GlobFilterImpl

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

func (GlobFilterImpl) Match

func (g GlobFilterImpl) Match(s string) (bool, error)