core

package
v0.1.1-alpha.2 Latest Latest
Warning

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

 Go to latest Published: Nov 23, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ExecutionLogPendingTimeout = 30 * time.Second
)
View Source 
const (
	SystemUserUUID = "00000000-0000-0000-0000-000000000000"
)
View Source 
const (
	TimeFormat = "2006-01-02T15:04:05Z"
)

Variables

View Source 
var (
	ErrNoPendingApproval = errors.New("no pending approval")
	ErrNil               = errors.New("not found")
)
View Source 
var (
	ErrFlowNotFound = errors.New("flow not found")
)

Functions

This section is empty.

Types

type Core 

type Core struct {
	LogManager streamlogger.LogManager
	// contains filtered or unexported fields
}

func NewCore 

func NewCore(flowsDirectory string, s repo.Store, sch scheduler.TaskScheduler, keeper *secrets.Keeper, enforcer *casbin.Enforcer) (*Core, error)

func (*Core) ApproveOrRejectAction 

func (c *Core) ApproveOrRejectAction(ctx context.Context, approvalUUID, decidedBy string, status models.ApprovalType, namespaceID string) error

ApproveOrRejectAction handles approval or rejection of an action request by a user. It takes the approval UUID, the ID of the user making the decision, and the approval status. The function updates the database with the decision. Once approved, the task is moved to a resume queue for further processing.

func (*Core) AssignNamespaceRole 

func (c *Core) AssignNamespaceRole(ctx context.Context, subjectID string, subjectType string, namespaceID string, role models.NamespaceRole) error

AssignNamespaceRole assigns a role to a user or group in a namespace

func (*Core) CancelFlowExecution 

func (c *Core) CancelFlowExecution(ctx context.Context, execID string) error

CancelFlowExecution cancels the given execution using the scheduler

func (*Core) CheckPermission 

func (c *Core) CheckPermission(ctx context.Context, userID string, namespaceID string, resource models.Resource, action models.RBACAction) (bool, error)

CheckPermission checks if a user has permission to perform an action on a resource in a namespace

func (*Core) CreateCredential 

func (c *Core) CreateCredential(ctx context.Context, cred models.Credential, namespaceID string) (models.Credential, error)

func (*Core) CreateFlow 

func (c *Core) CreateFlow(ctx context.Context, f models.Flow, namespaceID string) error

func (*Core) CreateFlowSecret 

func (c *Core) CreateFlowSecret(ctx context.Context, flowID string, secret models.FlowSecret, namespaceID string) (models.FlowSecret, error)

func (*Core) CreateGroup 

func (c *Core) CreateGroup(ctx context.Context, name, description string) (models.GroupWithUsers, error)

func (*Core) CreateNamespace 

func (c *Core) CreateNamespace(ctx context.Context, namespace *models.Namespace) (models.Namespace, error)

func (*Core) CreateNode 

func (c *Core) CreateNode(ctx context.Context, node *models.Node, namespaceID string) (models.Node, error)

func (*Core) CreateUser 

func (c *Core) CreateUser(ctx context.Context, name, username string, loginType models.UserLoginType, userRole models.UserRoleType, groups []string) (models.UserWithGroups, error)

func (*Core) DeleteCredential 

func (c *Core) DeleteCredential(ctx context.Context, id string, namespaceID string) error

func (*Core) DeleteFlow 

func (c *Core) DeleteFlow(ctx context.Context, flowID, namespaceID string) error

func (*Core) DeleteFlowSecret 

func (c *Core) DeleteFlowSecret(ctx context.Context, id string, namespaceID string) error

func (*Core) DeleteGroupByUUID 

func (c *Core) DeleteGroupByUUID(ctx context.Context, groupUUID string) error

func (*Core) DeleteNamespace 

func (c *Core) DeleteNamespace(ctx context.Context, id string) error

func (*Core) DeleteNode 

