manager

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: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExtensionRegistry 

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

ExtensionRegistry implements the domain.ExtensionRegistry interface

func NewExtensionRegistry 

func NewExtensionRegistry(extensionStore domain.ExtensionStore) *ExtensionRegistry

NewExtensionRegistry initializes an extension registry

func (*ExtensionRegistry) AddCredentials 

func (registry *ExtensionRegistry) AddCredentials(ctx context.Context, extensionID string, serviceID string,
	credentials *domain.ExtensionServiceCredentials) (*domain.ExtensionServiceCredentials, error)

AddCredentials - add a set of credentials to an existing extension service

func (*ExtensionRegistry) AddEndpoint 

func (registry *ExtensionRegistry) AddEndpoint(ctx context.Context, extensionID string, serviceID string,
	endpoint *domain.ExtensionServiceEndpoint) (*domain.ExtensionServiceEndpoint, error)

AddEndpoint - add an endpoint to an existing extension service

func (*ExtensionRegistry) AddService 

func (registry *ExtensionRegistry) AddService(ctx context.Context, extensionID string, service *domain.ExtensionService) (*domain.ExtensionService, error)

AddService - add a service to an existing extension

func (*ExtensionRegistry) GetCredentials 

func (registry *ExtensionRegistry) GetCredentials(ctx context.Context, extensionID, serviceID, credentialsID string) (*domain.ExtensionServiceCredentials, error)

GetCredentials - retrieve a set of extension credentials by ID

func (*ExtensionRegistry) GetEndpoint 

func (registry *ExtensionRegistry) GetEndpoint(ctx context.Context, extensionID, serviceID, endpointURL string) (*domain.ExtensionServiceEndpoint, error)

GetEndpoint - retrieve an extension endpoint by ID

func (*ExtensionRegistry) GetExtension 

func (registry *ExtensionRegistry) GetExtension(ctx context.Context, extensionID string) (*domain.Extension, error)

GetExtension - retrieve an extension by ID and, optionally, its entire service/endpoint/credentials subtree

func (*ExtensionRegistry) GetExtensionAccessDescriptors 

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

GetExtensionAccessDescriptors - returns access descriptors for extensions that matches the query

func (*ExtensionRegistry) GetService 

func (registry *ExtensionRegistry) GetService(ctx context.Context, extensionID, serviceID string) (*domain.ExtensionService, error)

GetService - retrieve an extension service by ID and, optionally, its entire endpoint/credentials subtree

func (*ExtensionRegistry) ListExtensions 

func (registry *ExtensionRegistry) ListExtensions(ctx context.Context, query *domain.ExtensionQuery) (result []*domain.Extension, err error)

ListExtensions - list all registered extensions that match the supplied query parameters

func (*ExtensionRegistry) RegisterExtension 

func (registry *ExtensionRegistry) RegisterExtension(ctx context.Context, extension *domain.Extension) (*domain.Extension, error)

RegisterExtension - register a new extension, with all participating services, endpoints and credentials

func (*ExtensionRegistry) RemoveCredentials 

func (registry *ExtensionRegistry) RemoveCredentials(ctx context.Context, extensionID, serviceID, credentialsID string) error

RemoveCredentials - remove a set of extension credentials from the registry

func (*ExtensionRegistry) RemoveEndpoint 

func (registry *ExtensionRegistry) RemoveEndpoint(ctx context.Context, extensionID, serviceID, endpointID string) error

RemoveEndpoint - remove an extension endpoint from the registry

func (*ExtensionRegistry) RemoveExtension 

func (registry *ExtensionRegistry) RemoveExtension(ctx context.Context, extensionID string) error

RemoveExtension - remove an extension from the registry

func (*ExtensionRegistry) RemoveService 

func (registry *ExtensionRegistry) RemoveService(ctx context.Context, extensionID, serviceID string) error

RemoveService - remove an extension service from the registry

func (*ExtensionRegistry) UpdateCredentials 

