executor

Documentation

Index

• type DataloaderResultTyped
• type GraphQLExecutor
  • func GetGraphQLExecutor(cfg *models.Config, systemDB interfaces.ApitoSystemDB) *GraphQLExecutor
  • func (s *GraphQLExecutor) DataLoaderHandler(ctx context.Context, keys []string) []*dataloader.Result[interface{}]
  • func (s *GraphQLExecutor) GetApplicationCache(ctx context.Context) (*models.ApplicationCache, error)
  • func (s *GraphQLExecutor) GetDataLoaders(ctx context.Context) (*models.DataLoaders, error)
  • func (s *GraphQLExecutor) GetExecutorVersion(ctx context.Context) (string, error)
  • func (s *GraphQLExecutor) GetProjectDriver(ctx context.Context) (interfaces.ProjectDBInterface, error)
  • func (s *GraphQLExecutor) GetSharedDBDriver(ctx context.Context) (interfaces.SharedDBInterface, error)
  • func (s *GraphQLExecutor) HandleMediaURL(ctx context.Context, media map[string]interface{}) (interface{}, error)
  • func (s *GraphQLExecutor) HandlePayloadFormatting(ctx context.Context, param *models.CommonSystemParams, local string, ...) (map[string]interface{}, error)
  • func (s *GraphQLExecutor) Init(ctx context.Context, _driver *models.InitParams) error
  • func (s *GraphQLExecutor) NewParam(_param *models.CommonSystemParams) *models.CommonSystemParams
  • func (s *GraphQLExecutor) SetApplicationCache(ctx context.Context, cache *models.ApplicationCache) error
  • func (s *GraphQLExecutor) SetProjectDriverCredential(ctx context.Context, driverCredentials *models.DriverCredentials) error
  • func (s *GraphQLExecutor) SetSharedDBDriver(ctx context.Context, driver interfaces.SharedDBInterface) error
  • func (s *GraphQLExecutor) SolvePublicMutation(ctx context.Context, resolverName string, _id *string, _ids []*string, ...) ([]byte, error)
  • func (s *GraphQLExecutor) SolvePublicQuery(ctx context.Context, model string, args interface{}, ...) ([]byte, error)
  • func (s *GraphQLExecutor) SolvePublicQueryCount(ctx context.Context, model string, args interface{}, ...) ([]byte, error)
  • func (s *GraphQLExecutor) TrackUploadHistory(ctx context.Context, param *models.CommonSystemParams, ...) error

Types

type DataloaderResultTyped

type DataloaderResultTyped[T any] struct {
	Result  []T  `json:"result"`
	Count   int  `json:"count"`
	Cached  bool `json:"cached"`
	HasMore bool `json:"hasMore"`
	Error   bool `json:"error"`
	Code    int  `json:"code"`
}

type GraphQLExecutor

type GraphQLExecutor struct {
	SharedDriver interfaces.SharedDBInterface
	Dataloaders  *models.DataLoaders
	Cache        *models.ApplicationCache
	// contains filtered or unexported fields
}

var GQLServerExecutor GraphQLExecutor

func GetGraphQLExecutor

func GetGraphQLExecutor(cfg *models.Config, systemDB interfaces.ApitoSystemDB) *GraphQLExecutor

func (*GraphQLExecutor) DataLoaderHandler

func (s *GraphQLExecutor) DataLoaderHandler(ctx context.Context, keys []string) []*dataloader.Result[interface{}]

func (*GraphQLExecutor) GetApplicationCache

func (s *GraphQLExecutor) GetApplicationCache(ctx context.Context) (*models.ApplicationCache, error)

func (*GraphQLExecutor) GetDataLoaders

func (s *GraphQLExecutor) GetDataLoaders(ctx context.Context) (*models.DataLoaders, error)

func (*GraphQLExecutor) GetExecutorVersion

func (s *GraphQLExecutor) GetExecutorVersion(ctx context.Context) (string, error)

func (*GraphQLExecutor) GetProjectDriver

func (s *GraphQLExecutor) GetProjectDriver(ctx context.Context) (interfaces.ProjectDBInterface, error)

func (*GraphQLExecutor) GetSharedDBDriver

func (s *GraphQLExecutor) GetSharedDBDriver(ctx context.Context) (interfaces.SharedDBInterface, error)

func (*GraphQLExecutor) HandleMediaURL

func (s *GraphQLExecutor) HandleMediaURL(ctx context.Context, media map[string]interface{}) (interface{}, error)

func (*GraphQLExecutor) HandlePayloadFormatting

func (s *GraphQLExecutor) HandlePayloadFormatting(ctx context.Context, param *models.CommonSystemParams, local string,
	fields []*models.FieldInfo,
	inputPayload map[string]interface{},
	dbPayload map[string]interface{},
	deltaUpdate bool,
) (map[string]interface{}, error)

func (*GraphQLExecutor) Init

func (s *GraphQLExecutor) Init(ctx context.Context, _driver *models.InitParams) error

func (*GraphQLExecutor) NewParam

func (s *GraphQLExecutor) NewParam(_param *models.CommonSystemParams) *models.CommonSystemParams

func (*GraphQLExecutor) SetApplicationCache

func (s *GraphQLExecutor) SetApplicationCache(ctx context.Context, cache *models.ApplicationCache) error

func (*GraphQLExecutor) SetProjectDriverCredential

func (s *GraphQLExecutor) SetProjectDriverCredential(ctx context.Context, driverCredentials *models.DriverCredentials) error

func (*GraphQLExecutor) SetSharedDBDriver

func (s *GraphQLExecutor) SetSharedDBDriver(ctx context.Context, driver interfaces.SharedDBInterface) error

func (*GraphQLExecutor) SolvePublicMutation

func (s *GraphQLExecutor) SolvePublicMutation(ctx context.Context, resolverName string, _id *string, _ids []*string, status *string, local *string, _userInputPayload interface{}, _connect interface{}, _disconnect interface{}, cache *models.ApplicationCache) ([]byte, error)

func (*GraphQLExecutor) SolvePublicQuery

func (s *GraphQLExecutor) SolvePublicQuery(ctx context.Context, model string, args interface{}, selectionSet *ast.SelectionSet, cache *models.ApplicationCache) ([]byte, error)

func (*GraphQLExecutor) SolvePublicQueryCount

func (s *GraphQLExecutor) SolvePublicQueryCount(ctx context.Context, model string, args interface{}, cache *models.ApplicationCache) ([]byte, error)

func (*GraphQLExecutor) TrackUploadHistory

func (s *GraphQLExecutor) TrackUploadHistory(ctx context.Context, param *models.CommonSystemParams, sent *models.FileDetails) error