func (c *Core) DeleteNode(ctx context.Context, id string, namespaceID string) error

func (*Core) DeleteUserByUUID 

func (c *Core) DeleteUserByUUID(ctx context.Context, userUUID string) error

func (*Core) GetAllExecutionSummaryPaginated 

func (c *Core) GetAllExecutionSummaryPaginated(ctx context.Context, namespaceID string, filter string, limit, offset int) ([]models.ExecutionSummary, int64, int64, error)

func (*Core) GetAllFlows 

func (c *Core) GetAllFlows(ctx context.Context, namespaceID string) ([]models.Flow, error)

func (*Core) GetAllGroups 

func (c *Core) GetAllGroups(ctx context.Context) ([]models.Group, error)

func (*Core) GetAllGroupsWithUsers 

func (c *Core) GetAllGroupsWithUsers(ctx context.Context) ([]models.GroupWithUsers, error)

func (*Core) GetAllUsersWithGroups 

func (c *Core) GetAllUsersWithGroups(ctx context.Context) ([]models.UserWithGroups, error)

func (*Core) GetApprovalRequest 

func (c *Core) GetApprovalRequest(ctx context.Context, approvalUUID string, namespaceID string) (models.ApprovalRequest, error)

GetApprovalRequest returns an approval request using the approval UUID and namespace UUID

func (*Core) GetApprovalWithInputs 

func (c *Core) GetApprovalWithInputs(ctx context.Context, approvalUUID string, namespaceID string) (models.ApprovalDetails, error)

GetApprovalWithInputs returns an approval request with additional info like flow name and id and inputs for the execution

func (*Core) GetApprovalsPaginated 

func (c *Core) GetApprovalsPaginated(ctx context.Context, namespaceID, status, filter string, page, countPerPage int) ([]models.ApprovalPaginationDetails, int64, int64, error)

func (*Core) GetApprovalsRequestsForExec 

func (c *Core) GetApprovalsRequestsForExec(ctx context.Context, execID string, namespaceID string) (models.ApprovalRequest, error)

GetApprovalsRequestsForExec returns approval requests for a given execution

func (*Core) GetCredentialByID 

func (c *Core) GetCredentialByID(ctx context.Context, id string, namespaceID string) (models.Credential, error)

func (*Core) GetDecryptedFlowSecrets 

func (c *Core) GetDecryptedFlowSecrets(ctx context.Context, flowID string, namespaceID string) (map[string]string, error)

func (*Core) GetExecutionByExecID 

func (c *Core) GetExecutionByExecID(ctx context.Context, execID string, namespaceID string) (models.Execution, error)

func (*Core) GetExecutionSummaryByExecID 

func (c *Core) GetExecutionSummaryByExecID(ctx context.Context, execID string, namespaceID string) (models.ExecutionSummary, error)

func (*Core) GetExecutionSummaryPaginated 

func (c *Core) GetExecutionSummaryPaginated(ctx context.Context, f models.Flow, namespaceID string, limit, offset int) ([]models.ExecutionSummary, int64, int64, error)

func (*Core) GetFlowByID 

func (c *Core) GetFlowByID(id string, namespaceID string) (models.Flow, error)

func (*Core) GetFlowFromLogID 

func (c *Core) GetFlowFromLogID(logID string, namespaceID string) (models.Flow, error)

func (*Core) GetFlowSecretByID 

func (c *Core) GetFlowSecretByID(ctx context.Context, id string, namespaceID string) (models.FlowSecret, error)

func (*Core) GetFlowsPaginated 

func (c *Core) GetFlowsPaginated(ctx context.Context, namespaceID string, limit, offset int) ([]models.Flow, int64, int64, error)

func (*Core) GetGroupByName 

func (c *Core) GetGroupByName(ctx context.Context, name string) (models.Group, error)

func (*Core) GetGroupByUUID 

func (c *Core) GetGroupByUUID(ctx context.Context, groupUUID string) (models.Group, error)

