Versions in this module Expand all Collapse all v0 v0.1.9 Mar 20, 2017 v0.1.7 Mar 6, 2017 Changes in this version + const HTTP_KEEPALIVE_DURATION + const HTTP_TIMEOUT_DURATION + const MESOS_STREAM_KEY + const USER_AGENT + var SPECIAL_CHARACTER = regexp.MustCompile("([\\-\\.\\$\\*\\+\\?\\{\\}\\(\\)\\[\\]\\|]+)") + func NewReader(r io.Reader) io.Reader + type Connector struct + ClusterID string + FrameworkInfo *mesos.FrameworkInfo + MesosLeader string + MesosLeaderHttpClient *HttpClient + ReceiveChan chan *event.MesosEvent + SendChan chan *sched.Call + StreamCancelFun context.CancelFunc + StreamCtx context.Context + func Instance() *Connector + func NewConnector() *Connector + func (s *Connector) LeaderDetect() error + func (s *Connector) Reregister() error + func (s *Connector) Send(call *sched.Call) (*http.Response, error) + func (s *Connector) SetFrameworkInfoId(id string) + func (s *Connector) Start(ctx context.Context, errorChan chan error) + func (s *Connector) Subscribe(ctx context.Context) + type HttpClient struct + func NewHTTPClient(addr, path string) *HttpClient + func (c *HttpClient) Send(payload []byte) (*http.Response, error)
Go to main page