connectors

package

v0.0.0-...-d86dc6f Latest Latest Go to latest Published: Aug 13, 2018 License: Apache-2.0 Imports: 14 Imported by: 3

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/soprasteria/intools-engine

Links

Open Source Insights

Documentation ¶

Index ¶

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) string
func GetRedisrKey(g string, c string) string
func RedisGetConnectors(group string) ([]string, error)
func RedisGetLastExecutor(c *Connector) (string, error)
func RedisRemoveConnector(c *Connector) error
func RedisSaveConnector(c *Connector) error
func RedisSaveExecutor(c *Connector, exec *executors.Executor) error
func RemoveConnector(c *Connector)
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) Id() string
- func (c *Connector) Init(image string, timeout uint, refresh uint, cmd []string)
- func (c *Connector) Run()
type ConnectorScheduler
- func NewConnectorScheduler() ConnectorScheduler
- func (ct ConnectorScheduler) RemoveJob(conn *Connector)
- func (ct ConnectorScheduler) SetJob(conn *Connector)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

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) string

func GetRedisrKey ¶

func GetRedisrKey(g string, c string) string

func RedisGetConnectors ¶

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

func RedisGetLastExecutor ¶

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

func RedisRemoveConnector ¶

func RedisRemoveConnector(c *Connector) error

func RedisSaveConnector ¶

func RedisSaveConnector(c *Connector) error

func RedisSaveExecutor ¶

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

func RemoveConnector ¶

func RemoveConnector(c *Connector)

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 *dockerapi.ContainerOptions `json:"config"`
	Timeout         uint                        `json:"timeout,omitempty"`
	Refresh         uint                        `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) Id ¶

func (c *Connector) Id() string

func (*Connector) Init ¶

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

func (*Connector) Run ¶

func (c *Connector) Run()

type ConnectorScheduler ¶

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

var Scheduler ConnectorScheduler

func NewConnectorScheduler ¶

func NewConnectorScheduler() ConnectorScheduler

func (ConnectorScheduler) RemoveJob ¶

func (ct ConnectorScheduler) RemoveJob(conn *Connector)

func (ConnectorScheduler) SetJob ¶

func (ct ConnectorScheduler) SetJob(conn *Connector)

Source Files ¶

View all Source files

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