Help us shape the future of Go! Take the 2026 Go Developer Survey

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.