repo

package
v0.11.1 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessCredentialParams 

type AccessCredentialParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type AddApprovalRequestParams 

type AddApprovalRequestParams struct {
	ExecLogID int32     `db:"exec_log_id" json:"exec_log_id"`
	ActionID  string    `db:"action_id" json:"action_id"`
	Uuid      uuid.UUID `db:"uuid" json:"uuid"`
}

type AddApprovalRequestRow 

type AddApprovalRequestRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
}

type AddExecutionLogParams 

type AddExecutionLogParams struct {
	ExecID      string          `db:"exec_id" json:"exec_id"`
	FlowID      int32           `db:"flow_id" json:"flow_id"`
	Input       json.RawMessage `db:"input" json:"input"`
	Uuid        uuid.UUID       `db:"uuid" json:"uuid"`
	Uuid_2      uuid.UUID       `db:"uuid_2" json:"uuid_2"`
	TriggerType TriggerType     `db:"trigger_type" json:"trigger_type"`
	ScheduledAt sql.NullTime    `db:"scheduled_at" json:"scheduled_at"`
}

type AddGroupToUserByUUIDParams 

type AddGroupToUserByUUIDParams struct {
	UserUuid  uuid.UUID `db:"user_uuid" json:"user_uuid"`
	GroupUuid uuid.UUID `db:"group_uuid" json:"group_uuid"`
}

type Approval 

type Approval struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
}

type ApprovalDecisionResult 

type ApprovalDecisionResult struct {
	Uuid        uuid.UUID
	Status      ApprovalStatus
	ActionID    string
	RequestedBy string
	ExecLogID   int32
	ExecID      string
}

type ApprovalDecisionTxParams 

type ApprovalDecisionTxParams struct {
	ApprovalUUID     uuid.UUID
	NamespaceUUID    uuid.UUID
	DecidedByUserID  int32
	Status           ApprovalStatus
	CancellationNote string
}

type ApprovalStatus 

type ApprovalStatus string
const (
	ApprovalStatusPending  ApprovalStatus = "pending"
	ApprovalStatusApproved ApprovalStatus = "approved"
	ApprovalStatusRejected ApprovalStatus = "rejected"
)

func (*ApprovalStatus) Scan 

func (e *ApprovalStatus) Scan(src interface{}) error

type ApproveRequestByUUIDParams 

type ApproveRequestByUUIDParams struct {
	Uuid      uuid.UUID     `db:"uuid" json:"uuid"`
	DecidedBy sql.NullInt32 `db:"decided_by" json:"decided_by"`
	Uuid_2    uuid.UUID     `db:"uuid_2" json:"uuid_2"`
}

type ApproveRequestByUUIDRow 

type ApproveRequestByUUIDRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
}

type AssignGroupNamespaceRoleParams 

type AssignGroupNamespaceRoleParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Role   string    `db:"role" json:"role"`
}

type AssignGroupPrefixAccessParams added in v0.8.0 

type AssignGroupPrefixAccessParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Name   string    `db:"name" json:"name"`
}

type AssignUserNamespaceRoleParams 

type AssignUserNamespaceRoleParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Role   string    `db:"role" json:"role"`
}

type AssignUserPrefixAccessParams added in v0.8.0 

type AssignUserPrefixAccessParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Name   string    `db:"name" json:"name"`
}

type AuthenticationMethod 

type AuthenticationMethod string
const (
	AuthenticationMethodPrivateKey AuthenticationMethod = "private_key"
	AuthenticationMethodPassword   AuthenticationMethod = "password"
)

func (*AuthenticationMethod) Scan 

func (e *AuthenticationMethod) Scan(src interface{}) error

type CasbinRule 

type CasbinRule struct {
	ID    int32          `db:"id" json:"id"`
	Ptype sql.NullString `db:"ptype" json:"ptype"`
	V0    sql.NullString `db:"v0" json:"v0"`
	V1    sql.NullString `db:"v1" json:"v1"`
	V2    sql.NullString `db:"v2" json:"v2"`
	V3    sql.NullString `db:"v3" json:"v3"`
	V4    sql.NullString `db:"v4" json:"v4"`
	V5    sql.NullString `db:"v5" json:"v5"`
}

type ConnectionType 

type ConnectionType string
const (
	ConnectionTypeSsh  ConnectionType = "ssh"
	ConnectionTypeQssh ConnectionType = "qssh"
)

func (*ConnectionType) Scan 

func (e *ConnectionType) Scan(src interface{}) error

type CreateCredentialParams 

type CreateCredentialParams struct {
	Name    string    `db:"name" json:"name"`
	KeyType string    `db:"key_type" json:"key_type"`
	KeyData string    `db:"key_data" json:"key_data"`
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
}

type CreateCronScheduleParams 

type CreateCronScheduleParams struct {
	FlowID   int32  `db:"flow_id" json:"flow_id"`
	Cron     string `db:"cron" json:"cron"`
	Timezone string `db:"timezone" json:"timezone"`
}

type CreateFlowParams 

type CreateFlowParams struct {
	Slug        string         `db:"slug" json:"slug"`
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
	Checksum    string         `db:"checksum" json:"checksum"`
	FilePath    string         `db:"file_path" json:"file_path"`
	Name_2      string         `db:"name_2" json:"name_2"`
	PrefixID    sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
}

type CreateFlowPrefixParams added in v0.8.0 

type CreateFlowPrefixParams struct {
	Uuid        uuid.UUID `db:"uuid" json:"uuid"`
	Name        string    `db:"name" json:"name"`
	Description string    `db:"description" json:"description"`
}

type CreateFlowSecretParams 

type CreateFlowSecretParams struct {
	FlowID         int32          `db:"flow_id" json:"flow_id"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
}

type CreateFlowTxParams 

type CreateFlowTxParams struct {
	Slug        string
	Name        string
	Description string
	Checksum    string
	FilePath    string
	Namespace   string
	PrefixID    sql.NullInt32
	Schedules   []struct {
		Cron     string
		Timezone string
	}
}

type CreateGroupParams 

type CreateGroupParams struct {
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
}

type CreateNamespaceSecretParams 

type CreateNamespaceSecretParams struct {
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
}

type CreateNodeParams 

type CreateNodeParams struct {
	Name           string               `db:"name" json:"name"`
	Hostname       string               `db:"hostname" json:"hostname"`
	Port           int32                `db:"port" json:"port"`
	Username       string               `db:"username" json:"username"`
	OsFamily       string               `db:"os_family" json:"os_family"`
	Tags           []string             `db:"tags" json:"tags"`
	AuthMethod     AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID   sql.NullInt32        `db:"credential_id" json:"credential_id"`
	Uuid           uuid.UUID            `db:"uuid" json:"uuid"`
}

type CreateSchedulerTaskParams 

type CreateSchedulerTaskParams struct {
	Uuid    uuid.UUID       `db:"uuid" json:"uuid"`
	ExecID  string          `db:"exec_id" json:"exec_id"`
	Payload json.RawMessage `db:"payload" json:"payload"`
	Status  string          `db:"status" json:"status"`
}

type CreateUserParams 

type CreateUserParams struct {
	Username  string         `db:"username" json:"username"`
	Password  sql.NullString `db:"password" json:"password"`
	LoginType UserLoginType  `db:"login_type" json:"login_type"`
	Role      UserRoleType   `db:"role" json:"role"`
	Name      string         `db:"name" json:"name"`
}

type CreateUserScheduleParams added in v0.5.0 

type CreateUserScheduleParams struct {
	FlowID   int32                 `db:"flow_id" json:"flow_id"`
	Cron     string                `db:"cron" json:"cron"`
	Timezone string                `db:"timezone" json:"timezone"`
	Inputs   pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	Uuid     uuid.UUID             `db:"uuid" json:"uuid"`
}

type CreateUserTxParams 

type CreateUserTxParams struct {
	Name      string
	Username  string
	LoginType UserLoginType
	Role      UserRoleType
	Groups    []string
}

type Credential 

type Credential struct {
	ID           int32        `db:"id" json:"id"`
	Uuid         uuid.UUID    `db:"uuid" json:"uuid"`
	Name         string       `db:"name" json:"name"`
	KeyType      string       `db:"key_type" json:"key_type"`
	KeyData      string       `db:"key_data" json:"key_data"`
	NamespaceID  int32        `db:"namespace_id" json:"namespace_id"`
	LastAccessed sql.NullTime `db:"last_accessed" json:"last_accessed"`
	CreatedAt    time.Time    `db:"created_at" json:"created_at"`
	UpdatedAt    time.Time    `db:"updated_at" json:"updated_at"`
}

type CronSchedule 

type CronSchedule struct {
	ID            int32                 `db:"id" json:"id"`
	FlowID        int32                 `db:"flow_id" json:"flow_id"`
	Cron          string                `db:"cron" json:"cron"`
	Timezone      string                `db:"timezone" json:"timezone"`
	CreatedAt     time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time             `db:"updated_at" json:"updated_at"`
	Uuid          uuid.UUID             `db:"uuid" json:"uuid"`
	Inputs        pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	CreatedBy     int32                 `db:"created_by" json:"created_by"`
	IsUserCreated bool                  `db:"is_user_created" json:"is_user_created"`
	IsActive      bool                  `db:"is_active" json:"is_active"`
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteCredentialParams 

type DeleteCredentialParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type DeleteFlowParams 

type DeleteFlowParams struct {
	Slug string    `db:"slug" json:"slug"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type DeleteFlowPrefixParams added in v0.8.0 

type DeleteFlowPrefixParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type DeleteFlowSecretParams 

type DeleteFlowSecretParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type DeleteNamespaceSecretParams 

type DeleteNamespaceSecretParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type DeleteNodeParams 

type DeleteNodeParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type DeleteUserScheduleByUUIDParams added in v0.5.0 

type DeleteUserScheduleByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Uuid_3 uuid.UUID `db:"uuid_3" json:"uuid_3"`
}

type ExecutionExistsForFlowParams 

type ExecutionExistsForFlowParams struct {
	Slug string    `db:"slug" json:"slug"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type ExecutionLog 

type ExecutionLog struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
}

type ExecutionStatus 

type ExecutionStatus string
const (
	ExecutionStatusCancelled       ExecutionStatus = "cancelled"
	ExecutionStatusCompleted       ExecutionStatus = "completed"
	ExecutionStatusErrored         ExecutionStatus = "errored"
	ExecutionStatusPending         ExecutionStatus = "pending"
	ExecutionStatusPendingApproval ExecutionStatus = "pending_approval"
	ExecutionStatusRunning         ExecutionStatus = "running"
)

func (*ExecutionStatus) Scan 

func (e *ExecutionStatus) Scan(src interface{}) error

type Flow 

type Flow struct {
	ID          int32          `db:"id" json:"id"`
	Slug        string         `db:"slug" json:"slug"`
	Name        string         `db:"name" json:"name"`
	Checksum    string         `db:"checksum" json:"checksum"`
	Description sql.NullString `db:"description" json:"description"`
	FilePath    string         `db:"file_path" json:"file_path"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	IsActive    bool           `db:"is_active" json:"is_active"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID    sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
}

type FlowPrefix added in v0.8.0 

type FlowPrefix struct {
	ID          int32     `db:"id" json:"id"`
	Uuid        uuid.UUID `db:"uuid" json:"uuid"`
	NamespaceID int32     `db:"namespace_id" json:"namespace_id"`
	Name        string    `db:"name" json:"name"`
	Description string    `db:"description" json:"description"`
	CreatedAt   time.Time `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time `db:"updated_at" json:"updated_at"`
}

type FlowSecret 

type FlowSecret struct {
	ID             int32          `db:"id" json:"id"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	FlowID         int32          `db:"flow_id" json:"flow_id"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	NamespaceID    int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at" json:"updated_at"`
}

type GetAllCronSchedulesRow 

type GetAllCronSchedulesRow struct {
	ID            int32                 `db:"id" json:"id"`
	FlowID        int32                 `db:"flow_id" json:"flow_id"`
	Cron          string                `db:"cron" json:"cron"`
	Timezone      string                `db:"timezone" json:"timezone"`
	CreatedAt     time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time             `db:"updated_at" json:"updated_at"`
	Uuid          uuid.UUID             `db:"uuid" json:"uuid"`
	Inputs        pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	CreatedBy     int32                 `db:"created_by" json:"created_by"`
	IsUserCreated bool                  `db:"is_user_created" json:"is_user_created"`
	IsActive      bool                  `db:"is_active" json:"is_active"`
	FlowSlug      string                `db:"flow_slug" json:"flow_slug"`
	FlowName      string                `db:"flow_name" json:"flow_name"`
	NamespaceUuid uuid.UUID             `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetAllExecutionsPaginatedParams 

type GetAllExecutionsPaginatedParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Limit  int32     `db:"limit" json:"limit"`
	Offset int32     `db:"offset" json:"offset"`
}

type GetAllExecutionsPaginatedRow 

type GetAllExecutionsPaginatedRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
	PageCount       int64                 `db:"page_count" json:"page_count"`
	TotalCount      int64                 `db:"total_count" json:"total_count"`
}

type GetAllNamespaceMembersRow 

type GetAllNamespaceMembersRow struct {
	Uuid          uuid.UUID `db:"uuid" json:"uuid"`
	SubjectUuid   uuid.UUID `db:"subject_uuid" json:"subject_uuid"`
	SubjectType   string    `db:"subject_type" json:"subject_type"`
	Role          string    `db:"role" json:"role"`
	NamespaceID   int32     `db:"namespace_id" json:"namespace_id"`
	NamespaceUuid uuid.UUID `db:"namespace_uuid" json:"namespace_uuid"`
	NamespaceName string    `db:"namespace_name" json:"namespace_name"`
	CreatedAt     time.Time `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time `db:"updated_at" json:"updated_at"`
}

type GetAllPrefixAccessesRow added in v0.8.0 

