connectors

package

v0.0.0-...-3c6cd92 Latest Latest Go to latest Published: Jul 23, 2015 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/imax-pp/intools-engine

Links

Open Source Insights

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
- func GetConnector(group string, connector string) (*Connector, error)
- func GetConnectors(group string) []Connector
- func NewConnector(group string, name string) *Connector
- func RedisGetConnector(group string, connector string) (*Connector, error)
- func (c *Connector) GetContainerName() string
- func (c *Connector) GetJSON() string
- func (c *Connector) Init(image string, timeout int, refresh int, cmd []string)
- func (c *Connector) Run()
type ConnectorRunner

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ControllerCreateConnector ¶

func ControllerCreateConnector(c *gin.Context)

func ControllerExecConnector ¶

func ControllerExecConnector(c *gin.Context)

func ControllerGetConnector ¶

func ControllerGetConnector(c *gin.Context)

func ControllerGetConnectorExecutor ¶

func ControllerGetConnectorExecutor(c *gin.Context)

func ControllerGetConnectorResult ¶

func ControllerGetConnectorResult(c *gin.Context)

func ControllerGetConnectors ¶

func ControllerGetConnectors(c *gin.Context)

func Exec ¶

func Exec(connector *Connector) (*executors.Executor, error)

func GetLastConnectorExecutor ¶

func GetLastConnectorExecutor(c *Connector) *executors.Executor

func GetRedisConnectorConfKey ¶

func GetRedisConnectorConfKey(g string, c string) string

func GetRedisConnectorKey ¶

func GetRedisConnectorKey(c *Connector) string

func GetRedisConnectorsKey ¶

func GetRedisConnectorsKey(c *Connector) string

func GetRedisExecutorKey ¶

func GetRedisExecutorKey(c *Connector) string

func GetRedisResultKey ¶

func GetRedisResultKey(c *Connector, e *executors.Executor) string

func GetRedisrKey ¶

func GetRedisrKey(g string, c string) string

func InitSchedule ¶

func InitSchedule(c *Connector)

func RedisGetConnectors ¶

func RedisGetConnectors(group string) ([]string, error)

func RedisGetLastExecutor ¶

func RedisGetLastExecutor(c *Connector) (string, error)

func RedisSaveConnector ¶

func RedisSaveConnector(c *Connector) error

func RedisSaveExecutor ¶

func RedisSaveExecutor(c *Connector, exec *executors.Executor) error

func SaveConnector ¶

func SaveConnector(c *Connector)

func SaveExecutor ¶

func SaveExecutor(c *Connector, exec *executors.Executor)

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 GetConnector ¶

func GetConnector(group string, connector string) (*Connector, error)

func GetConnectors ¶

func GetConnectors(group string) []Connector

func NewConnector ¶

func NewConnector(group string, name string) *Connector

func RedisGetConnector ¶

func RedisGetConnector(group string, connector string) (*Connector, error)

func (*Connector) GetContainerName ¶

func (c *Connector) GetContainerName() string

func (*Connector) GetJSON ¶

func (c *Connector) GetJSON() string

func (*Connector) Init ¶

func (c *Connector) Init(image string, timeout int, refresh int, cmd []string)

func (*Connector) Run ¶

func (c *Connector) Run()

type ConnectorRunner ¶

type ConnectorRunner interface {
	Exec(connector *Connector) (*executors.Executor, error)
}

Source Files ¶

View all Source files

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