mesos_connector

Documentation

Index

• func CreateFrameworkInfo() *mesos.FrameworkInfo
• func NewReader(r io.Reader) io.Reader
• type MesosConnector
  • func Instance() *MesosConnector
  • func NewMesosConnector() *MesosConnector
  • func (s *MesosConnector) Send(call *sched.Call) (*http.Response, error)
  • func (s *MesosConnector) Start(ctx context.Context, mesosFailureChan chan error)
• type MesosHttpClient
  • func NewHTTPClient(addr, path string) *MesosHttpClient
  • func (c *MesosHttpClient) Send(payload []byte) (*http.Response, error)
  • func (c *MesosHttpClient) SendAsJson(call *mesosjson.Call) (*http.Response, error)

Functions

func CreateFrameworkInfo

func CreateFrameworkInfo() *mesos.FrameworkInfo

func NewReader

func NewReader(r io.Reader) io.Reader

NewReader returns an io.Reader that unpacks the data read from r out of RecordIO framing before returning it.

Types

type MesosConnector

type MesosConnector struct {
	// mesos framework related
	ClusterID 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

func (*MesosConnector) Send

func (s *MesosConnector) Send(call *sched.Call) (*http.Response, error)

func (*MesosConnector) Start

func (s *MesosConnector) Start(ctx context.Context, mesosFailureChan chan error)

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

func (c *MesosHttpClient) SendAsJson(call *mesosjson.Call) (*http.Response, error)