syscol

Documentation

Index

• Constants
• Variables
• func InitLogging(level string) error
• type ApiRequest
  • func NewApiRequest(url string) *ApiRequest
  • func (r *ApiRequest) AddParam(key string, value interface{})
  • func (r *ApiRequest) Get() *ApiResponse
• type ApiResponse
  • func NewApiResponse(success bool, message string) *ApiResponse
• type Cluster
  • func NewCluster() *Cluster
  • func (c *Cluster) Add(slave string, task *mesos.TaskInfo)
  • func (c *Cluster) Exists(slave string) bool
  • func (c *Cluster) GetAllTasks() []*mesos.TaskInfo
  • func (c *Cluster) Remove(slave string)
• type Executor
  • func (e *Executor) Disconnected(executor.ExecutorDriver)
  • func (e *Executor) Error(driver executor.ExecutorDriver, message string)
  • func (e *Executor) FrameworkMessage(driver executor.ExecutorDriver, message string)
  • func (e *Executor) KillTask(driver executor.ExecutorDriver, id *mesos.TaskID)
  • func (e *Executor) LaunchTask(driver executor.ExecutorDriver, task *mesos.TaskInfo)
  • func (e *Executor) Registered(driver executor.ExecutorDriver, executor *mesos.ExecutorInfo, ...)
  • func (e *Executor) Reregistered(driver executor.ExecutorDriver, slave *mesos.SlaveInfo)
  • func (e *Executor) Shutdown(driver executor.ExecutorDriver)
• type HttpServer
  • func NewHttpServer(address string) *HttpServer
  • func (hs *HttpServer) Start()
• type MetricsReporter
  • func NewMetricsReporter(slaveID string, host string, port int32, namespace string, ...) *MetricsReporter
  • func (mr *MetricsReporter) GetMetrics() (map[string]interface{}, error)
  • func (mr *MetricsReporter) Start()
  • func (mr *MetricsReporter) Stop()
• type Scheduler
  • func (s *Scheduler) Disconnected(scheduler.SchedulerDriver)
  • func (s *Scheduler) Error(driver scheduler.SchedulerDriver, message string)
  • func (s *Scheduler) ExecutorLost(driver scheduler.SchedulerDriver, executor *mesos.ExecutorID, ...)
  • func (s *Scheduler) FrameworkMessage(driver scheduler.SchedulerDriver, executor *mesos.ExecutorID, ...)
  • func (s *Scheduler) OfferRescinded(driver scheduler.SchedulerDriver, id *mesos.OfferID)
  • func (s *Scheduler) Registered(driver scheduler.SchedulerDriver, id *mesos.FrameworkID, ...)
  • func (s *Scheduler) Reregistered(driver scheduler.SchedulerDriver, master *mesos.MasterInfo)
  • func (s *Scheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesos.Offer)
  • func (s *Scheduler) SetActive(active bool)
  • func (s *Scheduler) Shutdown(driver *scheduler.MesosSchedulerDriver)
  • func (s *Scheduler) SlaveLost(driver scheduler.SchedulerDriver, slave *mesos.SlaveID)
  • func (s *Scheduler) Start() error
  • func (s *Scheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus)
• type SlaveMetrics

Constants

const (
	TransformNone = "none"
	TransformAvro = "avro"
)

Variables

var Config *config = &config{
	FrameworkName:     "syscol",
	FrameworkRole:     "*",
	Cpus:              0.1,
	Mem:               64,
	ReportingInterval: 1 * time.Second,
	Transform:         "none",
	LogLevel:          "info",
}

var Logger log.LoggerInterface

Functions

func InitLogging

func InitLogging(level string) error

Types

type ApiRequest

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

func NewApiRequest

func NewApiRequest(url string) *ApiRequest

func (*ApiRequest) AddParam

func (r *ApiRequest) AddParam(key string, value interface{})

func (*ApiRequest) Get

func (r *ApiRequest) Get() *ApiResponse

type ApiResponse

type ApiResponse struct {
	Success bool
	Message string
}

func NewApiResponse

func NewApiResponse(success bool, message string) *ApiResponse

type Cluster

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

func NewCluster

