Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateFrameworkInfo ¶
func CreateFrameworkInfo() *mesos.FrameworkInfo
TODO add framework capbility, make following variables configurable
Types ¶
type MesosConnector ¶
type MesosConnector struct {
// mesos framework related
ClusterID string
Master string
MesosCallChan chan *sched.Call
// TODO make sure this chan doesn't explode
MesosEventChan chan *event.MesosEvent
Framework *mesos.FrameworkInfo
// contains filtered or unexported fields
}
func Instance ¶
func Instance() *MesosConnector
func NewMesosConnector ¶
func NewMesosConnector() *MesosConnector
type MesosHttpClient ¶
type MesosHttpClient struct {
StreamID string
// contains filtered or unexported fields
}
func NewHTTPClient ¶
func NewHTTPClient(addr, path string) *MesosHttpClient
func (*MesosHttpClient) Send ¶
func (c *MesosHttpClient) Send(payload []byte) (*http.Response, error)
func (*MesosHttpClient) SendAsJson ¶
Click to show internal directories.
Click to hide internal directories.