Versions in this module Expand all Collapse all v0 v0.0.2 Sep 30, 2015 v0.0.1 Sep 15, 2015 Changes in this version + const DefaultReadTimeout + const DefaultWriteTimeout + func UPIDBindingAddress(hostname string, bindingAddress net.IP) (string, error) + type Decoder interface + Cancel func(bool) + Err func() <-chan error + Requests func() <-chan *Request + func DecodeHTTP(w http.ResponseWriter, r *http.Request) Decoder + type HTTPTransporter struct + func NewHTTPTransporter(upid *upid.UPID, address net.IP) *HTTPTransporter + func (t *HTTPTransporter) Inject(ctx context.Context, msg *Message) error + func (t *HTTPTransporter) Install(msgName string) + func (t *HTTPTransporter) Recv() (*Message, error) + func (t *HTTPTransporter) Send(ctx context.Context, msg *Message) (sendError error) + func (t *HTTPTransporter) Start() <-chan error + func (t *HTTPTransporter) Stop(graceful bool) error + func (t *HTTPTransporter) UPID() *upid.UPID + type MesosMessenger struct + func New(upid *upid.UPID, t Transporter) *MesosMessenger + func NewHttp(upid *upid.UPID) *MesosMessenger + func NewHttpWithBindingAddress(upid *upid.UPID, address net.IP) *MesosMessenger + func (m *MesosMessenger) Install(handler MessageHandler, msg proto.Message) error + func (m *MesosMessenger) Route(ctx context.Context, upid *upid.UPID, msg proto.Message) error + func (m *MesosMessenger) Send(ctx context.Context, upid *upid.UPID, msg proto.Message) error + func (m *MesosMessenger) Start() error + func (m *MesosMessenger) Stop() error + func (m *MesosMessenger) UPID() *upid.UPID + type Message struct + Bytes []byte + Name string + ProtoMessage proto.Message + UPID *upid.UPID + func (m *Message) RequestURI() string + type MessageHandler func(from *upid.UPID, pbMsg proto.Message) + type Messenger interface + Install func(handler MessageHandler, msg proto.Message) error + Route func(ctx context.Context, from *upid.UPID, msg proto.Message) error + Send func(ctx context.Context, upid *upid.UPID, msg proto.Message) error + Start func() error + Stop func() error + UPID func() *upid.UPID + func ForHostname(proc *process.Process, hostname string, bindingAddress net.IP, port uint16, ...) (Messenger, error) + type MockedMessenger struct + func NewMockedMessenger() *MockedMessenger + func (m *MockedMessenger) Install(handler MessageHandler, msg proto.Message) error + func (m *MockedMessenger) Recv(from *upid.UPID, msg proto.Message) + func (m *MockedMessenger) Route(ctx context.Context, upid *upid.UPID, msg proto.Message) error + func (m *MockedMessenger) Send(ctx context.Context, upid *upid.UPID, msg proto.Message) error + func (m *MockedMessenger) Start() error + func (m *MockedMessenger) Stop() error + func (m *MockedMessenger) UPID() *upid.UPID + type Request struct + type Response struct + type Transporter interface + Inject func(ctx context.Context, msg *Message) error + Install func(messageName string) + Recv func() (*Message, error) + Send func(ctx context.Context, msg *Message) error + Start func() <-chan error + Stop func(graceful bool) error + UPID func() *upid.UPID
Go to main page