Documentation ¶
Index ¶
- Constants
- Variables
- func NewReader(r io.Reader) io.Reader
- type 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
Constants ¶
View Source
const ( HTTP_TIMEOUT_DURATION = 10 * time.Second HTTP_KEEPALIVE_DURATION = 30 * time.Second USER_AGENT = "swan/0.1" MESOS_STREAM_KEY = "swan/0.1" )
Variables ¶
View Source
var SPECIAL_CHARACTER = regexp.MustCompile("([\\-\\.\\$\\*\\+\\?\\{\\}\\(\\)\\[\\]\\|]+)")
Functions ¶
Types ¶
type Connector ¶
type Connector struct { ClusterID string MesosLeader string MesosLeaderHttpClient *HttpClient SendChan chan *sched.Call ReceiveChan chan *event.MesosEvent FrameworkInfo *mesos.FrameworkInfo StreamCtx context.Context StreamCancelFun context.CancelFunc // contains filtered or unexported fields }
func NewConnector ¶
func NewConnector() *Connector
func (*Connector) LeaderDetect ¶
func (*Connector) Reregister ¶
func (*Connector) SetFrameworkInfoId ¶
type HttpClient ¶
type HttpClient struct {
// contains filtered or unexported fields
}
func NewHTTPClient ¶
func NewHTTPClient(addr, path string) *HttpClient
Click to show internal directories.
Click to hide internal directories.