runners

package
v0.0.0-...-24596cf Latest Latest
Warning

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

 Go to latest Published: May 19, 2016 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Logger = log.NewDefaultLogger()

Functions

This section is empty.

Types

type DSE02xTaskRunner 

type DSE02xTaskRunner struct{}

func (*DSE02xTaskRunner) FillContext 

func (dtr *DSE02xTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*DSE02xTaskRunner) RunTask 

func (dtr *DSE02xTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type DSEMesos02xClient 

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

func NewDSEMesos02xClient 

func NewDSEMesos02xClient(api string) *DSEMesos02xClient

func (*DSEMesos02xClient) Add 

func (dmc *DSEMesos02xClient) Add(params map[string]string) ([]byte, error)

func (*DSEMesos02xClient) AddCluster 

func (dmc *DSEMesos02xClient) AddCluster(params map[string]string) ([]byte, error)

func (*DSEMesos02xClient) Start 

func (dmc *DSEMesos02xClient) Start(params map[string]string) ([]byte, error)

type DSEMesos02xNode 

type DSEMesos02xNode struct {
	Seed    bool                    `json:"seed"`
	State   string                  `json:"state"`
	DC      string                  `json:"dc"`
	ID      string                  `json:"id"`
	Mem     int                     `json:"mem"`
	Cpu     float64                 `json:"mem"`
	Rack    string                  `json:"rack"`
	Runtime *DSEMesos02xNodeRuntime `json:"runtime"`
}

type DSEMesos02xNodeReservation 

type DSEMesos02xNodeReservation struct {
	Cpus  float64        `json:"cpus"`
	Mem   int            `json:"mem"`
	Ports map[string]int `json:"ports"`
}

type DSEMesos02xNodeRuntime 

type DSEMesos02xNodeRuntime struct {
	Hostname    string                      `json:"hostname"`
	SlaveID     string                      `json:"slaveId"`
	ExecutorID  string                      `json:"executorId"`
	Attributes  map[string]string           `json:"attributes"`
	Reservation *DSEMesos02xNodeReservation `json:"reservation"`
	Seeds       []string                    `json:"seeds"`
	Address     string                      `json:"address"`
	TaskID      string                      `json:"taskId"`
}

type DSEMesos02xStartResponse 

type DSEMesos02xStartResponse struct {
	Status string             `json:"status"`
	Nodes  []*DSEMesos02xNode `json:"nodes"`
}

type DSEMesosClient 

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

func NewDSEMesosClient 

func NewDSEMesosClient(api string) *DSEMesosClient

func (*DSEMesosClient) Add 

func (dmc *DSEMesosClient) Add(params map[string]string) (map[string]interface{}, error)

func (*DSEMesosClient) Start 

func (dmc *DSEMesosClient) Start(params map[string]string) (map[string]interface{}, error)

type DSETaskRunner 

type DSETaskRunner struct{}

func (*DSETaskRunner) FillContext 

func (dtr *DSETaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*DSETaskRunner) RunTask 

func (dtr *DSETaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type ElasticsearchClient 

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

func NewElasticsearchClient 

func NewElasticsearchClient(api string) *ElasticsearchClient

func (*ElasticsearchClient) AwaitRunning 

func (c *ElasticsearchClient) AwaitRunning(awaitTimeout time.Duration, backoffTimeout time.Duration) error

func (*ElasticsearchClient) GetTasks 

func (c *ElasticsearchClient) GetTasks() ([]*ElasticsearchTask, error)

type ElasticsearchTask 

type ElasticsearchTask struct {
	ID               string `json:"id"`
	State            string `json:"state"`
	Name             string `json:"name"`
	Version          string `json:"version"`
	StartedAt        string `json:"started_at"`
	HttpAddress      string `json:"http_address"`
	TransportAddress string `json:"transport_address"`
	Hostname         string `json:"hostname"`
}

type ElasticsearchTaskRunner 

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

func NewElasticsearchTaskRunner 

func NewElasticsearchTaskRunner(awaitTimeout time.Duration, backoffTimeout time.Duration) *ElasticsearchTaskRunner

func (*ElasticsearchTaskRunner) FillContext 

func (etr *ElasticsearchTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*ElasticsearchTaskRunner) RunTask 

func (etr *ElasticsearchTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type ExhibitorMesosClient 

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

func NewExhibitorMesosClient 

func NewExhibitorMesosClient(api string) *ExhibitorMesosClient

func (*ExhibitorMesosClient) Add 

func (emc *ExhibitorMesosClient) Add(params map[string]string) (*exhibitorCluster, error)

func (*ExhibitorMesosClient) AwaitZookeeperRunning 

func (emc *ExhibitorMesosClient) AwaitZookeeperRunning() error

func (*ExhibitorMesosClient) Start 

func (emc *ExhibitorMesosClient) Start(params map[string]string) (*exhibitorCluster, error)

func (*ExhibitorMesosClient) Status 

func (emc *ExhibitorMesosClient) Status() (*exhibitorClusterStatus, error)

func (*ExhibitorMesosClient) Update 

func (emc *ExhibitorMesosClient) Update(params map[string]string) (*exhibitorCluster, error)

type ExhibitorTaskRunner 

type ExhibitorTaskRunner struct{}

func (*ExhibitorTaskRunner) FillContext 

func (etr *ExhibitorTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*ExhibitorTaskRunner) RunTask 

func (etr *ExhibitorTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type GoKafkaClientMesosClient 

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

func NewGoKafkaClientMesosClient 

func NewGoKafkaClientMesosClient(api string) *GoKafkaClientMesosClient

func (*GoKafkaClientMesosClient) Add 

func (c *GoKafkaClientMesosClient) Add(params map[string]string) error

func (*GoKafkaClientMesosClient) Start 

func (c *GoKafkaClientMesosClient) Start(params map[string]string) error

func (*GoKafkaClientMesosClient) Update 

func (c *GoKafkaClientMesosClient) Update(params map[string]string) error

type GoKafkaClientTaskRunner 

type GoKafkaClientTaskRunner struct{}

func (*GoKafkaClientTaskRunner) FillContext 

func (tr *GoKafkaClientTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*GoKafkaClientTaskRunner) RunTask 

func (tr *GoKafkaClientTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type KafkaMesosClient 

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

func NewKafkaMesosClient 

func NewKafkaMesosClient(api string) *KafkaMesosClient

func (*KafkaMesosClient) Add 

func (kmc *KafkaMesosClient) Add(params map[string]string) error

func (*KafkaMesosClient) Start 

func (kmc *KafkaMesosClient) Start(params map[string]string) error

type KafkaTaskRunner 

type KafkaTaskRunner struct{}

func (*KafkaTaskRunner) FillContext 

func (ktr *KafkaTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*KafkaTaskRunner) RunTask 

func (ktr *KafkaTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type StatsdMesosClient 

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

func NewStatsdMesosClient 

func NewStatsdMesosClient(api string) *StatsdMesosClient

func (*StatsdMesosClient) Start 

func (smc *StatsdMesosClient) Start(params map[string]string) error

func (*StatsdMesosClient) Update 

func (smc *StatsdMesosClient) Update(params map[string]string) error

type StatsdTaskRunner 

type StatsdTaskRunner struct{}

func (*StatsdTaskRunner) FillContext 

func (str *StatsdTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*StatsdTaskRunner) RunTask 

func (str *StatsdTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type SyslogMesosClient 

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

func NewSyslogMesosClient 

func NewSyslogMesosClient(api string) *SyslogMesosClient

func (*SyslogMesosClient) Start 

func (smc *SyslogMesosClient) Start(params map[string]string) error

func (*SyslogMesosClient) Update 

func (smc *SyslogMesosClient) Update(params map[string]string) error

type SyslogTaskRunner 

type SyslogTaskRunner struct{}

func (*SyslogTaskRunner) FillContext 

func (str *SyslogTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*SyslogTaskRunner) RunTask 

func (str *SyslogTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

type ZipkinMesosClient 

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

func NewZipkinMesosClient 

func NewZipkinMesosClient(api string) *ZipkinMesosClient

func (*ZipkinMesosClient) Add 

func (zmc *ZipkinMesosClient) Add(params map[string]string) (map[string]interface{}, error)

func (*ZipkinMesosClient) Start 

func (zmc *ZipkinMesosClient) Start(params map[string]string) (map[string]interface{}, error)

type ZipkinTaskRunner 

type ZipkinTaskRunner struct{}

func (*ZipkinTaskRunner) FillContext 

func (ztr *ZipkinTaskRunner) FillContext(context *framework.Variables, application *framework.Application, task marathon.Task) error

func (*ZipkinTaskRunner) RunTask 

func (ztr *ZipkinTaskRunner) RunTask(context *framework.Variables, application *framework.Application, task map[string]string) error

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.