core

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 18, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplicationStore 

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

ApplicationStore describes in memory store for applications

func NewApplicationStore 

func NewApplicationStore() *ApplicationStore

NewApplicationStore returns an in-memory application store instance

func (*ApplicationStore) Add 

func (as *ApplicationStore) Add(ctx context.Context, a *domain.Application) (*domain.Application, error)

Add adds a new application, based on the Application structure provided as argument

func (*ApplicationStore) Delete 

func (as *ApplicationStore) Delete(ctx context.Context, name string) error

Delete deletes the application registered by FuseML

func (*ApplicationStore) Find 

func (as *ApplicationStore) Find(ctx context.Context, name string) *domain.Application

Find returns a application identified by id

func (*ApplicationStore) GetAll 

func (as *ApplicationStore) GetAll(ctx context.Context, applicationType *string, applicationWorkflow *string) ([]*domain.Application, error)

GetAll returns all applications of a given type. If type is not specified, return all applications.

type ExtensionStore added in v0.2.1 

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

ExtensionStore is an in memory store for extensions.

func NewExtensionStore added in v0.2.1 

func NewExtensionStore() *ExtensionStore

NewExtensionStore returns an in-memory extension store instance.

func (*ExtensionStore) AddExtension added in v0.2.1 

func (store *ExtensionStore) AddExtension(ctx context.Context, extension *domain.Extension) (*domain.Extension, error)

AddExtension adds a new extension to the store.

func (*ExtensionStore) AddExtensionService added in v0.2.1 

func (store *ExtensionStore) AddExtensionService(ctx context.Context, extensionID string, service *domain.ExtensionService) (*domain.ExtensionService, error)

AddExtensionService adds a new extension service to an extension.

func (*ExtensionStore) AddExtensionServiceCredentials added in v0.2.1 

func (store *ExtensionStore) AddExtensionServiceCredentials(ctx context.Context, extensionID string, serviceID string,
	credentials *domain.ExtensionServiceCredentials) (*domain.ExtensionServiceCredentials, error)

AddExtensionServiceCredentials adds a new credential to an extension service.

func (*ExtensionStore) AddExtensionServiceEndpoint added in v0.2.1 

func (store *ExtensionStore) AddExtensionServiceEndpoint(ctx context.Context, extensionID string, serviceID string, endpoint *domain.ExtensionServiceEndpoint) (*domain.ExtensionServiceEndpoint, error)

AddExtensionServiceEndpoint adds a new endpoint to an extension service.

func (*ExtensionStore) DeleteExtension added in v0.2.1 

func (store *ExtensionStore) DeleteExtension(ctx context.Context, extensionID string) error

DeleteExtension deletes an extension from the store.

func (*ExtensionStore) DeleteExtensionService added in v0.2.1 

func (store *ExtensionStore) DeleteExtensionService(ctx context.Context, extensionID, serviceID string) error

DeleteExtensionService deletes an extension service from an extension.

func (*ExtensionStore) DeleteExtensionServiceCredentials added in v0.2.1 

func (store *ExtensionStore) DeleteExtensionServiceCredentials(ctx context.Context, extensionID, serviceID, credentialsID string) error

DeleteExtensionServiceCredentials deletes an extension credential from an extension service.

func (*ExtensionStore) DeleteExtensionServiceEndpoint added in v0.2.1 

func (store *ExtensionStore) DeleteExtensionServiceEndpoint(ctx context.Context, extensionID, serviceID, endpointID string) error

DeleteExtensionServiceEndpoint deletes an extension endpoint from an extension service.

func (*ExtensionStore) GetExtension added in v0.2.1 

func (store *ExtensionStore) GetExtension(ctx context.Context, extensionID string) (*domain.Extension, error)

GetExtension retrieves an extension by its ID.

func (*ExtensionStore) GetExtensionAccessDescriptors added in v0.2.1 

func (store *ExtensionStore) GetExtensionAccessDescriptors(ctx context.Context, query *domain.ExtensionQuery) (result []*domain.ExtensionAccessDescriptor, err error)

GetExtensionAccessDescriptors retrieves access descriptors belonging to an extension that matches the query.

func (*ExtensionStore) GetExtensionService added in v0.2.1 

func (store *ExtensionStore) GetExtensionService(ctx context.Context, extensionID string, serviceID string) (*domain.ExtensionService, error)

GetExtensionService retrieves an extension service by its ID.

func (*ExtensionStore) GetExtensionServiceCredentials added in v0.2.1 

func (store *ExtensionStore) GetExtensionServiceCredentials(ctx context.Context, extensionID string, serviceID string, credentialsID string) (*domain.ExtensionServiceCredentials, error)

GetExtensionServiceCredentials retrieves an extension credential by its ID.

func (*ExtensionStore) GetExtensionServiceEndpoint added in v0.2.1 