func (registry *ExtensionRegistry) UpdateCredentials(ctx context.Context, extensionID string, serviceID string, credentials *domain.ExtensionServiceCredentials) error

UpdateCredentials - update a set of credentials belonging to a service

func (*ExtensionRegistry) UpdateEndpoint 

func (registry *ExtensionRegistry) UpdateEndpoint(ctx context.Context, extensionID string, serviceID string, endpoint *domain.ExtensionServiceEndpoint) error

UpdateEndpoint - update an endpoint belonging to a service

func (*ExtensionRegistry) UpdateExtension 

func (registry *ExtensionRegistry) UpdateExtension(ctx context.Context, extension *domain.Extension) error

UpdateExtension - update an extension

func (*ExtensionRegistry) UpdateService 

func (registry *ExtensionRegistry) UpdateService(ctx context.Context, extensionID string, service *domain.ExtensionService) error

UpdateService - update a service belonging to an extension

type WorkflowManager 

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

WorkflowManager implements the domain.WorkflowManager interface

func NewWorkflowManager 

func NewWorkflowManager(
	workflowBackend domain.WorkflowBackend,
	workflowStore domain.WorkflowStore,
	codesetStore domain.CodesetStore,
	extensionRegistry domain.ExtensionRegistry) *WorkflowManager

NewWorkflowManager initializes a Workflow Manager FIXME: instead of CodesetStore, receive a CodesetManager

func (*WorkflowManager) AssignToCodeset 

func (mgr *WorkflowManager) AssignToCodeset(ctx context.Context, name, codesetProject, codesetName string) (wfListener *domain.WorkflowListener, webhookID *int64, err error)

AssignToCodeset assigns a Workflow to a Codeset.

func (*WorkflowManager) CreateWorkflow 

func (mgr *WorkflowManager) CreateWorkflow(ctx context.Context, wf *domain.Workflow) (*domain.Workflow, error)

CreateWorkflow creates a new Workflow.

func (*WorkflowManager) DeleteWorkflow 

func (mgr *WorkflowManager) DeleteWorkflow(ctx context.Context, name string) error

DeleteWorkflow deletes a Workflow and its assignments.

func (*WorkflowManager) GetAllCodesetAssignments 

func (mgr *WorkflowManager) GetAllCodesetAssignments(ctx context.Context, name *string) map[string][]*domain.CodesetAssignment

GetAllCodesetAssignments lists Workflow assignments.

func (*WorkflowManager) GetAssignmentStatus 

func (mgr *WorkflowManager) GetAssignmentStatus(ctx context.Context, name string) *domain.WorkflowAssignmentStatus

GetAssignmentStatus returns the status of a Workflow assignment.

func (*WorkflowManager) GetWorkflow 

func (mgr *WorkflowManager) GetWorkflow(ctx context.Context, name string) (*domain.Workflow, error)

GetWorkflow retrieves a Workflow.

func (*WorkflowManager) GetWorkflowRuns 

func (mgr *WorkflowManager) GetWorkflowRuns(ctx context.Context, filter *domain.WorkflowRunFilter) ([]*domain.WorkflowRun, error)

GetWorkflowRuns returns a lists Workflow runs.

func (*WorkflowManager) GetWorkflows 

func (mgr *WorkflowManager) GetWorkflows(ctx context.Context, name *string) []*domain.Workflow

GetWorkflows returns a list of Workflows.

func (*WorkflowManager) OnDeletingCodeset 

func (mgr *WorkflowManager) OnDeletingCodeset(ctx context.Context, codeset *domain.Codeset)

OnDeletingCodeset perform operations on workflows when a codeset is deleted

func (*WorkflowManager) UnassignFromCodeset 

func (mgr *WorkflowManager) UnassignFromCodeset(ctx context.Context, name, codesetProject, codesetName string) (err error)

UnassignFromCodeset unassign a Workflow from a Codeset

Source Files

View all Source files

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.