type GetAllPrefixAccessesRow struct {
	Uuid          uuid.UUID `db:"uuid" json:"uuid"`
	SubjectUuid   uuid.UUID `db:"subject_uuid" json:"subject_uuid"`
	SubjectType   string    `db:"subject_type" json:"subject_type"`
	NamespaceUuid uuid.UUID `db:"namespace_uuid" json:"namespace_uuid"`
	Prefix        string    `db:"prefix" json:"prefix"`
	CreatedAt     time.Time `db:"created_at" json:"created_at"`
}

type GetApprovalByUUIDParams 

type GetApprovalByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetApprovalByUUIDRow 

type GetApprovalByUUIDRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	ExecID      string         `db:"exec_id" json:"exec_id"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
}

type GetApprovalRequestForActionAndExecParams 

type GetApprovalRequestForActionAndExecParams struct {
	ExecID   string    `db:"exec_id" json:"exec_id"`
	ActionID string    `db:"action_id" json:"action_id"`
	Uuid     uuid.UUID `db:"uuid" json:"uuid"`
}

type GetApprovalRequestForExecParams 

type GetApprovalRequestForExecParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetApprovalRequestForExecRow 

type GetApprovalRequestForExecRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	ExecID      string         `db:"exec_id" json:"exec_id"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
}

type GetApprovalWithInputsByUUIDParams 

type GetApprovalWithInputsByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetApprovalWithInputsByUUIDRow 

type GetApprovalWithInputsByUUIDRow struct {
	ID            int32           `db:"id" json:"id"`
	Uuid          uuid.UUID       `db:"uuid" json:"uuid"`
	ExecLogID     int32           `db:"exec_log_id" json:"exec_log_id"`
	ActionID      string          `db:"action_id" json:"action_id"`
	Status        ApprovalStatus  `db:"status" json:"status"`
	DecidedBy     sql.NullInt32   `db:"decided_by" json:"decided_by"`
	NamespaceID   int32           `db:"namespace_id" json:"namespace_id"`
	CreatedAt     time.Time       `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time       `db:"updated_at" json:"updated_at"`
	ExecID        string          `db:"exec_id" json:"exec_id"`
	ExecInputs    json.RawMessage `db:"exec_inputs" json:"exec_inputs"`
	FlowName      string          `db:"flow_name" json:"flow_name"`
	FlowSlug      string          `db:"flow_slug" json:"flow_slug"`
	RequestedBy   string          `db:"requested_by" json:"requested_by"`
	DecidedByName sql.NullString  `db:"decided_by_name" json:"decided_by_name"`
}

type GetApprovalsPaginatedParams 

type GetApprovalsPaginatedParams struct {
	Uuid    uuid.UUID   `db:"uuid" json:"uuid"`
	Column2 string      `db:"column_2" json:"column_2"`
	Column3 interface{} `db:"column_3" json:"column_3"`
	Limit   int32       `db:"limit" json:"limit"`
	Offset  int32       `db:"offset" json:"offset"`
}

type GetApprovalsPaginatedRow 

type GetApprovalsPaginatedRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	ExecID      string         `db:"exec_id" json:"exec_id"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
	FlowName    string         `db:"flow_name" json:"flow_name"`
	PageCount   int64          `db:"page_count" json:"page_count"`
	TotalCount  int64          `db:"total_count" json:"total_count"`
}

type GetCredentialByIDParams 

type GetCredentialByIDParams struct {
	ID   int32     `db:"id" json:"id"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type GetCredentialByIDRow 

type GetCredentialByIDRow struct {
	ID            int32        `db:"id" json:"id"`
	Uuid          uuid.UUID    `db:"uuid" json:"uuid"`
	Name          string       `db:"name" json:"name"`
	KeyType       string       `db:"key_type" json:"key_type"`
	KeyData       string       `db:"key_data" json:"key_data"`
	NamespaceID   int32        `db:"namespace_id" json:"namespace_id"`
	LastAccessed  sql.NullTime `db:"last_accessed" json:"last_accessed"`
	CreatedAt     time.Time    `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time    `db:"updated_at" json:"updated_at"`
	NamespaceUuid uuid.UUID    `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetCredentialByUUIDParams 

type GetCredentialByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetCredentialByUUIDRow 

type GetCredentialByUUIDRow struct {
	ID            int32        `db:"id" json:"id"`
	Uuid          uuid.UUID    `db:"uuid" json:"uuid"`
	Name          string       `db:"name" json:"name"`
	KeyType       string       `db:"key_type" json:"key_type"`
	KeyData       string       `db:"key_data" json:"key_data"`
	NamespaceID   int32        `db:"namespace_id" json:"namespace_id"`
	LastAccessed  sql.NullTime `db:"last_accessed" json:"last_accessed"`
	CreatedAt     time.Time    `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time    `db:"updated_at" json:"updated_at"`
	NamespaceUuid uuid.UUID    `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetDecryptedNamespaceSecretsRow 

type GetDecryptedNamespaceSecretsRow struct {
	Key            string `db:"key" json:"key"`
	EncryptedValue string `db:"encrypted_value" json:"encrypted_value"`
}

type GetDistinctPrefixesRow added in v0.8.0 

type GetDistinctPrefixesRow struct {
	Uuid        uuid.UUID `db:"uuid" json:"uuid"`
	Name        string    `db:"name" json:"name"`
	Description string    `db:"description" json:"description"`
}

type GetExecutionActionRetriesParams added in v0.3.0 

type GetExecutionActionRetriesParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetExecutionByExecIDParams 

type GetExecutionByExecIDParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetExecutionByExecIDRow 

type GetExecutionByExecIDRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
}

type GetExecutionByExecIDWithNamespaceParams 

type GetExecutionByExecIDWithNamespaceParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetExecutionByExecIDWithNamespaceRow 

type GetExecutionByExecIDWithNamespaceRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
}

type GetExecutionByIDParams 

type GetExecutionByIDParams struct {
	ID   int32     `db:"id" json:"id"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type GetExecutionByIDRow 

type GetExecutionByIDRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
}

type GetExecutionsByFlowPaginatedParams 

type GetExecutionsByFlowPaginatedParams struct {
	ID     int32     `db:"id" json:"id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Limit  int32     `db:"limit" json:"limit"`
	Offset int32     `db:"offset" json:"offset"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetExecutionsByFlowPaginatedRow 

type GetExecutionsByFlowPaginatedRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
	PageCount       int64                 `db:"page_count" json:"page_count"`
	TotalCount      int64                 `db:"total_count" json:"total_count"`
}

type GetExecutionsByFlowParams 

