connection

Aug 9, 2016

Changes in this version

+ type Connection struct

+ ID string

+ LocalSubject string

+ Provider string

+ RemoteSubject string

+ func (c *Connection) GetID() string

+ func (c *Connection) GetLocalSubject() string

+ func (c *Connection) GetProvider() string

+ func (c *Connection) GetRemoteSubject() string

+ type HTTPManager struct

+ Client *http.Client

+ Dry bool

+ Endpoint *url.URL

+ func (m *HTTPManager) Create(connection *Connection) error

+ func (m *HTTPManager) Delete(id string) error

+ func (m *HTTPManager) FindAllByLocalSubject(subject string) ([]Connection, error)

+ func (m *HTTPManager) FindByRemoteSubject(provider, subject string) (*Connection, error)

+ func (m *HTTPManager) Get(id string) (*Connection, error)

+ type Handler struct

+ H herodot.Herodot

+ Manager Manager

+ W firewall.Firewall

+ func (h *Handler) Create(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (h *Handler) Delete(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (h *Handler) FindLocal(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (h *Handler) FindRemote(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (h *Handler) Get(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (h *Handler) SetRoutes(r *httprouter.Router)

+ type Manager interface

+ Create func(c *Connection) error

+ Delete func(id string) error

+ FindAllByLocalSubject func(subject string) ([]Connection, error)

+ FindByRemoteSubject func(provider, subject string) (*Connection, error)

+ Get func(id string) (*Connection, error)

+ type MemoryManager struct

+ Connections map[string]Connection

+ func NewMemoryManager() *MemoryManager

+ func (m *MemoryManager) Create(c *Connection) error

+ func (m *MemoryManager) Delete(id string) error

+ func (m *MemoryManager) FindAllByLocalSubject(subject string) ([]Connection, error)

+ func (m *MemoryManager) FindByRemoteSubject(provider, subject string) (*Connection, error)

+ func (m *MemoryManager) Get(id string) (*Connection, error)

+ type RethinkManager struct

+ Connections map[string]Connection

+ Session *r.Session

+ Table r.Term

+ func (m *RethinkManager) ColdStart() error

+ func (m *RethinkManager) Create(c *Connection) error

+ func (m *RethinkManager) Delete(id string) error

+ func (m *RethinkManager) FindAllByLocalSubject(subject string) ([]Connection, error)

+ func (m *RethinkManager) FindByRemoteSubject(provider, subject string) (*Connection, error)

+ func (m *RethinkManager) Get(id string) (*Connection, error)

+ func (m *RethinkManager) Watch(ctx context.Context)