Documentation ¶
Index ¶
- func ControllerCreateConnector(c *gin.Context)
- func ControllerExecConnector(c *gin.Context)
- func ControllerGetConnector(c *gin.Context)
- func ControllerGetConnectorExecutor(c *gin.Context)
- func ControllerGetConnectorResult(c *gin.Context)
- func ControllerGetConnectors(c *gin.Context)
- func Exec(connector *Connector) (*executors.Executor, error)
- func GetLastConnectorExecutor(c *Connector) *executors.Executor
- func GetRedisConnectorConfKey(g string, c string) string
- func GetRedisConnectorKey(c *Connector) string
- func GetRedisConnectorsKey(c *Connector) string
- func GetRedisExecutorKey(c *Connector) string
- func GetRedisResultKey(c *Connector, e *executors.Executor) string
- func GetRedisrKey(g string, c string) string
- func InitSchedule(c *Connector)
- func RedisGetConnectors(group string) ([]string, error)
- func RedisGetLastExecutor(c *Connector) (string, error)
- func RedisSaveConnector(c *Connector) error
- func RedisSaveExecutor(c *Connector, exec *executors.Executor) error
- func SaveConnector(c *Connector)
- func SaveExecutor(c *Connector, exec *executors.Executor)
- type Connector
- type ConnectorRunner
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ControllerExecConnector ¶
func ControllerGetConnector ¶
func ControllerGetConnectors ¶
func GetRedisConnectorKey ¶
func GetRedisConnectorsKey ¶
func GetRedisExecutorKey ¶
func GetRedisrKey ¶
func InitSchedule ¶
func InitSchedule(c *Connector)
func RedisGetConnectors ¶
func RedisGetLastExecutor ¶
func RedisSaveConnector ¶
func SaveConnector ¶
func SaveConnector(c *Connector)
func SaveExecutor ¶
Types ¶
type Connector ¶
type Connector struct { Group string `json:"group"` Name string `json:"name"` ContainerConfig *dockerclient.ContainerConfig `json:"config"` Timeout int `json:"timeout,omitempty"` Refresh int `json:"refresh,omitempty"` }
func GetConnectors ¶
func NewConnector ¶
func (*Connector) GetContainerName ¶
Click to show internal directories.
Click to hide internal directories.