type GetExecutionsByFlowParams struct {
	ID     int32     `db:"id" json:"id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetExecutionsByFlowRow 

type GetExecutionsByFlowRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
}

type GetFlowBySlugParams 

type GetFlowBySlugParams struct {
	Slug     string       `db:"slug" json:"slug"`
	Uuid     uuid.UUID    `db:"uuid" json:"uuid"`
	IsActive sql.NullBool `db:"is_active" json:"is_active"`
}

type GetFlowFromExecIDParams 

type GetFlowFromExecIDParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetFlowFromExecIDWithNamespaceParams 

type GetFlowFromExecIDWithNamespaceParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetFlowPrefixByNameParams added in v0.8.0 

type GetFlowPrefixByNameParams struct {
	Name string    `db:"name" json:"name"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type GetFlowPrefixByUUIDParams added in v0.8.0 

type GetFlowPrefixByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetFlowSecretByUUIDParams 

type GetFlowSecretByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetFlowSecretByUUIDRow 

type GetFlowSecretByUUIDRow struct {
	ID             int32          `db:"id" json:"id"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	FlowID         int32          `db:"flow_id" json:"flow_id"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	NamespaceID    int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetFlowsByNamespaceRow 

type GetFlowsByNamespaceRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetFlowsByPrefixParams added in v0.8.0 

type GetFlowsByPrefixParams struct {
	Uuid     uuid.UUID     `db:"uuid" json:"uuid"`
	PrefixID sql.NullInt32 `db:"prefix_id" json:"prefix_id"`
}

type GetFlowsByPrefixRow added in v0.8.0 

type GetFlowsByPrefixRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetFlowsByPrefixUUIDParams added in v0.8.0 

type GetFlowsByPrefixUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetFlowsByPrefixUUIDRow added in v0.8.0 

type GetFlowsByPrefixUUIDRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetGroupMembersByNameRow added in v0.2.0 

type GetGroupMembersByNameRow struct {
	Uuid     uuid.UUID `db:"uuid" json:"uuid"`
	Username string    `db:"username" json:"username"`
}

type GetInputForExecByUUIDParams 

type GetInputForExecByUUIDParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetMemberPrefixesParams added in v0.8.0 

type GetMemberPrefixesParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetMemberPrefixesRow added in v0.8.0 

type GetMemberPrefixesRow struct {
	Prefix    string    `db:"prefix" json:"prefix"`
	CreatedAt time.Time `db:"created_at" json:"created_at"`
}

type GetNamespaceMemberByUUIDParams added in v0.8.0 

type GetNamespaceMemberByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetNamespaceMemberByUUIDRow added in v0.8.0 

type GetNamespaceMemberByUUIDRow struct {
	ID          int32         `db:"id" json:"id"`
	Uuid        uuid.UUID     `db:"uuid" json:"uuid"`
	UserID      sql.NullInt32 `db:"user_id" json:"user_id"`
	GroupID     sql.NullInt32 `db:"group_id" json:"group_id"`
	NamespaceID int32         `db:"namespace_id" json:"namespace_id"`
	Role        string        `db:"role" json:"role"`
	CreatedAt   time.Time     `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time     `db:"updated_at" json:"updated_at"`
	SubjectUuid uuid.UUID     `db:"subject_uuid" json:"subject_uuid"`
	SubjectType string        `db:"subject_type" json:"subject_type"`
}

type GetNamespaceMembersRow 

type GetNamespaceMembersRow struct {
	Uuid        uuid.UUID `db:"uuid" json:"uuid"`
	SubjectUuid uuid.UUID `db:"subject_uuid" json:"subject_uuid"`
	SubjectName string    `db:"subject_name" json:"subject_name"`
	SubjectType string    `db:"subject_type" json:"subject_type"`
	Role        string    `db:"role" json:"role"`
	CreatedAt   time.Time `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time `db:"updated_at" json:"updated_at"`
}

type GetNamespaceSecretByUUIDParams 

type GetNamespaceSecretByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetNamespaceSecretByUUIDRow 

type GetNamespaceSecretByUUIDRow struct {
	ID             int32          `db:"id" json:"id"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	NamespaceID    int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetNodeByNameParams 

type GetNodeByNameParams struct {
	Name string    `db:"name" json:"name"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type GetNodeByNameRow 

type GetNodeByNameRow struct {
	ID             int32                `db:"id" json:"id"`
	Uuid           uuid.UUID            `db:"uuid" json:"uuid"`
	Name           string               `db:"name" json:"name"`
	Hostname       string               `db:"hostname" json:"hostname"`
	Port           int32                `db:"port" json:"port"`
	Username       string               `db:"username" json:"username"`
	OsFamily       string               `db:"os_family" json:"os_family"`
	Tags           []string             `db:"tags" json:"tags"`
	AuthMethod     AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID   sql.NullInt32        `db:"credential_id" json:"credential_id"`
	NamespaceID    int32                `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time            `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time            `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID            `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetNodeByUUIDParams 

type GetNodeByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetNodeByUUIDRow 

type GetNodeByUUIDRow struct {
	ID             int32                `db:"id" json:"id"`
	Uuid           uuid.UUID            `db:"uuid" json:"uuid"`
	Name           string               `db:"name" json:"name"`
	Hostname       string               `db:"hostname" json:"hostname"`
	Port           int32                `db:"port" json:"port"`
	Username       string               `db:"username" json:"username"`
	OsFamily       string               `db:"os_family" json:"os_family"`
	Tags           []string             `db:"tags" json:"tags"`
	AuthMethod     AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID   sql.NullInt32        `db:"credential_id" json:"credential_id"`
	NamespaceID    int32                `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time            `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time            `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID            `db:"namespace_uuid" json:"namespace_uuid"`
}

type GetNodeStatsRow 

type GetNodeStatsRow struct {
	TotalHosts int64 `db:"total_hosts" json:"total_hosts"`
	SshHosts   int64 `db:"ssh_hosts" json:"ssh_hosts"`
	QsshHosts  int64 `db:"qssh_hosts" json:"qssh_hosts"`
}

type GetNodesByNamesParams 

type GetNodesByNamesParams struct {
	Column1 []string  `db:"column_1" json:"column_1"`
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
}

type GetNodesByNamesRow 

type GetNodesByNamesRow struct {
	ID                int32                `db:"id" json:"id"`
	Uuid              uuid.UUID            `db:"uuid" json:"uuid"`
	Name              string               `db:"name" json:"name"`
	Hostname          string               `db:"hostname" json:"hostname"`
	Port              int32                `db:"port" json:"port"`
	Username          string               `db:"username" json:"username"`
	OsFamily          string               `db:"os_family" json:"os_family"`
	Tags              []string             `db:"tags" json:"tags"`
	AuthMethod        AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType    ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID      sql.NullInt32        `db:"credential_id" json:"credential_id"`
	NamespaceID       int32                `db:"namespace_id" json:"namespace_id"`
	CreatedAt         time.Time            `db:"created_at" json:"created_at"`
	UpdatedAt         time.Time            `db:"updated_at" json:"updated_at"`
	NamespaceUuid     uuid.UUID            `db:"namespace_uuid" json:"namespace_uuid"`
	CredentialUuid    uuid.NullUUID        `db:"credential_uuid" json:"credential_uuid"`
	CredentialName    sql.NullString       `db:"credential_name" json:"credential_name"`
	CredentialKeyType sql.NullString       `db:"credential_key_type" json:"credential_key_type"`
	CredentialKeyData sql.NullString       `db:"credential_key_data" json:"credential_key_data"`
}

type GetNodesByTagsParams added in v0.5.0 

type GetNodesByTagsParams struct {
	Column1 []string  `db:"column_1" json:"column_1"`
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
}

type GetNodesByTagsRow added in v0.5.0 

type GetNodesByTagsRow struct {
	ID                int32                `db:"id" json:"id"`
	Uuid              uuid.UUID            `db:"uuid" json:"uuid"`
	Name              string               `db:"name" json:"name"`
	Hostname          string               `db:"hostname" json:"hostname"`
	Port              int32                `db:"port" json:"port"`
	Username          string               `db:"username" json:"username"`
	OsFamily          string               `db:"os_family" json:"os_family"`
	Tags              []string             `db:"tags" json:"tags"`
	AuthMethod        AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType    ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID      sql.NullInt32        `db:"credential_id" json:"credential_id"`
	NamespaceID       int32                `db:"namespace_id" json:"namespace_id"`
	CreatedAt         time.Time            `db:"created_at" json:"created_at"`
	UpdatedAt         time.Time            `db:"updated_at" json:"updated_at"`
	NamespaceUuid     uuid.UUID            `db:"namespace_uuid" json:"namespace_uuid"`
	CredentialUuid    uuid.NullUUID        `db:"credential_uuid" json:"credential_uuid"`
	CredentialName    sql.NullString       `db:"credential_name" json:"credential_name"`
	CredentialKeyType sql.NullString       `db:"credential_key_type" json:"credential_key_type"`
	CredentialKeyData sql.NullString       `db:"credential_key_data" json:"credential_key_data"`
}

type GetPrefixMembersParams added in v0.8.0 

type GetPrefixMembersParams struct {
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
	Name string    `db:"name" json:"name"`
}

type GetPrefixMembersRow added in v0.8.0 

type GetPrefixMembersRow struct {
	Uuid        uuid.UUID `db:"uuid" json:"uuid"`
	SubjectUuid uuid.UUID `db:"subject_uuid" json:"subject_uuid"`
	SubjectName string    `db:"subject_name" json:"subject_name"`
	SubjectType string    `db:"subject_type" json:"subject_type"`
	Prefix      string    `db:"prefix" json:"prefix"`
	CreatedAt   time.Time `db:"created_at" json:"created_at"`
}

type GetScheduleByFlowAndCronParams added in v0.5.0 

type GetScheduleByFlowAndCronParams struct {
	FlowID        int32  `db:"flow_id" json:"flow_id"`
	Cron          string `db:"cron" json:"cron"`
	Timezone      string `db:"timezone" json:"timezone"`
	IsUserCreated bool   `db:"is_user_created" json:"is_user_created"`
}

type GetScheduledExecutionsByFlowParams added in v0.4.0 

type GetScheduledExecutionsByFlowParams struct {
	FlowID int32     `db:"flow_id" json:"flow_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type GetScheduledExecutionsByFlowRow added in v0.4.0 

type GetScheduledExecutionsByFlowRow struct {
	ExecID      string       `db:"exec_id" json:"exec_id"`
	ScheduledAt sql.NullTime `db:"scheduled_at" json:"scheduled_at"`
}

type GetScheduledFlowsRow 

type GetScheduledFlowsRow struct {
	ID            int32                 `db:"id" json:"id"`
	Slug          string                `db:"slug" json:"slug"`
	Name          string                `db:"name" json:"name"`
	Checksum      string                `db:"checksum" json:"checksum"`
	Description   sql.NullString        `db:"description" json:"description"`
	FilePath      string                `db:"file_path" json:"file_path"`
	NamespaceID   int32                 `db:"namespace_id" json:"namespace_id"`
	IsActive      bool                  `db:"is_active" json:"is_active"`
	CreatedAt     time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time             `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32         `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID             `db:"namespace_uuid" json:"namespace_uuid"`
	ScheduleID    int32                 `db:"schedule_id" json:"schedule_id"`
	Cron          string                `db:"cron" json:"cron"`
	Timezone      string                `db:"timezone" json:"timezone"`
	Inputs        pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	CreatedBy     int32                 `db:"created_by" json:"created_by"`
	IsUserCreated bool                  `db:"is_user_created" json:"is_user_created"`
}

type GetUserAccessiblePrefixesParams added in v0.8.0 

type GetUserAccessiblePrefixesParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type GetUserNamespacesWithRolesRow 

type GetUserNamespacesWithRolesRow struct {
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
	Name string    `db:"name" json:"name"`
	Role string    `db:"role" json:"role"`
}

type GetUserScheduleByUUIDParams added in v0.5.0 

type GetUserScheduleByUUIDParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Uuid_3 uuid.UUID `db:"uuid_3" json:"uuid_3"`
}

type GetUserScheduleByUUIDRow added in v0.5.0 

type GetUserScheduleByUUIDRow struct {
	ID            int32                 `db:"id" json:"id"`
	FlowID        int32                 `db:"flow_id" json:"flow_id"`
	Cron          string                `db:"cron" json:"cron"`
	Timezone      string                `db:"timezone" json:"timezone"`
	CreatedAt     time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time             `db:"updated_at" json:"updated_at"`
	Uuid          uuid.UUID             `db:"uuid" json:"uuid"`
	Inputs        pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	CreatedBy     int32                 `db:"created_by" json:"created_by"`
	IsUserCreated bool                  `db:"is_user_created" json:"is_user_created"`
	IsActive      bool                  `db:"is_active" json:"is_active"`
	FlowSlug      string                `db:"flow_slug" json:"flow_slug"`
	FlowName      string                `db:"flow_name" json:"flow_name"`
	CreatedByUuid uuid.UUID             `db:"created_by_uuid" json:"created_by_uuid"`
	CreatedByName string                `db:"created_by_name" json:"created_by_name"`
}

type Group 

type Group struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
}

type GroupMembership 

type GroupMembership struct {
	ID        int32     `db:"id" json:"id"`
	UserID    int32     `db:"user_id" json:"user_id"`
	GroupID   int32     `db:"group_id" json:"group_id"`
	CreatedAt time.Time `db:"created_at" json:"created_at"`
}

type GroupView 

type GroupView struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	Users       interface{}    `db:"users" json:"users"`
}

type IncrementActionRetryParams added in v0.3.0 

type IncrementActionRetryParams struct {
	ExecID  string      `db:"exec_id" json:"exec_id"`
	Column2 interface{} `db:"column_2" json:"column_2"`
	Uuid    uuid.UUID   `db:"uuid" json:"uuid"`
}

type IncrementActionRetryRow added in v0.3.0 

type IncrementActionRetryRow struct {
	ActionRetries pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	RetryCount    int32                 `db:"retry_count" json:"retry_count"`
}

type ListFlowSecretsParams 

type ListFlowSecretsParams struct {
	FlowID int32     `db:"flow_id" json:"flow_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type ListFlowSecretsRow 

type ListFlowSecretsRow struct {
	ID             int32          `db:"id" json:"id"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	FlowID         int32          `db:"flow_id" json:"flow_id"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	NamespaceID    int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type ListFlowsPaginatedFilteredParams added in v0.8.0 

type ListFlowsPaginatedFilteredParams struct {
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
	Limit   int32     `db:"limit" json:"limit"`
	Offset  int32     `db:"offset" json:"offset"`
	Column4 []string  `db:"column_4" json:"column_4"`
}

type ListFlowsPaginatedFilteredRow added in v0.8.0 

type ListFlowsPaginatedFilteredRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
	PrefixName    sql.NullString `db:"prefix_name" json:"prefix_name"`
	PageCount     int64          `db:"page_count" json:"page_count"`
	TotalCount    int64          `db:"total_count" json:"total_count"`
}

type ListFlowsPaginatedParams 

type ListFlowsPaginatedParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Limit  int32     `db:"limit" json:"limit"`
	Offset int32     `db:"offset" json:"offset"`
}

type ListFlowsPaginatedRow 

type ListFlowsPaginatedRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
	PrefixName    sql.NullString `db:"prefix_name" json:"prefix_name"`
	PageCount     int64          `db:"page_count" json:"page_count"`
	TotalCount    int64          `db:"total_count" json:"total_count"`
}

type ListFlowsParams 

type ListFlowsParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Limit  int32     `db:"limit" json:"limit"`
	Offset int32     `db:"offset" json:"offset"`
}

type ListFlowsRow 

type ListFlowsRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
	PageCount     int64          `db:"page_count" json:"page_count"`
	TotalCount    int64          `db:"total_count" json:"total_count"`
}

type ListNamespaceSecretsRow 

type ListNamespaceSecretsRow struct {
	ID             int32          `db:"id" json:"id"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	NamespaceID    int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
}

type ListNamespacesParams 

type ListNamespacesParams struct {
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
	Limit   int32     `db:"limit" json:"limit"`
	Offset  int32     `db:"offset" json:"offset"`
	Column4 string    `db:"column_4" json:"column_4"`
}

type ListNamespacesRow 

type ListNamespacesRow struct {
	ID         int32     `db:"id" json:"id"`
	Uuid       uuid.UUID `db:"uuid" json:"uuid"`
	Name       string    `db:"name" json:"name"`
	CreatedAt  time.Time `db:"created_at" json:"created_at"`
	UpdatedAt  time.Time `db:"updated_at" json:"updated_at"`
	PageCount  int64     `db:"page_count" json:"page_count"`
	TotalCount int64     `db:"total_count" json:"total_count"`
}

type ListSchedulesParams added in v0.5.0 

type ListSchedulesParams struct {
	Column1 interface{} `db:"column_1" json:"column_1"`
	Uuid    uuid.UUID   `db:"uuid" json:"uuid"`
	Uuid_2  uuid.UUID   `db:"uuid_2" json:"uuid_2"`
	Limit   int32       `db:"limit" json:"limit"`
	Offset  int32       `db:"offset" json:"offset"`
}

type ListSchedulesRow added in v0.5.0 

type ListSchedulesRow struct {
	ID            int32                 `db:"id" json:"id"`
	FlowID        int32                 `db:"flow_id" json:"flow_id"`
	Cron          string                `db:"cron" json:"cron"`
	Timezone      string                `db:"timezone" json:"timezone"`
	CreatedAt     time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time             `db:"updated_at" json:"updated_at"`
	Uuid          uuid.UUID             `db:"uuid" json:"uuid"`
	Inputs        pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	CreatedBy     int32                 `db:"created_by" json:"created_by"`
	IsUserCreated bool                  `db:"is_user_created" json:"is_user_created"`
	IsActive      bool                  `db:"is_active" json:"is_active"`
	FlowSlug      string                `db:"flow_slug" json:"flow_slug"`
	FlowName      string                `db:"flow_name" json:"flow_name"`
	CreatedByUuid uuid.UUID             `db:"created_by_uuid" json:"created_by_uuid"`
	CreatedByName string                `db:"created_by_name" json:"created_by_name"`
	PageCount     int64                 `db:"page_count" json:"page_count"`
	TotalCount    int64                 `db:"total_count" json:"total_count"`
}

type MarkFlowActiveParams 

type MarkFlowActiveParams struct {
	Slug string    `db:"slug" json:"slug"`
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
}

type Namespace 

type Namespace struct {
	ID        int32     `db:"id" json:"id"`
	Uuid      uuid.UUID `db:"uuid" json:"uuid"`
	Name      string    `db:"name" json:"name"`
	CreatedAt time.Time `db:"created_at" json:"created_at"`
	UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}

type NamespaceMember 

type NamespaceMember struct {
	ID          int32         `db:"id" json:"id"`
	Uuid        uuid.UUID     `db:"uuid" json:"uuid"`
	UserID      sql.NullInt32 `db:"user_id" json:"user_id"`
	GroupID     sql.NullInt32 `db:"group_id" json:"group_id"`
	NamespaceID int32         `db:"namespace_id" json:"namespace_id"`
	Role        string        `db:"role" json:"role"`
	CreatedAt   time.Time     `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time     `db:"updated_at" json:"updated_at"`
}

type NamespaceSecret 

type NamespaceSecret struct {
	ID             int32          `db:"id" json:"id"`
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	Key            string         `db:"key" json:"key"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
	NamespaceID    int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at" json:"updated_at"`
}

type Node 

type Node struct {
	ID             int32                `db:"id" json:"id"`
	Uuid           uuid.UUID            `db:"uuid" json:"uuid"`
	Name           string               `db:"name" json:"name"`
	Hostname       string               `db:"hostname" json:"hostname"`
	Port           int32                `db:"port" json:"port"`
	Username       string               `db:"username" json:"username"`
	OsFamily       string               `db:"os_family" json:"os_family"`
	Tags           []string             `db:"tags" json:"tags"`
	AuthMethod     AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID   sql.NullInt32        `db:"credential_id" json:"credential_id"`
	NamespaceID    int32                `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time            `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time            `db:"updated_at" json:"updated_at"`
}

type NullApprovalStatus 

type NullApprovalStatus struct {
	ApprovalStatus ApprovalStatus `json:"approval_status"`
	Valid          bool           `json:"valid"` // Valid is true if ApprovalStatus is not NULL
}

func (*NullApprovalStatus) Scan 

func (ns *NullApprovalStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullApprovalStatus) Value 

func (ns NullApprovalStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullAuthenticationMethod 

type NullAuthenticationMethod struct {
	AuthenticationMethod AuthenticationMethod `json:"authentication_method"`
	Valid                bool                 `json:"valid"` // Valid is true if AuthenticationMethod is not NULL
}

func (*NullAuthenticationMethod) Scan 

func (ns *NullAuthenticationMethod) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullAuthenticationMethod) Value 

func (ns NullAuthenticationMethod) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullConnectionType 

type NullConnectionType struct {
	ConnectionType ConnectionType `json:"connection_type"`
	Valid          bool           `json:"valid"` // Valid is true if ConnectionType is not NULL
}

func (*NullConnectionType) Scan 

func (ns *NullConnectionType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullConnectionType) Value 

func (ns NullConnectionType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullExecutionStatus 

type NullExecutionStatus struct {
	ExecutionStatus ExecutionStatus `json:"execution_status"`
	Valid           bool            `json:"valid"` // Valid is true if ExecutionStatus is not NULL
}

func (*NullExecutionStatus) Scan 

func (ns *NullExecutionStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullExecutionStatus) Value 

func (ns NullExecutionStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTriggerType 

type NullTriggerType struct {
	TriggerType TriggerType `json:"trigger_type"`
	Valid       bool        `json:"valid"` // Valid is true if TriggerType is not NULL
}

func (*NullTriggerType) Scan 

func (ns *NullTriggerType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTriggerType) Value 

func (ns NullTriggerType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullUserLoginType 

type NullUserLoginType struct {
	UserLoginType UserLoginType `json:"user_login_type"`
	Valid         bool          `json:"valid"` // Valid is true if UserLoginType is not NULL
}

func (*NullUserLoginType) Scan 

func (ns *NullUserLoginType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullUserLoginType) Value 

func (ns NullUserLoginType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullUserRoleType 

type NullUserRoleType struct {
	UserRoleType UserRoleType `json:"user_role_type"`
	Valid        bool         `json:"valid"` // Valid is true if UserRoleType is not NULL
}

func (*NullUserRoleType) Scan 

func (ns *NullUserRoleType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullUserRoleType) Value 

func (ns NullUserRoleType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type PostgresStore 

type PostgresStore struct {
	*Queries
	// contains filtered or unexported fields
}

func (*PostgresStore) CreateFlowTx 

func (p *PostgresStore) CreateFlowTx(ctx context.Context, params CreateFlowTxParams) (Flow, error)

func (*PostgresStore) CreateUserTx 

func (p *PostgresStore) CreateUserTx(ctx context.Context, params CreateUserTxParams) (UserView, error)

func (*PostgresStore) ProcessApprovalDecisionTx 

func (p *PostgresStore) ProcessApprovalDecisionTx(ctx context.Context, params ApprovalDecisionTxParams) (ApprovalDecisionResult, error)

func (*PostgresStore) RequestApprovalTx 

func (p *PostgresStore) RequestApprovalTx(ctx context.Context, execID string, namespaceUUID uuid.UUID, action RequestApprovalParam) (AddApprovalRequestRow, error)

func (*PostgresStore) UpdateFlowTx 

func (p *PostgresStore) UpdateFlowTx(ctx context.Context, params UpdateFlowTxParams) (Flow, error)

func (*PostgresStore) UpdateUserTx 

func (p *PostgresStore) UpdateUserTx(ctx context.Context, params UpdateUserTxParams) (UserView, error)

type PrefixAccess added in v0.8.0 

type PrefixAccess struct {
	ID          int32         `db:"id" json:"id"`
	Uuid        uuid.UUID     `db:"uuid" json:"uuid"`
	UserID      sql.NullInt32 `db:"user_id" json:"user_id"`
	GroupID     sql.NullInt32 `db:"group_id" json:"group_id"`
	NamespaceID int32         `db:"namespace_id" json:"namespace_id"`
	PrefixID    int32         `db:"prefix_id" json:"prefix_id"`
	CreatedAt   time.Time     `db:"created_at" json:"created_at"`
}

type Querier 

type Querier interface {
	AccessCredential(ctx context.Context, arg AccessCredentialParams) (Credential, error)
	AddApprovalRequest(ctx context.Context, arg AddApprovalRequestParams) (AddApprovalRequestRow, error)
	AddExecutionLog(ctx context.Context, arg AddExecutionLogParams) (ExecutionLog, error)
	AddGroupToUserByUUID(ctx context.Context, arg AddGroupToUserByUUIDParams) error
	ApproveRequestByUUID(ctx context.Context, arg ApproveRequestByUUIDParams) (ApproveRequestByUUIDRow, error)
	AssignGroupNamespaceRole(ctx context.Context, arg AssignGroupNamespaceRoleParams) (NamespaceMember, error)
	AssignGroupPrefixAccess(ctx context.Context, arg AssignGroupPrefixAccessParams) error
	AssignUserNamespaceRole(ctx context.Context, arg AssignUserNamespaceRoleParams) (NamespaceMember, error)
	AssignUserPrefixAccess(ctx context.Context, arg AssignUserPrefixAccessParams) error
	CancelTasksByExecID(ctx context.Context, execID string) error
	CreateCredential(ctx context.Context, arg CreateCredentialParams) (Credential, error)
	CreateCronSchedule(ctx context.Context, arg CreateCronScheduleParams) (CronSchedule, error)
	CreateFlow(ctx context.Context, arg CreateFlowParams) (Flow, error)
	CreateFlowPrefix(ctx context.Context, arg CreateFlowPrefixParams) (FlowPrefix, error)
	CreateFlowSecret(ctx context.Context, arg CreateFlowSecretParams) (FlowSecret, error)
	CreateGroup(ctx context.Context, arg CreateGroupParams) (Group, error)
	CreateNamespace(ctx context.Context, name string) (Namespace, error)
	CreateNamespaceSecret(ctx context.Context, arg CreateNamespaceSecretParams) (NamespaceSecret, error)
	CreateNode(ctx context.Context, arg CreateNodeParams) (Node, error)
	// Immediate task operations
	CreateSchedulerTask(ctx context.Context, arg CreateSchedulerTaskParams) (SchedulerTask, error)
	CreateUser(ctx context.Context, arg CreateUserParams) (User, error)
	CreateUserSchedule(ctx context.Context, arg CreateUserScheduleParams) (CronSchedule, error)
	DeleteAllFlows(ctx context.Context) error
	DeleteCredential(ctx context.Context, arg DeleteCredentialParams) error
	DeleteFlow(ctx context.Context, arg DeleteFlowParams) error
	DeleteFlowPrefix(ctx context.Context, arg DeleteFlowPrefixParams) error
	DeleteFlowSecret(ctx context.Context, arg DeleteFlowSecretParams) error
	DeleteGroupByUUID(ctx context.Context, argUuid uuid.UUID) error
	DeleteNamespace(ctx context.Context, argUuid uuid.UUID) error
	DeleteNamespaceSecret(ctx context.Context, arg DeleteNamespaceSecretParams) error
	DeleteNode(ctx context.Context, arg DeleteNodeParams) error
	DeleteSystemCronsByFlowID(ctx context.Context, flowID int32) error
	DeleteUserByUUID(ctx context.Context, argUuid uuid.UUID) error
	// DELETE FROM cron_schedules cs
	// USING flows f
	// WHERE cs.id = $1
	//   AND cs.flow_id = f.id
	//   AND cs.is_user_created = TRUE
	//   AND f.namespace_id = (SELECT id FROM namespaces WHERE namespaces.uuid = $3)
	//   AND cs.created_by = (SELECT id FROM users WHERE users.uuid = $2);
	DeleteUserScheduleByUUID(ctx context.Context, arg DeleteUserScheduleByUUIDParams) (int64, error)
	DisableUserSchedulesForFlow(ctx context.Context, flowID int32) error
	ExecutionExistsForFlow(ctx context.Context, arg ExecutionExistsForFlowParams) (bool, error)
	GetAllCronSchedules(ctx context.Context) ([]GetAllCronSchedulesRow, error)
	GetAllExecutionsPaginated(ctx context.Context, arg GetAllExecutionsPaginatedParams) ([]GetAllExecutionsPaginatedRow, error)
	GetAllGroups(ctx context.Context) ([]Group, error)
	GetAllGroupsWithUsers(ctx context.Context) ([]GroupView, error)
	GetAllNamespaceMembers(ctx context.Context) ([]GetAllNamespaceMembersRow, error)
	GetAllNamespaces(ctx context.Context) ([]Namespace, error)
	GetAllPrefixAccesses(ctx context.Context) ([]GetAllPrefixAccessesRow, error)
	GetAllUsersWithGroups(ctx context.Context) ([]UserView, error)
	GetApprovalByUUID(ctx context.Context, arg GetApprovalByUUIDParams) (GetApprovalByUUIDRow, error)
	GetApprovalRequestForActionAndExec(ctx context.Context, arg GetApprovalRequestForActionAndExecParams) (Approval, error)
	GetApprovalRequestForExec(ctx context.Context, arg GetApprovalRequestForExecParams) (GetApprovalRequestForExecRow, error)
	GetApprovalWithInputsByUUID(ctx context.Context, arg GetApprovalWithInputsByUUIDParams) (GetApprovalWithInputsByUUIDRow, error)
	GetApprovalsPaginated(ctx context.Context, arg GetApprovalsPaginatedParams) ([]GetApprovalsPaginatedRow, error)
	GetCredentialByID(ctx context.Context, arg GetCredentialByIDParams) (GetCredentialByIDRow, error)
	GetCredentialByUUID(ctx context.Context, arg GetCredentialByUUIDParams) (GetCredentialByUUIDRow, error)
	GetCronSchedulesByFlowID(ctx context.Context, flowID int32) ([]CronSchedule, error)
	// Used internally for execution - returns all secrets for a namespace
	GetDecryptedNamespaceSecrets(ctx context.Context, argUuid uuid.UUID) ([]GetDecryptedNamespaceSecretsRow, error)
	GetDistinctPrefixes(ctx context.Context, argUuid uuid.UUID) ([]GetDistinctPrefixesRow, error)
	GetExecutionActionRetries(ctx context.Context, arg GetExecutionActionRetriesParams) (pqtype.NullRawMessage, error)
	GetExecutionByExecID(ctx context.Context, arg GetExecutionByExecIDParams) (GetExecutionByExecIDRow, error)
	GetExecutionByExecIDWithNamespace(ctx context.Context, arg GetExecutionByExecIDWithNamespaceParams) (GetExecutionByExecIDWithNamespaceRow, error)
	GetExecutionByID(ctx context.Context, arg GetExecutionByIDParams) (GetExecutionByIDRow, error)
	GetExecutionsByFlow(ctx context.Context, arg GetExecutionsByFlowParams) ([]GetExecutionsByFlowRow, error)
	GetExecutionsByFlowPaginated(ctx context.Context, arg GetExecutionsByFlowPaginatedParams) ([]GetExecutionsByFlowPaginatedRow, error)
	GetFlowBySlug(ctx context.Context, arg GetFlowBySlugParams) (Flow, error)
	GetFlowCountByPrefix(ctx context.Context, prefixID sql.NullInt32) (int64, error)
	GetFlowFromExecID(ctx context.Context, arg GetFlowFromExecIDParams) (Flow, error)
	GetFlowFromExecIDWithNamespace(ctx context.Context, arg GetFlowFromExecIDWithNamespaceParams) (Flow, error)
	GetFlowPrefixByName(ctx context.Context, arg GetFlowPrefixByNameParams) (FlowPrefix, error)
	GetFlowPrefixByUUID(ctx context.Context, arg GetFlowPrefixByUUIDParams) (FlowPrefix, error)
	GetFlowSecretByUUID(ctx context.Context, arg GetFlowSecretByUUIDParams) (GetFlowSecretByUUIDRow, error)
	GetFlowsByNamespace(ctx context.Context, argUuid uuid.UUID) ([]GetFlowsByNamespaceRow, error)
	GetFlowsByPrefix(ctx context.Context, arg GetFlowsByPrefixParams) ([]GetFlowsByPrefixRow, error)
	GetFlowsByPrefixUUID(ctx context.Context, arg GetFlowsByPrefixUUIDParams) ([]GetFlowsByPrefixUUIDRow, error)
	GetGroupByID(ctx context.Context, id int32) (Group, error)
	GetGroupByName(ctx context.Context, name string) (Group, error)
	GetGroupByUUID(ctx context.Context, argUuid uuid.UUID) (Group, error)
	GetGroupByUUIDWithUsers(ctx context.Context, argUuid uuid.UUID) (GroupView, error)
	GetGroupMembersByName(ctx context.Context, name string) ([]GetGroupMembersByNameRow, error)
	GetInputForExecByUUID(ctx context.Context, arg GetInputForExecByUUIDParams) (json.RawMessage, error)
	GetMemberPrefixes(ctx context.Context, arg GetMemberPrefixesParams) ([]GetMemberPrefixesRow, error)
	GetNamespaceByName(ctx context.Context, name string) (Namespace, error)
	GetNamespaceByUUID(ctx context.Context, argUuid uuid.UUID) (Namespace, error)
	GetNamespaceMemberByUUID(ctx context.Context, arg GetNamespaceMemberByUUIDParams) (GetNamespaceMemberByUUIDRow, error)
	GetNamespaceMembers(ctx context.Context, argUuid uuid.UUID) ([]GetNamespaceMembersRow, error)
	GetNamespaceSecretByUUID(ctx context.Context, arg GetNamespaceSecretByUUIDParams) (GetNamespaceSecretByUUIDRow, error)
	GetNodeByName(ctx context.Context, arg GetNodeByNameParams) (GetNodeByNameRow, error)
	GetNodeByUUID(ctx context.Context, arg GetNodeByUUIDParams) (GetNodeByUUIDRow, error)
	GetNodeStats(ctx context.Context, argUuid uuid.UUID) (GetNodeStatsRow, error)
	GetNodesByNames(ctx context.Context, arg GetNodesByNamesParams) ([]GetNodesByNamesRow, error)
	GetNodesByTags(ctx context.Context, arg GetNodesByTagsParams) ([]GetNodesByTagsRow, error)
	GetPendingTasks(ctx context.Context, limit int32) ([]SchedulerTask, error)
	GetPrefixMembers(ctx context.Context, arg GetPrefixMembersParams) ([]GetPrefixMembersRow, error)
	GetScheduleByFlowAndCron(ctx context.Context, arg GetScheduleByFlowAndCronParams) (CronSchedule, error)
	GetScheduledExecutionsByFlow(ctx context.Context, arg GetScheduledExecutionsByFlowParams) ([]GetScheduledExecutionsByFlowRow, error)
	GetScheduledFlows(ctx context.Context) ([]GetScheduledFlowsRow, error)
	GetUserAccessiblePrefixes(ctx context.Context, arg GetUserAccessiblePrefixesParams) ([]string, error)
	GetUserByID(ctx context.Context, id int32) (User, error)
	GetUserByUUID(ctx context.Context, argUuid uuid.UUID) (User, error)
	GetUserByUUIDWithGroups(ctx context.Context, argUuid uuid.UUID) (UserView, error)
	GetUserByUsername(ctx context.Context, username string) (User, error)
	GetUserByUsernameWithGroups(ctx context.Context, username string) (UserView, error)
	GetUserGroups(ctx context.Context, argUuid uuid.UUID) ([]Group, error)
	GetUserNamespacesWithRoles(ctx context.Context, argUuid uuid.UUID) ([]GetUserNamespacesWithRolesRow, error)
	// SELECT
	//     cs.*,
	//     f.slug as flow_slug,
	//     f.name as flow_name,
	//     u.uuid as created_by_uuid,
	//     u.name as created_by_name
	// FROM cron_schedules cs
	// JOIN flows f ON cs.flow_id = f.id
	// LEFT JOIN users u ON cs.created_by = u.id
	// WHERE cs.id = $1
	//   AND f.namespace_id = (SELECT id FROM namespaces WHERE namespaces.uuid = $3)
	//   AND (cs.created_by = (SELECT id FROM users WHERE users.uuid = $2) OR cs.is_user_created = FALSE);
	GetUserScheduleByUUID(ctx context.Context, arg GetUserScheduleByUUIDParams) (GetUserScheduleByUUIDRow, error)
	GetUsersByRole(ctx context.Context, role UserRoleType) ([]User, error)
	IncrementActionRetry(ctx context.Context, arg IncrementActionRetryParams) (IncrementActionRetryRow, error)
	ListFlowPrefixes(ctx context.Context, argUuid uuid.UUID) ([]FlowPrefix, error)
	ListFlowSecrets(ctx context.Context, arg ListFlowSecretsParams) ([]ListFlowSecretsRow, error)
	ListFlows(ctx context.Context, arg ListFlowsParams) ([]ListFlowsRow, error)
	ListFlowsPaginated(ctx context.Context, arg ListFlowsPaginatedParams) ([]ListFlowsPaginatedRow, error)
	ListFlowsPaginatedFiltered(ctx context.Context, arg ListFlowsPaginatedFilteredParams) ([]ListFlowsPaginatedFilteredRow, error)
	ListNamespaceSecrets(ctx context.Context, argUuid uuid.UUID) ([]ListNamespaceSecretsRow, error)
	ListNamespaces(ctx context.Context, arg ListNamespacesParams) ([]ListNamespacesRow, error)
	ListSchedules(ctx context.Context, arg ListSchedulesParams) ([]ListSchedulesRow, error)
	MarkAllFlowsInactiveForNamespace(ctx context.Context, argUuid uuid.UUID) error
	MarkFlowActive(ctx context.Context, arg MarkFlowActiveParams) error
	RejectRequestByUUID(ctx context.Context, arg RejectRequestByUUIDParams) (RejectRequestByUUIDRow, error)
	RemoveAllGroupsForUserByUUID(ctx context.Context, userUuid uuid.UUID) error
	RemoveNamespaceMember(ctx context.Context, arg RemoveNamespaceMemberParams) (NamespaceMember, error)
	RevokeAllMemberPrefixAccess(ctx context.Context, arg RevokeAllMemberPrefixAccessParams) error
	RevokeGroupPrefixAccess(ctx context.Context, arg RevokeGroupPrefixAccessParams) error
	RevokeUserPrefixAccess(ctx context.Context, arg RevokeUserPrefixAccessParams) error
	SearchCredentials(ctx context.Context, arg SearchCredentialsParams) ([]SearchCredentialsRow, error)
	SearchExecutionsPaginated(ctx context.Context, arg SearchExecutionsPaginatedParams) ([]SearchExecutionsPaginatedRow, error)
	SearchFlowsPaginated(ctx context.Context, arg SearchFlowsPaginatedParams) ([]SearchFlowsPaginatedRow, error)
	SearchFlowsPaginatedFiltered(ctx context.Context, arg SearchFlowsPaginatedFilteredParams) ([]SearchFlowsPaginatedFilteredRow, error)
	SearchGroup(ctx context.Context, arg SearchGroupParams) ([]SearchGroupRow, error)
	SearchNodes(ctx context.Context, arg SearchNodesParams) ([]SearchNodesRow, error)
	SearchUsersWithGroups(ctx context.Context, arg SearchUsersWithGroupsParams) ([]SearchUsersWithGroupsRow, error)
	UpdateApprovalStatusByUUID(ctx context.Context, arg UpdateApprovalStatusByUUIDParams) (UpdateApprovalStatusByUUIDRow, error)
	UpdateCredential(ctx context.Context, arg UpdateCredentialParams) (Credential, error)
	UpdateExecutionActionID(ctx context.Context, arg UpdateExecutionActionIDParams) (ExecutionLog, error)
	UpdateExecutionActionRetries(ctx context.Context, arg UpdateExecutionActionRetriesParams) error
	UpdateExecutionStartedAt(ctx context.Context, arg UpdateExecutionStartedAtParams) error
	UpdateExecutionStatus(ctx context.Context, arg UpdateExecutionStatusParams) (ExecutionLog, error)
	UpdateFlow(ctx context.Context, arg UpdateFlowParams) (Flow, error)
	UpdateFlowPrefix(ctx context.Context, arg UpdateFlowPrefixParams) (FlowPrefix, error)
	UpdateFlowSecret(ctx context.Context, arg UpdateFlowSecretParams) (FlowSecret, error)
	UpdateGroupByUUID(ctx context.Context, arg UpdateGroupByUUIDParams) (Group, error)
	UpdateNamespace(ctx context.Context, arg UpdateNamespaceParams) (Namespace, error)
	UpdateNamespaceMember(ctx context.Context, arg UpdateNamespaceMemberParams) (NamespaceMember, error)
	UpdateNamespaceSecret(ctx context.Context, arg UpdateNamespaceSecretParams) (NamespaceSecret, error)
	UpdateNode(ctx context.Context, arg UpdateNodeParams) (Node, error)
	UpdateTaskStatus(ctx context.Context, arg UpdateTaskStatusParams) error
	UpdateUserByUUID(ctx context.Context, arg UpdateUserByUUIDParams) (User, error)
	UpdateUserPasswordByUsername(ctx context.Context, arg UpdateUserPasswordByUsernameParams) (User, error)
	// UPDATE cron_schedules cs
	// SET
	//     cron = $2,
	//     timezone = $3,
	//     inputs = $4,
	//     is_active = $5,
	//     updated_at = NOW()
	// FROM flows f
	// WHERE cs.id = $1
	//   AND cs.flow_id = f.id
	//   AND cs.is_user_created = TRUE
	//   AND f.namespace_id = (SELECT id FROM namespaces WHERE namespaces.uuid = $7)
	//   AND cs.created_by = (SELECT id FROM users WHERE users.uuid = $6)
	// RETURNING cs.*;
	UpdateUserScheduleByUUID(ctx context.Context, arg UpdateUserScheduleByUUIDParams) (CronSchedule, error)
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AccessCredential 

func (q *Queries) AccessCredential(ctx context.Context, arg AccessCredentialParams) (Credential, error)

func (*Queries) AddApprovalRequest 

func (q *Queries) AddApprovalRequest(ctx context.Context, arg AddApprovalRequestParams) (AddApprovalRequestRow, error)

func (*Queries) AddExecutionLog 

func (q *Queries) AddExecutionLog(ctx context.Context, arg AddExecutionLogParams) (ExecutionLog, error)

func (*Queries) AddGroupToUserByUUID 

func (q *Queries) AddGroupToUserByUUID(ctx context.Context, arg AddGroupToUserByUUIDParams) error

func (*Queries) ApproveRequestByUUID 

func (q *Queries) ApproveRequestByUUID(ctx context.Context, arg ApproveRequestByUUIDParams) (ApproveRequestByUUIDRow, error)

func (*Queries) AssignGroupNamespaceRole 

func (q *Queries) AssignGroupNamespaceRole(ctx context.Context, arg AssignGroupNamespaceRoleParams) (NamespaceMember, error)

func (*Queries) AssignGroupPrefixAccess added in v0.8.0 

func (q *Queries) AssignGroupPrefixAccess(ctx context.Context, arg AssignGroupPrefixAccessParams) error

func (*Queries) AssignUserNamespaceRole 

func (q *Queries) AssignUserNamespaceRole(ctx context.Context, arg AssignUserNamespaceRoleParams) (NamespaceMember, error)

func (*Queries) AssignUserPrefixAccess added in v0.8.0 

func (q *Queries) AssignUserPrefixAccess(ctx context.Context, arg AssignUserPrefixAccessParams) error

func (*Queries) CancelTasksByExecID 

func (q *Queries) CancelTasksByExecID(ctx context.Context, execID string) error

func (*Queries) CreateCredential 

func (q *Queries) CreateCredential(ctx context.Context, arg CreateCredentialParams) (Credential, error)

func (*Queries) CreateCronSchedule 

func (q *Queries) CreateCronSchedule(ctx context.Context, arg CreateCronScheduleParams) (CronSchedule, error)

func (*Queries) CreateFlow 

func (q *Queries) CreateFlow(ctx context.Context, arg CreateFlowParams) (Flow, error)

func (*Queries) CreateFlowPrefix added in v0.8.0 

func (q *Queries) CreateFlowPrefix(ctx context.Context, arg CreateFlowPrefixParams) (FlowPrefix, error)

func (*Queries) CreateFlowSecret 

func (q *Queries) CreateFlowSecret(ctx context.Context, arg CreateFlowSecretParams) (FlowSecret, error)

func (*Queries) CreateGroup 

func (q *Queries) CreateGroup(ctx context.Context, arg CreateGroupParams) (Group, error)

func (*Queries) CreateNamespace 

func (q *Queries) CreateNamespace(ctx context.Context, name string) (Namespace, error)

func (*Queries) CreateNamespaceSecret 

func (q *Queries) CreateNamespaceSecret(ctx context.Context, arg CreateNamespaceSecretParams) (NamespaceSecret, error)

func (*Queries) CreateNode 

func (q *Queries) CreateNode(ctx context.Context, arg CreateNodeParams) (Node, error)

func (*Queries) CreateSchedulerTask 

func (q *Queries) CreateSchedulerTask(ctx context.Context, arg CreateSchedulerTaskParams) (SchedulerTask, error)

Immediate task operations

func (*Queries) CreateUser 

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)

func (*Queries) CreateUserSchedule added in v0.5.0 

func (q *Queries) CreateUserSchedule(ctx context.Context, arg CreateUserScheduleParams) (CronSchedule, error)

func (*Queries) DeleteAllFlows 

func (q *Queries) DeleteAllFlows(ctx context.Context) error

func (*Queries) DeleteCredential 

func (q *Queries) DeleteCredential(ctx context.Context, arg DeleteCredentialParams) error

func (*Queries) DeleteFlow 

func (q *Queries) DeleteFlow(ctx context.Context, arg DeleteFlowParams) error

func (*Queries) DeleteFlowPrefix added in v0.8.0 

func (q *Queries) DeleteFlowPrefix(ctx context.Context, arg DeleteFlowPrefixParams) error

func (*Queries) DeleteFlowSecret 

func (q *Queries) DeleteFlowSecret(ctx context.Context, arg DeleteFlowSecretParams) error

func (*Queries) DeleteGroupByUUID 

func (q *Queries) DeleteGroupByUUID(ctx context.Context, argUuid uuid.UUID) error

func (*Queries) DeleteNamespace 

func (q *Queries) DeleteNamespace(ctx context.Context, argUuid uuid.UUID) error

func (*Queries) DeleteNamespaceSecret 

func (q *Queries) DeleteNamespaceSecret(ctx context.Context, arg DeleteNamespaceSecretParams) error

func (*Queries) DeleteNode 

func (q *Queries) DeleteNode(ctx context.Context, arg DeleteNodeParams) error

func (*Queries) DeleteSystemCronsByFlowID added in v0.5.0 

func (q *Queries) DeleteSystemCronsByFlowID(ctx context.Context, flowID int32) error

func (*Queries) DeleteUserByUUID 

func (q *Queries) DeleteUserByUUID(ctx context.Context, argUuid uuid.UUID) error

func (*Queries) DeleteUserScheduleByUUID added in v0.5.0 

func (q *Queries) DeleteUserScheduleByUUID(ctx context.Context, arg DeleteUserScheduleByUUIDParams) (int64, error)

DELETE FROM cron_schedules cs USING flows f WHERE cs.id = $1 

AND cs.flow_id = f.id
AND cs.is_user_created = TRUE
AND f.namespace_id = (SELECT id FROM namespaces WHERE namespaces.uuid = $3)
AND cs.created_by = (SELECT id FROM users WHERE users.uuid = $2);

func (*Queries) DisableUserSchedulesForFlow added in v0.5.0 

func (q *Queries) DisableUserSchedulesForFlow(ctx context.Context, flowID int32) error

func (*Queries) ExecutionExistsForFlow 

func (q *Queries) ExecutionExistsForFlow(ctx context.Context, arg ExecutionExistsForFlowParams) (bool, error)

func (*Queries) GetAllCronSchedules 

func (q *Queries) GetAllCronSchedules(ctx context.Context) ([]GetAllCronSchedulesRow, error)

func (*Queries) GetAllExecutionsPaginated 

func (q *Queries) GetAllExecutionsPaginated(ctx context.Context, arg GetAllExecutionsPaginatedParams) ([]GetAllExecutionsPaginatedRow, error)

func (*Queries) GetAllGroups 

func (q *Queries) GetAllGroups(ctx context.Context) ([]Group, error)

func (*Queries) GetAllGroupsWithUsers 

func (q *Queries) GetAllGroupsWithUsers(ctx context.Context) ([]GroupView, error)

func (*Queries) GetAllNamespaceMembers 

func (q *Queries) GetAllNamespaceMembers(ctx context.Context) ([]GetAllNamespaceMembersRow, error)

func (*Queries) GetAllNamespaces 

func (q *Queries) GetAllNamespaces(ctx context.Context) ([]Namespace, error)

func (*Queries) GetAllPrefixAccesses added in v0.8.0 

func (q *Queries) GetAllPrefixAccesses(ctx context.Context) ([]GetAllPrefixAccessesRow, error)

func (*Queries) GetAllUsersWithGroups 

func (q *Queries) GetAllUsersWithGroups(ctx context.Context) ([]UserView, error)

func (*Queries) GetApprovalByUUID 

func (q *Queries) GetApprovalByUUID(ctx context.Context, arg GetApprovalByUUIDParams) (GetApprovalByUUIDRow, error)

func (*Queries) GetApprovalRequestForActionAndExec 

func (q *Queries) GetApprovalRequestForActionAndExec(ctx context.Context, arg GetApprovalRequestForActionAndExecParams) (Approval, error)

func (*Queries) GetApprovalRequestForExec 

func (q *Queries) GetApprovalRequestForExec(ctx context.Context, arg GetApprovalRequestForExecParams) (GetApprovalRequestForExecRow, error)

func (*Queries) GetApprovalWithInputsByUUID 

func (q *Queries) GetApprovalWithInputsByUUID(ctx context.Context, arg GetApprovalWithInputsByUUIDParams) (GetApprovalWithInputsByUUIDRow, error)

func (*Queries) GetApprovalsPaginated 

func (q *Queries) GetApprovalsPaginated(ctx context.Context, arg GetApprovalsPaginatedParams) ([]GetApprovalsPaginatedRow, error)

func (*Queries) GetCredentialByID 

func (q *Queries) GetCredentialByID(ctx context.Context, arg GetCredentialByIDParams) (GetCredentialByIDRow, error)

func (*Queries) GetCredentialByUUID 

func (q *Queries) GetCredentialByUUID(ctx context.Context, arg GetCredentialByUUIDParams) (GetCredentialByUUIDRow, error)

func (*Queries) GetCronSchedulesByFlowID 

func (q *Queries) GetCronSchedulesByFlowID(ctx context.Context, flowID int32) ([]CronSchedule, error)

func (*Queries) GetDecryptedNamespaceSecrets 

func (q *Queries) GetDecryptedNamespaceSecrets(ctx context.Context, argUuid uuid.UUID) ([]GetDecryptedNamespaceSecretsRow, error)

Used internally for execution - returns all secrets for a namespace

func (*Queries) GetDistinctPrefixes added in v0.8.0 

func (q *Queries) GetDistinctPrefixes(ctx context.Context, argUuid uuid.UUID) ([]GetDistinctPrefixesRow, error)

func (*Queries) GetExecutionActionRetries added in v0.3.0 

func (q *Queries) GetExecutionActionRetries(ctx context.Context, arg GetExecutionActionRetriesParams) (pqtype.NullRawMessage, error)

func (*Queries) GetExecutionByExecID 

func (q *Queries) GetExecutionByExecID(ctx context.Context, arg GetExecutionByExecIDParams) (GetExecutionByExecIDRow, error)

func (*Queries) GetExecutionByExecIDWithNamespace 

func (q *Queries) GetExecutionByExecIDWithNamespace(ctx context.Context, arg GetExecutionByExecIDWithNamespaceParams) (GetExecutionByExecIDWithNamespaceRow, error)

func (*Queries) GetExecutionByID 

func (q *Queries) GetExecutionByID(ctx context.Context, arg GetExecutionByIDParams) (GetExecutionByIDRow, error)

func (*Queries) GetExecutionsByFlow 

func (q *Queries) GetExecutionsByFlow(ctx context.Context, arg GetExecutionsByFlowParams) ([]GetExecutionsByFlowRow, error)

func (*Queries) GetExecutionsByFlowPaginated 

func (q *Queries) GetExecutionsByFlowPaginated(ctx context.Context, arg GetExecutionsByFlowPaginatedParams) ([]GetExecutionsByFlowPaginatedRow, error)

func (*Queries) GetFlowBySlug 

func (q *Queries) GetFlowBySlug(ctx context.Context, arg GetFlowBySlugParams) (Flow, error)

func (*Queries) GetFlowCountByPrefix added in v0.8.0 

func (q *Queries) GetFlowCountByPrefix(ctx context.Context, prefixID sql.NullInt32) (int64, error)

func (*Queries) GetFlowFromExecID 

func (q *Queries) GetFlowFromExecID(ctx context.Context, arg GetFlowFromExecIDParams) (Flow, error)

func (*Queries) GetFlowFromExecIDWithNamespace 

func (q *Queries) GetFlowFromExecIDWithNamespace(ctx context.Context, arg GetFlowFromExecIDWithNamespaceParams) (Flow, error)

func (*Queries) GetFlowPrefixByName added in v0.8.0 

func (q *Queries) GetFlowPrefixByName(ctx context.Context, arg GetFlowPrefixByNameParams) (FlowPrefix, error)

func (*Queries) GetFlowPrefixByUUID added in v0.8.0 

func (q *Queries) GetFlowPrefixByUUID(ctx context.Context, arg GetFlowPrefixByUUIDParams) (FlowPrefix, error)

func (*Queries) GetFlowSecretByUUID 

func (q *Queries) GetFlowSecretByUUID(ctx context.Context, arg GetFlowSecretByUUIDParams) (GetFlowSecretByUUIDRow, error)

func (*Queries) GetFlowsByNamespace 

func (q *Queries) GetFlowsByNamespace(ctx context.Context, argUuid uuid.UUID) ([]GetFlowsByNamespaceRow, error)

func (*Queries) GetFlowsByPrefix added in v0.8.0 

func (q *Queries) GetFlowsByPrefix(ctx context.Context, arg GetFlowsByPrefixParams) ([]GetFlowsByPrefixRow, error)

func (*Queries) GetFlowsByPrefixUUID added in v0.8.0 

func (q *Queries) GetFlowsByPrefixUUID(ctx context.Context, arg GetFlowsByPrefixUUIDParams) ([]GetFlowsByPrefixUUIDRow, error)

func (*Queries) GetGroupByID 

func (q *Queries) GetGroupByID(ctx context.Context, id int32) (Group, error)

func (*Queries) GetGroupByName 

func (q *Queries) GetGroupByName(ctx context.Context, name string) (Group, error)

func (*Queries) GetGroupByUUID 

func (q *Queries) GetGroupByUUID(ctx context.Context, argUuid uuid.UUID) (Group, error)

func (*Queries) GetGroupByUUIDWithUsers 

func (q *Queries) GetGroupByUUIDWithUsers(ctx context.Context, argUuid uuid.UUID) (GroupView, error)

func (*Queries) GetGroupMembersByName added in v0.2.0 

func (q *Queries) GetGroupMembersByName(ctx context.Context, name string) ([]GetGroupMembersByNameRow, error)

func (*Queries) GetInputForExecByUUID 

func (q *Queries) GetInputForExecByUUID(ctx context.Context, arg GetInputForExecByUUIDParams) (json.RawMessage, error)

func (*Queries) GetMemberPrefixes added in v0.8.0 

func (q *Queries) GetMemberPrefixes(ctx context.Context, arg GetMemberPrefixesParams) ([]GetMemberPrefixesRow, error)

func (*Queries) GetNamespaceByName 

func (q *Queries) GetNamespaceByName(ctx context.Context, name string) (Namespace, error)

func (*Queries) GetNamespaceByUUID 

func (q *Queries) GetNamespaceByUUID(ctx context.Context, argUuid uuid.UUID) (Namespace, error)

func (*Queries) GetNamespaceMemberByUUID added in v0.8.0 

func (q *Queries) GetNamespaceMemberByUUID(ctx context.Context, arg GetNamespaceMemberByUUIDParams) (GetNamespaceMemberByUUIDRow, error)

func (*Queries) GetNamespaceMembers 

func (q *Queries) GetNamespaceMembers(ctx context.Context, argUuid uuid.UUID) ([]GetNamespaceMembersRow, error)

func (*Queries) GetNamespaceSecretByUUID 

func (q *Queries) GetNamespaceSecretByUUID(ctx context.Context, arg GetNamespaceSecretByUUIDParams) (GetNamespaceSecretByUUIDRow, error)

func (*Queries) GetNodeByName 

func (q *Queries) GetNodeByName(ctx context.Context, arg GetNodeByNameParams) (GetNodeByNameRow, error)

func (*Queries) GetNodeByUUID 

func (q *Queries) GetNodeByUUID(ctx context.Context, arg GetNodeByUUIDParams) (GetNodeByUUIDRow, error)

func (*Queries) GetNodeStats 

func (q *Queries) GetNodeStats(ctx context.Context, argUuid uuid.UUID) (GetNodeStatsRow, error)

func (*Queries) GetNodesByNames 

func (q *Queries) GetNodesByNames(ctx context.Context, arg GetNodesByNamesParams) ([]GetNodesByNamesRow, error)

func (*Queries) GetNodesByTags added in v0.5.0 

func (q *Queries) GetNodesByTags(ctx context.Context, arg GetNodesByTagsParams) ([]GetNodesByTagsRow, error)

func (*Queries) GetPendingTasks 

func (q *Queries) GetPendingTasks(ctx context.Context, limit int32) ([]SchedulerTask, error)

func (*Queries) GetPrefixMembers added in v0.8.0 

func (q *Queries) GetPrefixMembers(ctx context.Context, arg GetPrefixMembersParams) ([]GetPrefixMembersRow, error)

func (*Queries) GetScheduleByFlowAndCron added in v0.5.0 

func (q *Queries) GetScheduleByFlowAndCron(ctx context.Context, arg GetScheduleByFlowAndCronParams) (CronSchedule, error)

func (*Queries) GetScheduledExecutionsByFlow added in v0.4.0 

func (q *Queries) GetScheduledExecutionsByFlow(ctx context.Context, arg GetScheduledExecutionsByFlowParams) ([]GetScheduledExecutionsByFlowRow, error)

func (*Queries) GetScheduledFlows 

func (q *Queries) GetScheduledFlows(ctx context.Context) ([]GetScheduledFlowsRow, error)

func (*Queries) GetUserAccessiblePrefixes added in v0.8.0 

func (q *Queries) GetUserAccessiblePrefixes(ctx context.Context, arg GetUserAccessiblePrefixesParams) ([]string, error)

func (*Queries) GetUserByID 

func (q *Queries) GetUserByID(ctx context.Context, id int32) (User, error)

func (*Queries) GetUserByUUID 

func (q *Queries) GetUserByUUID(ctx context.Context, argUuid uuid.UUID) (User, error)

func (*Queries) GetUserByUUIDWithGroups 

func (q *Queries) GetUserByUUIDWithGroups(ctx context.Context, argUuid uuid.UUID) (UserView, error)

func (*Queries) GetUserByUsername 

func (q *Queries) GetUserByUsername(ctx context.Context, username string) (User, error)

func (*Queries) GetUserByUsernameWithGroups 

func (q *Queries) GetUserByUsernameWithGroups(ctx context.Context, username string) (UserView, error)

func (*Queries) GetUserGroups 

func (q *Queries) GetUserGroups(ctx context.Context, argUuid uuid.UUID) ([]Group, error)

func (*Queries) GetUserNamespacesWithRoles 

func (q *Queries) GetUserNamespacesWithRoles(ctx context.Context, argUuid uuid.UUID) ([]GetUserNamespacesWithRolesRow, error)

func (*Queries) GetUserScheduleByUUID added in v0.5.0 

func (q *Queries) GetUserScheduleByUUID(ctx context.Context, arg GetUserScheduleByUUIDParams) (GetUserScheduleByUUIDRow, error)

SELECT 

cs.*,
f.slug as flow_slug,
f.name as flow_name,
u.uuid as created_by_uuid,
u.name as created_by_name

FROM cron_schedules cs JOIN flows f ON cs.flow_id = f.id LEFT JOIN users u ON cs.created_by = u.id WHERE cs.id = $1 

AND f.namespace_id = (SELECT id FROM namespaces WHERE namespaces.uuid = $3)
AND (cs.created_by = (SELECT id FROM users WHERE users.uuid = $2) OR cs.is_user_created = FALSE);

func (*Queries) GetUsersByRole 

func (q *Queries) GetUsersByRole(ctx context.Context, role UserRoleType) ([]User, error)

func (*Queries) IncrementActionRetry added in v0.3.0 

func (q *Queries) IncrementActionRetry(ctx context.Context, arg IncrementActionRetryParams) (IncrementActionRetryRow, error)

func (*Queries) ListFlowPrefixes added in v0.8.0 

func (q *Queries) ListFlowPrefixes(ctx context.Context, argUuid uuid.UUID) ([]FlowPrefix, error)

func (*Queries) ListFlowSecrets 

func (q *Queries) ListFlowSecrets(ctx context.Context, arg ListFlowSecretsParams) ([]ListFlowSecretsRow, error)

func (*Queries) ListFlows 

func (q *Queries) ListFlows(ctx context.Context, arg ListFlowsParams) ([]ListFlowsRow, error)

func (*Queries) ListFlowsPaginated 

func (q *Queries) ListFlowsPaginated(ctx context.Context, arg ListFlowsPaginatedParams) ([]ListFlowsPaginatedRow, error)

func (*Queries) ListFlowsPaginatedFiltered added in v0.8.0 

func (q *Queries) ListFlowsPaginatedFiltered(ctx context.Context, arg ListFlowsPaginatedFilteredParams) ([]ListFlowsPaginatedFilteredRow, error)

func (*Queries) ListNamespaceSecrets 

func (q *Queries) ListNamespaceSecrets(ctx context.Context, argUuid uuid.UUID) ([]ListNamespaceSecretsRow, error)

func (*Queries) ListNamespaces 

func (q *Queries) ListNamespaces(ctx context.Context, arg ListNamespacesParams) ([]ListNamespacesRow, error)

func (*Queries) ListSchedules added in v0.5.0 

func (q *Queries) ListSchedules(ctx context.Context, arg ListSchedulesParams) ([]ListSchedulesRow, error)

func (*Queries) MarkAllFlowsInactiveForNamespace 

func (q *Queries) MarkAllFlowsInactiveForNamespace(ctx context.Context, argUuid uuid.UUID) error

func (*Queries) MarkFlowActive 

func (q *Queries) MarkFlowActive(ctx context.Context, arg MarkFlowActiveParams) error

func (*Queries) RejectRequestByUUID 

func (q *Queries) RejectRequestByUUID(ctx context.Context, arg RejectRequestByUUIDParams) (RejectRequestByUUIDRow, error)

func (*Queries) RemoveAllGroupsForUserByUUID 

func (q *Queries) RemoveAllGroupsForUserByUUID(ctx context.Context, userUuid uuid.UUID) error

func (*Queries) RemoveNamespaceMember 

func (q *Queries) RemoveNamespaceMember(ctx context.Context, arg RemoveNamespaceMemberParams) (NamespaceMember, error)

func (*Queries) RevokeAllMemberPrefixAccess added in v0.8.0 

func (q *Queries) RevokeAllMemberPrefixAccess(ctx context.Context, arg RevokeAllMemberPrefixAccessParams) error

func (*Queries) RevokeGroupPrefixAccess added in v0.8.0 

func (q *Queries) RevokeGroupPrefixAccess(ctx context.Context, arg RevokeGroupPrefixAccessParams) error

func (*Queries) RevokeUserPrefixAccess added in v0.8.0 

func (q *Queries) RevokeUserPrefixAccess(ctx context.Context, arg RevokeUserPrefixAccessParams) error

func (*Queries) SearchCredentials 

func (q *Queries) SearchCredentials(ctx context.Context, arg SearchCredentialsParams) ([]SearchCredentialsRow, error)

func (*Queries) SearchExecutionsPaginated 

func (q *Queries) SearchExecutionsPaginated(ctx context.Context, arg SearchExecutionsPaginatedParams) ([]SearchExecutionsPaginatedRow, error)

func (*Queries) SearchFlowsPaginated 

func (q *Queries) SearchFlowsPaginated(ctx context.Context, arg SearchFlowsPaginatedParams) ([]SearchFlowsPaginatedRow, error)

func (*Queries) SearchFlowsPaginatedFiltered added in v0.8.0 

func (q *Queries) SearchFlowsPaginatedFiltered(ctx context.Context, arg SearchFlowsPaginatedFilteredParams) ([]SearchFlowsPaginatedFilteredRow, error)

func (*Queries) SearchGroup 

func (q *Queries) SearchGroup(ctx context.Context, arg SearchGroupParams) ([]SearchGroupRow, error)

func (*Queries) SearchNodes 

func (q *Queries) SearchNodes(ctx context.Context, arg SearchNodesParams) ([]SearchNodesRow, error)

func (*Queries) SearchUsersWithGroups 

func (q *Queries) SearchUsersWithGroups(ctx context.Context, arg SearchUsersWithGroupsParams) ([]SearchUsersWithGroupsRow, error)

func (*Queries) UpdateApprovalStatusByUUID 

func (q *Queries) UpdateApprovalStatusByUUID(ctx context.Context, arg UpdateApprovalStatusByUUIDParams) (UpdateApprovalStatusByUUIDRow, error)

func (*Queries) UpdateCredential 

func (q *Queries) UpdateCredential(ctx context.Context, arg UpdateCredentialParams) (Credential, error)

func (*Queries) UpdateExecutionActionID 

func (q *Queries) UpdateExecutionActionID(ctx context.Context, arg UpdateExecutionActionIDParams) (ExecutionLog, error)

func (*Queries) UpdateExecutionActionRetries added in v0.3.0 

func (q *Queries) UpdateExecutionActionRetries(ctx context.Context, arg UpdateExecutionActionRetriesParams) error

func (*Queries) UpdateExecutionStartedAt added in v0.4.0 

func (q *Queries) UpdateExecutionStartedAt(ctx context.Context, arg UpdateExecutionStartedAtParams) error

func (*Queries) UpdateExecutionStatus 

func (q *Queries) UpdateExecutionStatus(ctx context.Context, arg UpdateExecutionStatusParams) (ExecutionLog, error)

func (*Queries) UpdateFlow 

func (q *Queries) UpdateFlow(ctx context.Context, arg UpdateFlowParams) (Flow, error)

func (*Queries) UpdateFlowPrefix added in v0.8.0 

func (q *Queries) UpdateFlowPrefix(ctx context.Context, arg UpdateFlowPrefixParams) (FlowPrefix, error)

func (*Queries) UpdateFlowSecret 

func (q *Queries) UpdateFlowSecret(ctx context.Context, arg UpdateFlowSecretParams) (FlowSecret, error)

func (*Queries) UpdateGroupByUUID 

func (q *Queries) UpdateGroupByUUID(ctx context.Context, arg UpdateGroupByUUIDParams) (Group, error)

func (*Queries) UpdateNamespace 

func (q *Queries) UpdateNamespace(ctx context.Context, arg UpdateNamespaceParams) (Namespace, error)

func (*Queries) UpdateNamespaceMember 

func (q *Queries) UpdateNamespaceMember(ctx context.Context, arg UpdateNamespaceMemberParams) (NamespaceMember, error)

func (*Queries) UpdateNamespaceSecret 

func (q *Queries) UpdateNamespaceSecret(ctx context.Context, arg UpdateNamespaceSecretParams) (NamespaceSecret, error)

func (*Queries) UpdateNode 

func (q *Queries) UpdateNode(ctx context.Context, arg UpdateNodeParams) (Node, error)

func (*Queries) UpdateTaskStatus 

func (q *Queries) UpdateTaskStatus(ctx context.Context, arg UpdateTaskStatusParams) error

func (*Queries) UpdateUserByUUID 

func (q *Queries) UpdateUserByUUID(ctx context.Context, arg UpdateUserByUUIDParams) (User, error)

func (*Queries) UpdateUserPasswordByUsername 

func (q *Queries) UpdateUserPasswordByUsername(ctx context.Context, arg UpdateUserPasswordByUsernameParams) (User, error)

func (*Queries) UpdateUserScheduleByUUID added in v0.5.0 

func (q *Queries) UpdateUserScheduleByUUID(ctx context.Context, arg UpdateUserScheduleByUUIDParams) (CronSchedule, error)

UPDATE cron_schedules cs SET 

cron = $2,
timezone = $3,
inputs = $4,
is_active = $5,
updated_at = NOW()

FROM flows f WHERE cs.id = $1 

AND cs.flow_id = f.id
AND cs.is_user_created = TRUE
AND f.namespace_id = (SELECT id FROM namespaces WHERE namespaces.uuid = $7)
AND cs.created_by = (SELECT id FROM users WHERE users.uuid = $6)

RETURNING cs.*;

func (*Queries) WithTx 

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type RejectRequestByUUIDParams 

type RejectRequestByUUIDParams struct {
	Uuid      uuid.UUID     `db:"uuid" json:"uuid"`
	DecidedBy sql.NullInt32 `db:"decided_by" json:"decided_by"`
	Uuid_2    uuid.UUID     `db:"uuid_2" json:"uuid_2"`
}

type RejectRequestByUUIDRow 

type RejectRequestByUUIDRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	ExecID      string         `db:"exec_id" json:"exec_id"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
}

type RemoveNamespaceMemberParams 

type RemoveNamespaceMemberParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type RequestApprovalParam 

type RequestApprovalParam struct {
	ID string
}

type RevokeAllMemberPrefixAccessParams added in v0.8.0 

type RevokeAllMemberPrefixAccessParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type RevokeGroupPrefixAccessParams added in v0.8.0 

type RevokeGroupPrefixAccessParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Name   string    `db:"name" json:"name"`
}

type RevokeUserPrefixAccessParams added in v0.8.0 

type RevokeUserPrefixAccessParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Name   string    `db:"name" json:"name"`
}

type SchedulerTask 

type SchedulerTask struct {
	ID        int32           `db:"id" json:"id"`
	Uuid      uuid.UUID       `db:"uuid" json:"uuid"`
	ExecID    string          `db:"exec_id" json:"exec_id"`
	Payload   json.RawMessage `db:"payload" json:"payload"`
	Status    string          `db:"status" json:"status"`
	CreatedAt time.Time       `db:"created_at" json:"created_at"`
}

type SearchCredentialsParams 

type SearchCredentialsParams struct {
	Uuid    uuid.UUID   `db:"uuid" json:"uuid"`
	Limit   int32       `db:"limit" json:"limit"`
	Offset  int32       `db:"offset" json:"offset"`
	Column4 interface{} `db:"column_4" json:"column_4"`
}

type SearchCredentialsRow 

type SearchCredentialsRow struct {
	ID            int32        `db:"id" json:"id"`
	Uuid          uuid.UUID    `db:"uuid" json:"uuid"`
	Name          string       `db:"name" json:"name"`
	KeyType       string       `db:"key_type" json:"key_type"`
	KeyData       string       `db:"key_data" json:"key_data"`
	NamespaceID   int32        `db:"namespace_id" json:"namespace_id"`
	LastAccessed  sql.NullTime `db:"last_accessed" json:"last_accessed"`
	CreatedAt     time.Time    `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time    `db:"updated_at" json:"updated_at"`
	NamespaceUuid uuid.UUID    `db:"namespace_uuid" json:"namespace_uuid"`
	PageCount     int64        `db:"page_count" json:"page_count"`
	TotalCount    int64        `db:"total_count" json:"total_count"`
}

type SearchExecutionsPaginatedParams 

type SearchExecutionsPaginatedParams struct {
	Uuid    uuid.UUID   `db:"uuid" json:"uuid"`
	Column2 interface{} `db:"column_2" json:"column_2"`
	Limit   int32       `db:"limit" json:"limit"`
	Offset  int32       `db:"offset" json:"offset"`
	Uuid_2  uuid.UUID   `db:"uuid_2" json:"uuid_2"`
}

type SearchExecutionsPaginatedRow 

type SearchExecutionsPaginatedRow struct {
	ID              int32                 `db:"id" json:"id"`
	ExecID          string                `db:"exec_id" json:"exec_id"`
	FlowID          int32                 `db:"flow_id" json:"flow_id"`
	Version         int32                 `db:"version" json:"version"`
	Input           json.RawMessage       `db:"input" json:"input"`
	Error           sql.NullString        `db:"error" json:"error"`
	CurrentActionID sql.NullString        `db:"current_action_id" json:"current_action_id"`
	Status          ExecutionStatus       `db:"status" json:"status"`
	TriggerType     TriggerType           `db:"trigger_type" json:"trigger_type"`
	TriggeredBy     int32                 `db:"triggered_by" json:"triggered_by"`
	NamespaceID     int32                 `db:"namespace_id" json:"namespace_id"`
	CreatedAt       time.Time             `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time             `db:"updated_at" json:"updated_at"`
	CompletedAt     sql.NullTime          `db:"completed_at" json:"completed_at"`
	ActionRetries   pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	ScheduledAt     sql.NullTime          `db:"scheduled_at" json:"scheduled_at"`
	StartedAt       sql.NullTime          `db:"started_at" json:"started_at"`
	Name            string                `db:"name" json:"name"`
	Username        string                `db:"username" json:"username"`
	TriggeredByUuid uuid.UUID             `db:"triggered_by_uuid" json:"triggered_by_uuid"`
	TriggeredByName string                `db:"triggered_by_name" json:"triggered_by_name"`
	FlowName        string                `db:"flow_name" json:"flow_name"`
	FlowSlug        string                `db:"flow_slug" json:"flow_slug"`
	PageCount       int64                 `db:"page_count" json:"page_count"`
	TotalCount      int64                 `db:"total_count" json:"total_count"`
}

type SearchFlowsPaginatedFilteredParams added in v0.8.0 

type SearchFlowsPaginatedFilteredParams struct {
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
	Column2 string    `db:"column_2" json:"column_2"`
	Limit   int32     `db:"limit" json:"limit"`
	Offset  int32     `db:"offset" json:"offset"`
	Column5 []string  `db:"column_5" json:"column_5"`
}

type SearchFlowsPaginatedFilteredRow added in v0.8.0 

type SearchFlowsPaginatedFilteredRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
	PrefixName    sql.NullString `db:"prefix_name" json:"prefix_name"`
	PageCount     int64          `db:"page_count" json:"page_count"`
	TotalCount    int64          `db:"total_count" json:"total_count"`
}

type SearchFlowsPaginatedParams 

type SearchFlowsPaginatedParams struct {
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
	Column2 string    `db:"column_2" json:"column_2"`
	Limit   int32     `db:"limit" json:"limit"`
	Offset  int32     `db:"offset" json:"offset"`
}

type SearchFlowsPaginatedRow 

type SearchFlowsPaginatedRow struct {
	ID            int32          `db:"id" json:"id"`
	Slug          string         `db:"slug" json:"slug"`
	Name          string         `db:"name" json:"name"`
	Checksum      string         `db:"checksum" json:"checksum"`
	Description   sql.NullString `db:"description" json:"description"`
	FilePath      string         `db:"file_path" json:"file_path"`
	NamespaceID   int32          `db:"namespace_id" json:"namespace_id"`
	IsActive      bool           `db:"is_active" json:"is_active"`
	CreatedAt     time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt     time.Time      `db:"updated_at" json:"updated_at"`
	PrefixID      sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	NamespaceUuid uuid.UUID      `db:"namespace_uuid" json:"namespace_uuid"`
	PrefixName    sql.NullString `db:"prefix_name" json:"prefix_name"`
	PageCount     int64          `db:"page_count" json:"page_count"`
	TotalCount    int64          `db:"total_count" json:"total_count"`
}

type SearchGroupParams 

type SearchGroupParams struct {
	Column1 string `db:"column_1" json:"column_1"`
	Limit   int32  `db:"limit" json:"limit"`
	Offset  int32  `db:"offset" json:"offset"`
}

type SearchGroupRow 

type SearchGroupRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	Users       interface{}    `db:"users" json:"users"`
	PageCount   int64          `db:"page_count" json:"page_count"`
	TotalCount  int64          `db:"total_count" json:"total_count"`
}

type SearchNodesParams 

type SearchNodesParams struct {
	Uuid    uuid.UUID   `db:"uuid" json:"uuid"`
	Limit   int32       `db:"limit" json:"limit"`
	Offset  int32       `db:"offset" json:"offset"`
	Column4 interface{} `db:"column_4" json:"column_4"`
	Column5 []string    `db:"column_5" json:"column_5"`
}

type SearchNodesRow 

type SearchNodesRow struct {
	ID             int32                `db:"id" json:"id"`
	Uuid           uuid.UUID            `db:"uuid" json:"uuid"`
	Name           string               `db:"name" json:"name"`
	Hostname       string               `db:"hostname" json:"hostname"`
	Port           int32                `db:"port" json:"port"`
	Username       string               `db:"username" json:"username"`
	OsFamily       string               `db:"os_family" json:"os_family"`
	Tags           []string             `db:"tags" json:"tags"`
	AuthMethod     AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID   sql.NullInt32        `db:"credential_id" json:"credential_id"`
	NamespaceID    int32                `db:"namespace_id" json:"namespace_id"`
	CreatedAt      time.Time            `db:"created_at" json:"created_at"`
	UpdatedAt      time.Time            `db:"updated_at" json:"updated_at"`
	NamespaceUuid  uuid.UUID            `db:"namespace_uuid" json:"namespace_uuid"`
	PageCount      int64                `db:"page_count" json:"page_count"`
	TotalCount     int64                `db:"total_count" json:"total_count"`
}

type SearchUsersWithGroupsParams 

type SearchUsersWithGroupsParams struct {
	Column1 string `db:"column_1" json:"column_1"`
	Limit   int32  `db:"limit" json:"limit"`
	Offset  int32  `db:"offset" json:"offset"`
}

type SearchUsersWithGroupsRow 

type SearchUsersWithGroupsRow struct {
	ID         int32          `db:"id" json:"id"`
	Uuid       uuid.UUID      `db:"uuid" json:"uuid"`
	Name       string         `db:"name" json:"name"`
	Username   string         `db:"username" json:"username"`
	Password   sql.NullString `db:"password" json:"password"`
	LoginType  UserLoginType  `db:"login_type" json:"login_type"`
	Role       UserRoleType   `db:"role" json:"role"`
	CreatedAt  time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt  time.Time      `db:"updated_at" json:"updated_at"`
	Groups     interface{}    `db:"groups" json:"groups"`
	PageCount  int64          `db:"page_count" json:"page_count"`
	TotalCount int64          `db:"total_count" json:"total_count"`
}

type Session 

type Session struct {
	ID        string          `db:"id" json:"id"`
	Data      json.RawMessage `db:"data" json:"data"`
	CreatedAt time.Time       `db:"created_at" json:"created_at"`
}

type Store 

type Store interface {
	Querier
	RequestApprovalTx(ctx context.Context, execID string, namespaceUUID uuid.UUID, action RequestApprovalParam) (AddApprovalRequestRow, error)
	CreateUserTx(ctx context.Context, params CreateUserTxParams) (UserView, error)
	UpdateUserTx(ctx context.Context, params UpdateUserTxParams) (UserView, error)
	ProcessApprovalDecisionTx(ctx context.Context, params ApprovalDecisionTxParams) (ApprovalDecisionResult, error)
	CreateFlowTx(ctx context.Context, params CreateFlowTxParams) (Flow, error)
	UpdateFlowTx(ctx context.Context, params UpdateFlowTxParams) (Flow, error)
}

func NewPostgresStore 

func NewPostgresStore(db *sqlx.DB) Store

type TriggerType 

type TriggerType string
const (
	TriggerTypeManual    TriggerType = "manual"
	TriggerTypeScheduled TriggerType = "scheduled"
)

func (*TriggerType) Scan 

func (e *TriggerType) Scan(src interface{}) error

type UpdateApprovalStatusByUUIDParams 

type UpdateApprovalStatusByUUIDParams struct {
	Status    ApprovalStatus `db:"status" json:"status"`
	DecidedBy sql.NullInt32  `db:"decided_by" json:"decided_by"`
}

type UpdateApprovalStatusByUUIDRow 

type UpdateApprovalStatusByUUIDRow struct {
	ID          int32          `db:"id" json:"id"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
	ExecLogID   int32          `db:"exec_log_id" json:"exec_log_id"`
	ActionID    string         `db:"action_id" json:"action_id"`
	Status      ApprovalStatus `db:"status" json:"status"`
	DecidedBy   sql.NullInt32  `db:"decided_by" json:"decided_by"`
	NamespaceID int32          `db:"namespace_id" json:"namespace_id"`
	CreatedAt   time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time      `db:"updated_at" json:"updated_at"`
	RequestedBy string         `db:"requested_by" json:"requested_by"`
}

type UpdateCredentialParams 

type UpdateCredentialParams struct {
	Uuid    uuid.UUID `db:"uuid" json:"uuid"`
	Name    string    `db:"name" json:"name"`
	KeyType string    `db:"key_type" json:"key_type"`
	KeyData string    `db:"key_data" json:"key_data"`
	Uuid_2  uuid.UUID `db:"uuid_2" json:"uuid_2"`
}

type UpdateExecutionActionIDParams 

type UpdateExecutionActionIDParams struct {
	CurrentActionID sql.NullString `db:"current_action_id" json:"current_action_id"`
	ExecID          string         `db:"exec_id" json:"exec_id"`
	Uuid            uuid.UUID      `db:"uuid" json:"uuid"`
}

type UpdateExecutionActionRetriesParams added in v0.3.0 

type UpdateExecutionActionRetriesParams struct {
	ExecID        string                `db:"exec_id" json:"exec_id"`
	ActionRetries pqtype.NullRawMessage `db:"action_retries" json:"action_retries"`
	Uuid          uuid.UUID             `db:"uuid" json:"uuid"`
}

type UpdateExecutionStartedAtParams added in v0.4.0 

type UpdateExecutionStartedAtParams struct {
	ExecID string    `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
}

type UpdateExecutionStatusParams 

type UpdateExecutionStatusParams struct {
	Status ExecutionStatus `db:"status" json:"status"`
	Error  sql.NullString  `db:"error" json:"error"`
	ExecID string          `db:"exec_id" json:"exec_id"`
	Uuid   uuid.UUID       `db:"uuid" json:"uuid"`
}

type UpdateFlowParams 

type UpdateFlowParams struct {
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
	Checksum    string         `db:"checksum" json:"checksum"`
	FilePath    string         `db:"file_path" json:"file_path"`
	PrefixID    sql.NullInt32  `db:"prefix_id" json:"prefix_id"`
	Slug        string         `db:"slug" json:"slug"`
	Name_2      string         `db:"name_2" json:"name_2"`
}

type UpdateFlowPrefixParams added in v0.8.0 

type UpdateFlowPrefixParams struct {
	Uuid        uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2      uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Name        string    `db:"name" json:"name"`
	Description string    `db:"description" json:"description"`
}

type UpdateFlowSecretParams 

type UpdateFlowSecretParams struct {
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	Uuid_2         uuid.UUID      `db:"uuid_2" json:"uuid_2"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
}

type UpdateFlowTxParams 

type UpdateFlowTxParams struct {
	Slug            string
	Name            string
	Description     string
	Checksum        string
	FilePath        string
	Namespace       string
	PrefixID        sql.NullInt32
	UserSchedulable bool
	Schedules       []struct {
		Cron     string
		Timezone string
	}
}

type UpdateGroupByUUIDParams 

type UpdateGroupByUUIDParams struct {
	Name        string         `db:"name" json:"name"`
	Description sql.NullString `db:"description" json:"description"`
	Uuid        uuid.UUID      `db:"uuid" json:"uuid"`
}

type UpdateNamespaceMemberParams 

type UpdateNamespaceMemberParams struct {
	Uuid   uuid.UUID `db:"uuid" json:"uuid"`
	Uuid_2 uuid.UUID `db:"uuid_2" json:"uuid_2"`
	Role   string    `db:"role" json:"role"`
}

type UpdateNamespaceParams 

type UpdateNamespaceParams struct {
	Uuid uuid.UUID `db:"uuid" json:"uuid"`
	Name string    `db:"name" json:"name"`
}

type UpdateNamespaceSecretParams 

type UpdateNamespaceSecretParams struct {
	Uuid           uuid.UUID      `db:"uuid" json:"uuid"`
	Uuid_2         uuid.UUID      `db:"uuid_2" json:"uuid_2"`
	EncryptedValue string         `db:"encrypted_value" json:"encrypted_value"`
	Description    sql.NullString `db:"description" json:"description"`
}

type UpdateNodeParams 

type UpdateNodeParams struct {
	Uuid           uuid.UUID            `db:"uuid" json:"uuid"`
	Name           string               `db:"name" json:"name"`
	Hostname       string               `db:"hostname" json:"hostname"`
	Port           int32                `db:"port" json:"port"`
	Username       string               `db:"username" json:"username"`
	OsFamily       string               `db:"os_family" json:"os_family"`
	Tags           []string             `db:"tags" json:"tags"`
	AuthMethod     AuthenticationMethod `db:"auth_method" json:"auth_method"`
	ConnectionType ConnectionType       `db:"connection_type" json:"connection_type"`
	CredentialID   sql.NullInt32        `db:"credential_id" json:"credential_id"`
	Uuid_2         uuid.UUID            `db:"uuid_2" json:"uuid_2"`
}

type UpdateTaskStatusParams 

type UpdateTaskStatusParams struct {
	Status string `db:"status" json:"status"`
	ID     int32  `db:"id" json:"id"`
}

type UpdateUserByUUIDParams 

type UpdateUserByUUIDParams struct {
	Name     string    `db:"name" json:"name"`
	Username string    `db:"username" json:"username"`
	Uuid     uuid.UUID `db:"uuid" json:"uuid"`
}

type UpdateUserPasswordByUsernameParams 

type UpdateUserPasswordByUsernameParams struct {
	Username string         `db:"username" json:"username"`
	Password sql.NullString `db:"password" json:"password"`
}

type UpdateUserScheduleByUUIDParams added in v0.5.0 

type UpdateUserScheduleByUUIDParams struct {
	Uuid     uuid.UUID             `db:"uuid" json:"uuid"`
	Cron     string                `db:"cron" json:"cron"`
	Timezone string                `db:"timezone" json:"timezone"`
	Inputs   pqtype.NullRawMessage `db:"inputs" json:"inputs"`
	IsActive bool                  `db:"is_active" json:"is_active"`
	Uuid_2   uuid.UUID             `db:"uuid_2" json:"uuid_2"`
	Uuid_3   uuid.UUID             `db:"uuid_3" json:"uuid_3"`
}

type UpdateUserTxParams 

type UpdateUserTxParams struct {
	UserUUID uuid.UUID
	Name     string
	Username string
	Groups   []string
}

type User 

type User struct {
	ID        int32          `db:"id" json:"id"`
	Uuid      uuid.UUID      `db:"uuid" json:"uuid"`
	Name      string         `db:"name" json:"name"`
	Username  string         `db:"username" json:"username"`
	Password  sql.NullString `db:"password" json:"password"`
	LoginType UserLoginType  `db:"login_type" json:"login_type"`
	Role      UserRoleType   `db:"role" json:"role"`
	CreatedAt time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt time.Time      `db:"updated_at" json:"updated_at"`
}

type UserLoginType 

type UserLoginType string
const (
	UserLoginTypeOidc     UserLoginType = "oidc"
	UserLoginTypeStandard UserLoginType = "standard"
	UserLoginTypeToken    UserLoginType = "token"
)

func (*UserLoginType) Scan 

func (e *UserLoginType) Scan(src interface{}) error

type UserRoleType 

type UserRoleType string
const (
	UserRoleTypeSuperuser UserRoleType = "superuser"
	UserRoleTypeUser      UserRoleType = "user"
)

func (*UserRoleType) Scan 

func (e *UserRoleType) Scan(src interface{}) error

type UserView 

type UserView struct {
	ID        int32          `db:"id" json:"id"`
	Uuid      uuid.UUID      `db:"uuid" json:"uuid"`
	Name      string         `db:"name" json:"name"`
	Username  string         `db:"username" json:"username"`
	Password  sql.NullString `db:"password" json:"password"`
	LoginType UserLoginType  `db:"login_type" json:"login_type"`
	Role      UserRoleType   `db:"role" json:"role"`
	CreatedAt time.Time      `db:"created_at" json:"created_at"`
	UpdatedAt time.Time      `db:"updated_at" json:"updated_at"`
	Groups    interface{}    `db:"groups" json:"groups"`
}

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.