func (store *ExtensionStore) GetExtensionServiceEndpoint(ctx context.Context, extensionID string, serviceID string, endpointID string) (*domain.ExtensionServiceEndpoint, error)

GetExtensionServiceEndpoint retrieves an extension endpoint by its ID.

func (*ExtensionStore) ListExtensionServiceCredentials added in v0.2.1 

func (store *ExtensionStore) ListExtensionServiceCredentials(ctx context.Context, extensionID string, serviceID string) ([]*domain.ExtensionServiceCredentials, error)

ListExtensionServiceCredentials retrieves all credentials belonging to an extension service.

func (*ExtensionStore) ListExtensionServiceEndpoints added in v0.2.1 

func (store *ExtensionStore) ListExtensionServiceEndpoints(ctx context.Context, extensionID string, serviceID string) ([]*domain.ExtensionServiceEndpoint, error)

ListExtensionServiceEndpoints retrieves all endpoints belonging to an extension service.

func (*ExtensionStore) ListExtensionServices added in v0.2.1 

func (store *ExtensionStore) ListExtensionServices(ctx context.Context, extensionID string) ([]*domain.ExtensionService, error)

ListExtensionServices retrieves all services belonging to an extension.

func (*ExtensionStore) ListExtensions added in v0.2.1 

func (store *ExtensionStore) ListExtensions(ctx context.Context, query *domain.ExtensionQuery) (result []*domain.Extension)

ListExtensions retrieves all stored extensions.

func (*ExtensionStore) UpdateExtension added in v0.2.1 

func (store *ExtensionStore) UpdateExtension(ctx context.Context, newExtension *domain.Extension) error

UpdateExtension updates an existing extension.

func (*ExtensionStore) UpdateExtensionService added in v0.2.1 

func (store *ExtensionStore) UpdateExtensionService(ctx context.Context, extensionID string, newService *domain.ExtensionService) error

UpdateExtensionService updates a service belonging to an extension.

func (*ExtensionStore) UpdateExtensionServiceCredentials added in v0.2.1 

func (store *ExtensionStore) UpdateExtensionServiceCredentials(ctx context.Context, extensionID string, serviceID string, credentials *domain.ExtensionServiceCredentials) (err error)

UpdateExtensionServiceCredentials updates an extension credential.

func (*ExtensionStore) UpdateExtensionServiceEndpoint added in v0.2.1 

func (store *ExtensionStore) UpdateExtensionServiceEndpoint(ctx context.Context, extensionID string, serviceID string, endpoint *domain.ExtensionServiceEndpoint) error

UpdateExtensionServiceEndpoint updates an endpoint belonging to an extension service.

type GitCodesetStore 

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

GitCodesetStore describes a structure that accesses codeset store implemented in git

func NewGitCodesetStore 

func NewGitCodesetStore(gitAdmin domain.GitAdminClient) *GitCodesetStore

NewGitCodesetStore returns codeset store instance

func (*GitCodesetStore) Add 

func (cs *GitCodesetStore) Add(ctx context.Context, c *domain.Codeset) (*domain.Codeset, *string, *string, error)

Add creates new codeset

func (*GitCodesetStore) CreateWebhook 

func (cs *GitCodesetStore) CreateWebhook(ctx context.Context, c *domain.Codeset, listenerURL string) (*int64, error)

CreateWebhook adds a new webhook to a codeset

func (*GitCodesetStore) Delete 

func (cs *GitCodesetStore) Delete(ctx context.Context, project, name string) error

Delete removes a codeset identified by project and name

func (*GitCodesetStore) DeleteWebhook added in v0.1.0 

func (cs *GitCodesetStore) DeleteWebhook(ctx context.Context, c *domain.Codeset, hookID *int64) error

DeleteWebhook deletes a webhook from a codeset

func (*GitCodesetStore) Find 

func (cs *GitCodesetStore) Find(ctx context.Context, project, name string) (*domain.Codeset, error)

Find returns a codeset identified by project and name

func (*GitCodesetStore) GetAll 

func (cs *GitCodesetStore) GetAll(ctx context.Context, project, label *string) ([]*domain.Codeset, error)

GetAll returns all codesets matching given project and label

func (*GitCodesetStore) Subscribe added in v0.2.1 

func (cs *GitCodesetStore) Subscribe(ctx context.Context, subscriber domain.CodesetSubscriber, codeset *domain.Codeset) error

Subscribe adds a subscriber interested on operations performed on a specific codeset

func (*GitCodesetStore) Unsubscribe added in v0.2.1 

func (cs *GitCodesetStore) Unsubscribe(ctx context.Context, subscriber domain.CodesetSubscriber, codeset *domain.Codeset) error

Unsubscribe deletes a specific codeset subscriber

type GitProjectStore added in v0.2.1 

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

