control

package

v0.0.0-...-e8da0a6 Latest Latest Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/claion-org/claiflow

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CreateCluster(ctx context.Context, model *model.Cluster) error
func CreateClusterClientSession(ctx context.Context, session *model.ClusterClientSession) error
func CreateClusterClientToken(ctx context.Context, token *model.ClusterClientToken) error
func CreateClusterServiceStatus(ctx context.Context, status *model.ClusterServiceStatus) error
func CreateClusterServiceStatuses(ctx context.Context, statuses []model.ClusterServiceStatus) error
func CreateService(ctx context.Context, newServicies []model.ServiceWithStatuses) error
func CreateWebhook(ctx context.Context, webhook *model.Webhook) error
func DeleteCluster(ctx context.Context, uuid string) error
func DeleteClusterClientSession(ctx context.Context, uuid string) error
func DeleteClusterClientToken(ctx context.Context, uuid string) error
func DeleteWebhook(ctx context.Context, uuid string) error
func FindCluster(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, ...) ([]model.Cluster, error)
func FindClusterClientSession(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, ...) ([]model.ClusterClientSession, error)
func FindClusterClientToken(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, ...) ([]model.ClusterClientToken, error)
func FindClusterService(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, ...) ([]model.ServiceWithStatuses, error)
func FindGlobalVariables(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt) ([]model.GlobalVariable, error)
func FindWebhook(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, ...) ([]model.Webhook, error)
func GetCluster(ctx context.Context, uuid string) (*model.Cluster, error)
func GetClusterClientSession(ctx context.Context, uuid string) (*model.ClusterClientSession, error)
func GetClusterClientToken(ctx context.Context, uuid string) (*model.ClusterClientToken, error)
func GetClusterClientTokenByAssertion(ctx context.Context, clusterUUID string, token_ string) (*model.ClusterClientToken, error)
func GetClusterClientTokenColumns(ctx context.Context, uuid string, columns map[string]interface{}) error
func GetClusterPollingOffset(ctx context.Context, clusterUUID string) (time.Time, error)
func GetClusterService(ctx context.Context, clusterUUID, uuid string) (*model.ClusterService, error)
func GetClusterServiceResult(ctx context.Context, clusterUUID, uuid string) (*model.ClusterServiceResult, error)
func GetClusterServiceResults(ctx context.Context, clusterUUID, uuid string) ([]model.ClusterServiceResult, error)
func GetClusterServiceStatuses(ctx context.Context, clusterUUID, uuid string) ([]model.ClusterServiceStatus, error)
func GetGlobalVariable(ctx context.Context, uuid string) (*model.GlobalVariable, error)
func GetTemplate(ctx context.Context, uuid string) (*model.Template, error)
func GetWebhook(ctx context.Context, uuid string) (*model.Webhook, error)
func IsExistsCluster(ctx context.Context, uuid string) (bool, error)
func IsExistsClusterClientSession(ctx context.Context, uuid string) (bool, error)
func PollClusterService(ctx context.Context, clusterUUID string, offset time.Time, ...) ([]model.ClusterService, error)
func UpsertCluster(ctx context.Context, cluster *model.Cluster, updateColumns []string) error
func UpsertClusterClientSession(ctx context.Context, session *model.ClusterClientSession, ...) error
func UpsertClusterClientToken(ctx context.Context, token *model.ClusterClientToken, updateColumns []string) error
func UpsertClusterPollingOffset(ctx context.Context, clusterUUID string, pollingOffset time.Time, ...) error
func UpsertClusterServiceResult(ctx context.Context, result *model.ClusterServiceResult) error
func UpsertGlobalVariable(ctx context.Context, globvar *model.GlobalVariable, updateColumns []string) error
func UpsertWebhook(ctx context.Context, webhook *model.Webhook, updateColumns []string) error

Constants ¶

View Source

const (
	INIT_SLICE_CAP = 10
)

Variables ¶

View Source

var (
	ErrNoAffected = fmt.Errorf("sql: no affected")
	ErrNoRows     = sql.ErrNoRows
)

View Source

var Database func() *sql.DB = nil

View Source

var Driver func() excute.SqlExcutor = nil

Functions ¶

func CreateCluster ¶

func CreateCluster(ctx context.Context, model *model.Cluster) error

func CreateClusterClientSession ¶

func CreateClusterClientSession(ctx context.Context, session *model.ClusterClientSession) error

func CreateClusterClientToken ¶

func CreateClusterClientToken(ctx context.Context, token *model.ClusterClientToken) error

func CreateClusterServiceStatus ¶

func CreateClusterServiceStatus(ctx context.Context, status *model.ClusterServiceStatus) error

func CreateClusterServiceStatuses ¶

func CreateClusterServiceStatuses(ctx context.Context, statuses []model.ClusterServiceStatus) error