func (*Core) GetGroupWithUsers 

func (c *Core) GetGroupWithUsers(ctx context.Context, groupUUID string) (models.GroupWithUsers, error)

func (*Core) GetInputForExec 

func (c *Core) GetInputForExec(ctx context.Context, execID string, namespaceID string) (map[string]interface{}, error)

func (*Core) GetNamespaceByID 

func (c *Core) GetNamespaceByID(ctx context.Context, id string) (models.Namespace, error)

func (*Core) GetNamespaceByName 

func (c *Core) GetNamespaceByName(ctx context.Context, name string) (models.Namespace, error)

func (*Core) GetNamespaceMembers 

func (c *Core) GetNamespaceMembers(ctx context.Context, namespaceID string) ([]models.NamespaceMember, error)

GetNamespaceMembers returns all members of a namespace

func (*Core) GetNodeByID 

func (c *Core) GetNodeByID(ctx context.Context, id string, namespaceID string) (models.Node, error)

func (*Core) GetNodeStats 

func (c *Core) GetNodeStats(ctx context.Context, namespaceID string) (models.NodeStats, error)

func (*Core) GetNodesByNames 

func (c *Core) GetNodesByNames(ctx context.Context, nodeNames []string, namespaceUUID uuid.UUID) ([]models.Node, error)

GetNodesByNames retrieves nodes by their names and returns a slice of models.Node This is used as a lookup function for converting flows to task models

func (*Core) GetPermissionsForUser 

func (c *Core) GetPermissionsForUser(userID string) (string, error)

GetPermissions returns the casbin policies for the user

func (*Core) GetScheduledFlows 

func (c *Core) GetScheduledFlows() []models.Flow

GetScheduledFlows returns all flows that have a cron schedule configured

func (*Core) GetSchedulerFlow 

func (c *Core) GetSchedulerFlow(ctx context.Context, flowSlug string, namespaceUUID string) (scheduler.Flow, error)

GetSchedulerFlow loads a flow and converts it to scheduler.Flow format This function can be used as a FlowLoaderFn for the scheduler

func (*Core) GetUserByUUID 

func (c *Core) GetUserByUUID(ctx context.Context, userUUID string) (models.User, error)

func (*Core) GetUserByUsername 

func (c *Core) GetUserByUsername(ctx context.Context, username string) (models.User, error)

func (*Core) GetUserByUsernameWithGroups 

func (c *Core) GetUserByUsernameWithGroups(ctx context.Context, username string) (models.UserWithGroups, error)

func (*Core) GetUserNamespaces 

func (c *Core) GetUserNamespaces(ctx context.Context, userID string) ([]models.NamespaceWithRole, error)

GetUserNamespaces returns all namespaces a user has access to with their roles

func (*Core) GetUserWithUUIDWithGroups 

func (c *Core) GetUserWithUUIDWithGroups(ctx context.Context, userUUID string) (models.UserWithGroups, error)

func (*Core) GrantSuperusersAdminAccessToAllNamespaces 

func (c *Core) GrantSuperusersAdminAccessToAllNamespaces(ctx context.Context) error

GrantSuperusersAdminAccessToAllNamespaces queries for all users with superuser role and adds a grouping policy to them to have admin access to all namespaces

func (*Core) InitializeRBACPolicies 

func (c *Core) InitializeRBACPolicies() error

InitializeRBACPolicies sets up the base policies for each role These policies apply to all namespaces using wildcard "*"

func (*Core) ListFlowSecrets 

func (c *Core) ListFlowSecrets(ctx context.Context, flowID string, namespaceID string) ([]models.FlowSecret, error)

func (*Core) ListNamespaces 

func (c *Core) ListNamespaces(ctx context.Context, userID string, name string, limit, offset int) ([]models.Namespace, int64, int64, error)

func (*Core) LoadFlows 

func (c *Core) LoadFlows() error

func (*Core) QueueFlowExecution 

func (c *Core) QueueFlowExecution(ctx context.Context, f models.Flow, input map[string]interface{}, userUUID string, namespaceID string) (string, error)

QueueFlowExecution adds a flow in the execution queue. The ID returned is the execution queue ID. Exec ID should be universally unique, this is used to create the log stream and identify each execution

func (*Core) RemoveNamespaceMember 

func (c *Core) RemoveNamespaceMember(ctx context.Context, membershipID, namespaceID string) error

RemoveNamespaceMember removes a user or group from a namespace

func (*Core) RequestApproval 

func (c *Core) RequestApproval(ctx context.Context, execID string, action models.Action, namespaceID string) (string, error)

func (*Core) ResumeFlowExecution 

func (c *Core) ResumeFlowExecution(ctx context.Context, execID string, actionID string, userUUID string, namespaceID string) error

ResumeFlowExecution moves the task to a resume queue for further processing.

func (*Core) SearchCredentials 

func (c *Core) SearchCredentials(ctx context.Context, filter string, limit, offset int, namespaceID string) ([]models.Credential, int64, int64, error)

func (*Core) SearchFlows 

func (c *Core) SearchFlows(ctx context.Context, namespaceID string, query string, limit, offset int) ([]models.Flow, int64, int64, error)

func (*Core) SearchGroup 

func (c *Core) SearchGroup(ctx context.Context, query string, limit, offset int) ([]models.GroupWithUsers, int64, int64, error)

func (*Core) SearchNodes 

func (c *Core) SearchNodes(ctx context.Context, filter string, limit, offset int, namespaceID string) ([]models.Node, int64, int64, error)

func (*Core) SearchUser 

func (c *Core) SearchUser(ctx context.Context, query string, limit, offset int) ([]models.UserWithGroups, int64, int64, error)

func (*Core) StreamLogs 

func (c *Core) StreamLogs(ctx context.Context, logID string, namespaceID string) (chan models.StreamMessage, error)

StreamLogs reads values from a stream from the beginning and returns a channel to which all the messages are sent. logID is the ID sent to the NewFlowExecution task

func (*Core) SynchronizePolicies 

func (c *Core) SynchronizePolicies(ctx context.Context) error

SynchronizePolicies synchronizes Casbin policies from the namespace_members table This ensures that the RBAC policies in Casbin match the role assignments stored in the database

func (*Core) UpdateCredential 

func (c *Core) UpdateCredential(ctx context.Context, id string, cred *models.Credential, namespaceID string) (models.Credential, error)

func (*Core) UpdateFlow 

func (c *Core) UpdateFlow(ctx context.Context, f models.Flow, namespaceID string) error

func (*Core) UpdateFlowSecret 

func (c *Core) UpdateFlowSecret(ctx context.Context, id string, secret models.FlowSecret, namespaceID string) (models.FlowSecret, error)

func (*Core) UpdateGroup 

func (c *Core) UpdateGroup(ctx context.Context, groupUUID, name, description string) (models.GroupWithUsers, error)

func (*Core) UpdateNamespace 

func (c *Core) UpdateNamespace(ctx context.Context, id string, namespace models.Namespace) (models.Namespace, error)

func (*Core) UpdateNamespaceMember 

func (c *Core) UpdateNamespaceMember(ctx context.Context, membershipID, namespaceID string, role models.NamespaceRole) error

UpdateNamespaceMember updates the role of a user or group in a namespace

func (*Core) UpdateNode 

func (c *Core) UpdateNode(ctx context.Context, id string, node *models.Node, namespaceID string) (models.Node, error)

func (*Core) UpdateUser 

func (c *Core) UpdateUser(ctx context.Context, userUUID string, name string, username string, groups []string) (models.UserWithGroups, error)

Source Files

View all Source files

Directories

Path Synopsis

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.