GitProjectStore describes a structure that accesses project store implemented in git

func NewGitProjectStore added in v0.2.1 

func NewGitProjectStore(gitAdmin domain.GitAdminClient) *GitProjectStore

NewGitProjectStore returns project store instance

func (*GitProjectStore) Create added in v0.2.1 

func (cs *GitProjectStore) Create(ctx context.Context, name, desc string) (*domain.Project, error)

Create creates a new project

func (*GitProjectStore) Delete added in v0.2.1 

func (cs *GitProjectStore) Delete(ctx context.Context, project string) error

Delete removes a project identified by project and name

func (*GitProjectStore) Find added in v0.2.1 

func (cs *GitProjectStore) Find(ctx context.Context, project string) (*domain.Project, error)

Find returns a project identified by project and name

func (*GitProjectStore) GetAll added in v0.2.1 

func (cs *GitProjectStore) GetAll(ctx context.Context) ([]*domain.Project, error)

GetAll returns all projects matching given project and label

type RunnableStore 

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

RunnableStore describes in memory store for runnables

func NewRunnableStore 

func NewRunnableStore() *RunnableStore

NewRunnableStore creates and returns an in-memory runnable store instance

func (*RunnableStore) Find 

func (s *RunnableStore) Find(ctx context.Context, id string, kind string, labels map[string]string) (res []*domain.Runnable, err error)

Find returns a list of runnables matching the input query. Runnables may be matched by id, kind or labels. Only runnables that match all the supplied criteria will be returned.

func (*RunnableStore) Get 

func (s *RunnableStore) Get(ctx context.Context, id string) (res *domain.Runnable, err error)

Get returns a runnable identified by id

func (*RunnableStore) Register 

func (s *RunnableStore) Register(ctx context.Context, r *domain.Runnable) (res *domain.Runnable, err error)

Register adds a new runnable, based on the Runnable structure provided as argument

type WorkflowStore 

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

WorkflowStore describes in memory store for workflows

func NewWorkflowStore 

func NewWorkflowStore() *WorkflowStore

NewWorkflowStore returns an in-memory workflow store instance

func (*WorkflowStore) AddCodesetAssignment added in v0.0.2 

func (ws *WorkflowStore) AddCodesetAssignment(ctx context.Context, workflowName string, codeset *domain.Codeset,
	webhookID *int64) ([]*domain.CodesetAssignment, error)

AddCodesetAssignment adds a codeset assignment to the list of assigned codesets of a workflow

func (*WorkflowStore) AddWorkflow added in v0.0.2 

func (ws *WorkflowStore) AddWorkflow(ctx context.Context, w *domain.Workflow) (*domain.Workflow, error)

AddWorkflow adds a new workflow based on the Workflow structure provided as argument

func (*WorkflowStore) DeleteCodesetAssignment added in v0.1.0 

func (ws *WorkflowStore) DeleteCodesetAssignment(ctx context.Context, workflowName string, codeset *domain.Codeset) ([]*domain.CodesetAssignment, error)

DeleteCodesetAssignment deletes a codeset assignment from the list of assigned codesets of a workflow

func (*WorkflowStore) DeleteWorkflow added in v0.1.0 

func (ws *WorkflowStore) DeleteWorkflow(ctx context.Context, name string) error

DeleteWorkflow deletes the workflow from the store

func (*WorkflowStore) GetAllCodesetAssignments added in v0.2.1 

func (ws *WorkflowStore) GetAllCodesetAssignments(ctx context.Context, workflowName *string) (result map[string][]*domain.CodesetAssignment)

GetAllCodesetAssignments returns a map of workflows and its assigned codesets

func (*WorkflowStore) GetCodesetAssignment added in v0.2.1 

func (ws *WorkflowStore) GetCodesetAssignment(ctx context.Context, workflowName string, codeset *domain.Codeset) (*domain.CodesetAssignment, error)

GetCodesetAssignment returns a codeset assignment for a given Workflow and Codeset

func (*WorkflowStore) GetCodesetAssignments added in v0.2.1 

func (ws *WorkflowStore) GetCodesetAssignments(ctx context.Context, workflowName string) []*domain.CodesetAssignment

GetCodesetAssignments returns a list of codesets assigned to the specified workflow

func (*WorkflowStore) GetWorkflow added in v0.0.2 

func (ws *WorkflowStore) GetWorkflow(ctx context.Context, name string) (*domain.Workflow, error)

GetWorkflow returns a workflow identified by its name

func (*WorkflowStore) GetWorkflows added in v0.1.0 

func (ws *WorkflowStore) GetWorkflows(ctx context.Context, name *string) (result []*domain.Workflow)

GetWorkflows returns all workflows or the one that matches a given name.

Source Files

View all Source files

Directories

Path Synopsis
store
badger
builder

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.