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

manager

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 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.