manager

Documentation

Index

• type ExtensionRegistry
  • func NewExtensionRegistry(extensionStore domain.ExtensionStore) *ExtensionRegistry
  • func (registry *ExtensionRegistry) AddCredentials(ctx context.Context, extensionID string, serviceID string, ...) (*domain.ExtensionServiceCredentials, error)
  • func (registry *ExtensionRegistry) AddEndpoint(ctx context.Context, extensionID string, serviceID string, ...) (*domain.ExtensionServiceEndpoint, error)
  • func (registry *ExtensionRegistry) AddService(ctx context.Context, extensionID string, service *domain.ExtensionService) (*domain.ExtensionService, error)
  • func (registry *ExtensionRegistry) GetCredentials(ctx context.Context, extensionID, serviceID, credentialsID string) (*domain.ExtensionServiceCredentials, error)
  • func (registry *ExtensionRegistry) GetEndpoint(ctx context.Context, extensionID, serviceID, endpointURL string) (*domain.ExtensionServiceEndpoint, error)
  • func (registry *ExtensionRegistry) GetExtension(ctx context.Context, extensionID string) (*domain.Extension, error)
  • func (registry *ExtensionRegistry) GetExtensionAccessDescriptors(ctx context.Context, query *domain.ExtensionQuery) (result []*domain.ExtensionAccessDescriptor, err error)
  • func (registry *ExtensionRegistry) GetService(ctx context.Context, extensionID, serviceID string) (*domain.ExtensionService, error)
  • func (registry *ExtensionRegistry) ListExtensions(ctx context.Context, query *domain.ExtensionQuery) (result []*domain.Extension, err error)
  • func (registry *ExtensionRegistry) RegisterExtension(ctx context.Context, extension *domain.Extension) (*domain.Extension, error)
  • func (registry *ExtensionRegistry) RemoveCredentials(ctx context.Context, extensionID, serviceID, credentialsID string) error
  • func (registry *ExtensionRegistry) RemoveEndpoint(ctx context.Context, extensionID, serviceID, endpointID string) error
  • func (registry *ExtensionRegistry) RemoveExtension(ctx context.Context, extensionID string) error
  • func (registry *ExtensionRegistry) RemoveService(ctx context.Context, extensionID, serviceID string) error
  • func (registry *ExtensionRegistry) UpdateCredentials(ctx context.Context, extensionID string, serviceID string, ...) error
  • func (registry *ExtensionRegistry) UpdateEndpoint(ctx context.Context, extensionID string, serviceID string, ...) error
  • func (registry *ExtensionRegistry) UpdateExtension(ctx context.Context, extension *domain.Extension) error
  • func (registry *ExtensionRegistry) UpdateService(ctx context.Context, extensionID string, service *domain.ExtensionService) error
• type WorkflowManager
  • func NewWorkflowManager(workflowBackend domain.WorkflowBackend, workflowStore domain.WorkflowStore, ...) *WorkflowManager
  • func (mgr *WorkflowManager) AssignToCodeset(ctx context.Context, name, codesetProject, codesetName string) (wfListener *domain.WorkflowListener, webhookID *int64, err error)
  • func (mgr *WorkflowManager) CreateWorkflow(ctx context.Context, wf *domain.Workflow) (*domain.Workflow, error)
  • func (mgr *WorkflowManager) DeleteWorkflow(ctx context.Context, name string) error
  • func (mgr *WorkflowManager) GetAllCodesetAssignments(ctx context.Context, name *string) map[string][]*domain.CodesetAssignment
  • func (mgr *WorkflowManager) GetAssignmentStatus(ctx context.Context, name string) *domain.WorkflowAssignmentStatus
  • func (mgr *WorkflowManager) GetWorkflow(ctx context.Context, name string) (*domain.Workflow, error)
  • func (mgr *WorkflowManager) GetWorkflowRuns(ctx context.Context, filter *domain.WorkflowRunFilter) ([]*domain.WorkflowRun, error)
  • func (mgr *WorkflowManager) GetWorkflows(ctx context.Context, name *string) []*domain.Workflow
  • func (mgr *WorkflowManager) OnDeletingCodeset(ctx context.Context, codeset *domain.Codeset)
  • func (mgr *WorkflowManager) UnassignFromCodeset(ctx context.Context, name, codesetProject, codesetName string) (err error)

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