func NewCluster() *Cluster

func (*Cluster) Add

func (c *Cluster) Add(slave string, task *mesos.TaskInfo)

func (*Cluster) Exists

func (c *Cluster) Exists(slave string) bool

func (*Cluster) GetAllTasks

func (c *Cluster) GetAllTasks() []*mesos.TaskInfo

func (*Cluster) Remove

func (c *Cluster) Remove(slave string)

type Executor

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

func (*Executor) Disconnected

func (e *Executor) Disconnected(executor.ExecutorDriver)

func (*Executor) Error

func (e *Executor) Error(driver executor.ExecutorDriver, message string)

func (*Executor) FrameworkMessage

func (e *Executor) FrameworkMessage(driver executor.ExecutorDriver, message string)

func (*Executor) KillTask

func (e *Executor) KillTask(driver executor.ExecutorDriver, id *mesos.TaskID)

func (*Executor) LaunchTask

func (e *Executor) LaunchTask(driver executor.ExecutorDriver, task *mesos.TaskInfo)

func (*Executor) Registered

func (e *Executor) Registered(driver executor.ExecutorDriver, executor *mesos.ExecutorInfo, framework *mesos.FrameworkInfo, slave *mesos.SlaveInfo)

func (*Executor) Reregistered

func (e *Executor) Reregistered(driver executor.ExecutorDriver, slave *mesos.SlaveInfo)

func (*Executor) Shutdown

func (e *Executor) Shutdown(driver executor.ExecutorDriver)

type HttpServer

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

func NewHttpServer

func NewHttpServer(address string) *HttpServer

func (*HttpServer) Start

func (hs *HttpServer) Start()

type MetricsReporter

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

func NewMetricsReporter

func NewMetricsReporter(slaveID string, host string, port int32, namespace string, reportingInterval time.Duration, producer *producer.KafkaProducer, topic string, transform string) *MetricsReporter

func (*MetricsReporter) GetMetrics

func (mr *MetricsReporter) GetMetrics() (map[string]interface{}, error)

func (*MetricsReporter) Start

func (mr *MetricsReporter) Start()

func (*MetricsReporter) Stop

func (mr *MetricsReporter) Stop()

type Scheduler

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

func (*Scheduler) Disconnected

func (s *Scheduler) Disconnected(scheduler.SchedulerDriver)

func (*Scheduler) Error

func (s *Scheduler) Error(driver scheduler.SchedulerDriver, message string)

func (*Scheduler) ExecutorLost

func (s *Scheduler) ExecutorLost(driver scheduler.SchedulerDriver, executor *mesos.ExecutorID, slave *mesos.SlaveID, status int)

func (*Scheduler) FrameworkMessage

func (s *Scheduler) FrameworkMessage(driver scheduler.SchedulerDriver, executor *mesos.ExecutorID, slave *mesos.SlaveID, message string)

func (*Scheduler) OfferRescinded

func (s *Scheduler) OfferRescinded(driver scheduler.SchedulerDriver, id *mesos.OfferID)

func (*Scheduler) Registered

func (s *Scheduler) Registered(driver scheduler.SchedulerDriver, id *mesos.FrameworkID, master *mesos.MasterInfo)

func (*Scheduler) Reregistered

func (s *Scheduler) Reregistered(driver scheduler.SchedulerDriver, master *mesos.MasterInfo)

func (*Scheduler) ResourceOffers

func (s *Scheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesos.Offer)

func (*Scheduler) SetActive

func (s *Scheduler) SetActive(active bool)

func (*Scheduler) Shutdown

func (s *Scheduler) Shutdown(driver *scheduler.MesosSchedulerDriver)

func (*Scheduler) SlaveLost

func (s *Scheduler) SlaveLost(driver scheduler.SchedulerDriver, slave *mesos.SlaveID)

func (*Scheduler) Start

func (s *Scheduler) Start() error

func (*Scheduler) StatusUpdate

func (s *Scheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus)

type SlaveMetrics

type SlaveMetrics struct {
	SlaveID   string
	Hostname  string
	Port      int32
	Namespace string
	Timestamp int64
	Metrics   map[string]interface{}
}