abs

Documentation

Index

• Variables
• func GetType(resource *model.Resource) string
• func RecordLikeAsRecord(record RecordLike) *model.Record
• func RecordLikeAsRecords(record []RecordLike) []*model.Record
• func UpdateRecordsProperties(record RecordLike, properties map[string]*structpb.Value)
• type AddResourceParams
• type Backend
• type BackendConstructor
• type BackendGenericInterface
• type BackendRecordsInterface
• type BackendSchemaInterface
• type BackendType
• type DataSource
• type DataSourceConnectionDetails
• type EntityMapper
• type ListRecordParams
• type PropertyWithPath
• type RecordLike
  • func NewRecordLike() RecordLike
  • func RecordLikeAsRecords2(record []*model.Record) []RecordLike
• type ResourceIdentity
  • func (r ResourceIdentity) Type() string
• type ResourceLike
• type Schema
• type UpgradeResourceParams

Variables

var ClientTrackIdContextKey = contextKey("ClientTrackIdContextKey")

var LogFieldsContextKey = contextKey("LogFieldsContextKey")

var SystemContextKey = contextKey("SystemContextKey")

var UserContextKey = contextKey("UserContextKey")

Functions

func GetType

func GetType(resource *model.Resource) string

func RecordLikeAsRecord

func RecordLikeAsRecord(record RecordLike) *model.Record

func RecordLikeAsRecords

func RecordLikeAsRecords(record []RecordLike) []*model.Record

func UpdateRecordsProperties

func UpdateRecordsProperties(record RecordLike, properties map[string]*structpb.Value)

Types

type AddResourceParams

type AddResourceParams struct {
	Resource       *model.Resource
	IgnoreIfExists bool
	Migrate        bool
	ForceMigrate   bool
}

type Backend

type Backend interface {
	BackendGenericInterface
	BackendRecordsInterface
	BackendSchemaInterface

	SetSchema(schema *Schema)
}

type BackendConstructor

type BackendConstructor func(dataSourceRecord DataSource) Backend

type BackendGenericInterface

type BackendGenericInterface interface {
	GetStatus(ctx context.Context) (connectionAlreadyInitiated bool, testConnection bool, err error)
	DestroyDataSource(ctx context.Context)
}

type BackendRecordsInterface

type BackendRecordsInterface interface {
	AddRecords(ctx context.Context, resource *model.Resource, records []RecordLike) ([]RecordLike, error)
	UpdateRecords(ctx context.Context, resource *model.Resource, records []RecordLike) ([]RecordLike, error)
	GetRecord(ctx context.Context, resource *model.Resource, id string, resolveReferences []string) (RecordLike, error)
	DeleteRecords(ctx context.Context, resource *model.Resource, ids []RecordLike) error
	ListRecords(ctx context.Context, resource *model.Resource, params ListRecordParams) ([]RecordLike, uint32, error)
}

type BackendSchemaInterface

type BackendSchemaInterface interface {
	ListEntities(ctx context.Context) ([]*model.DataSourceCatalog, error)
	PrepareResourceFromEntity(ctx context.Context, catalog, entity string) (*model.Resource, error)
	UpgradeResource(ctx context.Context, params UpgradeResourceParams) error
}

type BackendType

type BackendType struct {
	Name        string
	Constructor BackendConstructor
}

type DataSource

type DataSource interface {
	GetName() string
}

type DataSourceConnectionDetails

type DataSourceConnectionDetails interface {
}

type EntityMapper

type EntityMapper[Entity interface{}] interface {
	New() Entity
	ResourceIdentity() ResourceIdentity
	ToRecord(entity Entity) RecordLike
	FromRecord(record RecordLike) Entity
	ToProperties(entity Entity) map[string]*structpb.Value
	FromProperties(properties map[string]*structpb.Value) Entity
}

type ListRecordParams

type ListRecordParams struct {
	Query             *model.BooleanExpression
	Limit             uint32
	Offset            uint64
	ResolveReferences []string
	Aggregation       *model.Aggregation
	Sorting           *model.Sorting
}

type PropertyWithPath

type PropertyWithPath struct {
	Path     string
	Property *model.ResourceProperty
}

type RecordLike

type RecordLike interface {
	GetProperties() map[string]*structpb.Value
}

func NewRecordLike

func NewRecordLike() RecordLike

func RecordLikeAsRecords2

func RecordLikeAsRecords2(record []*model.Record) []RecordLike

type ResourceIdentity

type ResourceIdentity struct {
	Namespace string
	Name      string
}

func (ResourceIdentity) Type

func (r ResourceIdentity) Type() string

type ResourceLike

type ResourceLike interface {
	GetProperties() []*model.ResourceProperty
	GetTypes() []*model.ResourceSubType
}

type Schema

type Schema struct {
	Resources                    []*model.Resource
	ResourceByNamespaceSlashName map[string]*model.Resource
	ResourceBySlug               map[string]*model.Resource
	ResourcePropertiesByType     map[string]map[model.ResourceProperty_Type][]PropertyWithPath
	ResourcePropertyPaths        map[string]map[string]bool
}

type UpgradeResourceParams

type UpgradeResourceParams struct {
	ForceMigration bool
	MigrationPlan  *model.ResourceMigrationPlan
}