func CreateService ¶

func CreateService(ctx context.Context, newServicies []model.ServiceWithStatuses) error

func CreateWebhook ¶

func CreateWebhook(ctx context.Context, webhook *model.Webhook) error

func DeleteCluster ¶

func DeleteCluster(ctx context.Context, uuid string) error

func DeleteClusterClientSession ¶

func DeleteClusterClientSession(ctx context.Context, uuid string) error

func DeleteClusterClientToken ¶

func DeleteClusterClientToken(ctx context.Context, uuid string) error

func DeleteWebhook ¶

func DeleteWebhook(ctx context.Context, uuid string) error

func FindCluster ¶

func FindCluster(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, page stmt.PaginationStmt) ([]model.Cluster, error)

func FindClusterClientSession ¶

func FindClusterClientSession(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, page stmt.PaginationStmt) ([]model.ClusterClientSession, error)

func FindClusterClientToken ¶

func FindClusterClientToken(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, page stmt.PaginationStmt) ([]model.ClusterClientToken, error)

func FindClusterService ¶

func FindClusterService(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, page stmt.PaginationStmt) ([]model.ServiceWithStatuses, error)

func FindGlobalVariables ¶

func FindGlobalVariables(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt) ([]model.GlobalVariable, error)

func FindWebhook ¶

func FindWebhook(ctx context.Context, query stmt.ConditionStmt, order stmt.OrderStmt, page stmt.PaginationStmt) ([]model.Webhook, error)

func GetCluster ¶

func GetCluster(ctx context.Context, uuid string) (*model.Cluster, error)

func GetClusterClientSession ¶

func GetClusterClientSession(ctx context.Context, uuid string) (*model.ClusterClientSession, error)

func GetClusterClientToken ¶

func GetClusterClientToken(ctx context.Context, uuid string) (*model.ClusterClientToken, error)

func GetClusterClientTokenByAssertion ¶

func GetClusterClientTokenByAssertion(ctx context.Context, clusterUUID string, token_ string) (*model.ClusterClientToken, error)

func GetClusterClientTokenColumns ¶

func GetClusterClientTokenColumns(ctx context.Context, uuid string, columns map[string]interface{}) error

GetClusterClientTokenColumns

func GetClusterPollingOffset ¶

func GetClusterPollingOffset(ctx context.Context, clusterUUID string) (time.Time, error)

func GetClusterService ¶

func GetClusterService(ctx context.Context, clusterUUID, uuid string) (*model.ClusterService, error)

func GetClusterServiceResult ¶

func GetClusterServiceResult(ctx context.Context, clusterUUID, uuid string) (*model.ClusterServiceResult, error)

func GetClusterServiceResults ¶

func GetClusterServiceResults(ctx context.Context, clusterUUID, uuid string) ([]model.ClusterServiceResult, error)

func GetClusterServiceStatuses ¶

func GetClusterServiceStatuses(ctx context.Context, clusterUUID, uuid string) ([]model.ClusterServiceStatus, error)

func GetGlobalVariable ¶

func GetGlobalVariable(ctx context.Context, uuid string) (*model.GlobalVariable, error)

func GetTemplate ¶

func GetTemplate(ctx context.Context, uuid string) (*model.Template, error)

func GetWebhook ¶

func GetWebhook(ctx context.Context, uuid string) (*model.Webhook, error)

func IsExistsCluster ¶

func IsExistsCluster(ctx context.Context, uuid string) (bool, error)

func IsExistsClusterClientSession ¶

func IsExistsClusterClientSession(ctx context.Context, uuid string) (bool, error)

func PollClusterService ¶

func PollClusterService(ctx context.Context, clusterUUID string, offset time.Time, filter func(*model.ClusterService) bool) ([]model.ClusterService, error)

func UpsertCluster ¶

func UpsertCluster(ctx context.Context, cluster *model.Cluster, updateColumns []string) error

func UpsertClusterClientSession ¶

func UpsertClusterClientSession(ctx context.Context, session *model.ClusterClientSession, updateColumns []string) error

func UpsertClusterClientToken ¶

func UpsertClusterClientToken(ctx context.Context, token *model.ClusterClientToken, updateColumns []string) error

func UpsertClusterPollingOffset ¶

func UpsertClusterPollingOffset(ctx context.Context, clusterUUID string, pollingOffset time.Time, updated time.Time) error

func UpsertClusterServiceResult ¶

func UpsertClusterServiceResult(ctx context.Context, result *model.ClusterServiceResult) error

func UpsertGlobalVariable ¶

func UpsertGlobalVariable(ctx context.Context, globvar *model.GlobalVariable, updateColumns []string) error

func UpsertWebhook ¶

func UpsertWebhook(ctx context.Context, webhook *model.Webhook, updateColumns []string) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL