http

package

Go to main page

Versions in this module

v0

v0.22.0

Mar 21, 2019

v0.20.1

Dec 17, 2018

Changes in this version

+ const DefaultUserRole

+ func Authenticate(backend AuthenticationBackend, w http.ResponseWriter, ...) (string, error)

+ func SetTLSHeader(w http.ResponseWriter, r *http.Request)

+ func Unauthorized(w http.ResponseWriter, r *http.Request)

type AuthenticationOpts

+ Cookie map[string]string

v0.19.1

Sep 14, 2018

Changes in this version

+ func AuthCookie(token, path string) *http.Cookie

+ func GetTLSConfig(setupRootCA bool) (*tls.Config, error)

+ func NoAuthenticationWrap(wrapped auth.AuthenticatedHandlerFunc) http.HandlerFunc

+ func SetAuthHeaders(headers *http.Header, authOpts *AuthenticationOpts)

type AuthenticationBackend

+ func NewAuthenticationBackendByName(name string) (backend AuthenticationBackend, err error)

+ DefaultUserRole func(user string) string

+ Name func() string

+ SetDefaultUserRole func(role string)

type AuthenticationOpts

+ Token string

type BasicAuthenticationBackend

+ func (b *BasicAuthenticationBackend) DefaultUserRole(user string) string

+ func (b *BasicAuthenticationBackend) Name() string

+ func (b *BasicAuthenticationBackend) SetDefaultUserRole(role string)

+ type HtpasswdMapProvider struct

+ func NewHtpasswdMapProvider(users map[string]string) *HtpasswdMapProvider

+ func (h *HtpasswdMapProvider) AddUser(user, password string)

+ func (h *HtpasswdMapProvider) SecretProvider() auth.SecretProvider

type KeystoneAuthenticationBackend

+ func (b *KeystoneAuthenticationBackend) DefaultUserRole(user string) string

+ func (b *KeystoneAuthenticationBackend) Name() string

+ func (b *KeystoneAuthenticationBackend) SetDefaultUserRole(role string)

type NoAuthenticationBackend

+ func (b *NoAuthenticationBackend) SetDefaultUserRole(role string)

+ func (h *NoAuthenticationBackend) DefaultUserRole(user string) string

+ func (h *NoAuthenticationBackend) Name() string

type Server

+ AuthBackend AuthenticationBackend

+ func (s *Server) AddGlobalVar(key string, v interface{})

+ func (s *Server) RegisterLoginRoute(authBackend AuthenticationBackend)

+ func (s *Server) ServeIndex(w http.ResponseWriter, r *auth.AuthenticatedRequest)

v0.18.0

Jun 21, 2018

Changes in this version

+ const JsonProtocol

+ const ProtobufProtocol

+ const WildcardNamespace

type NoAuthenticationBackend

+ func (h *NoAuthenticationBackend) AuthType() string

type WSClient

+ func (c *WSClient) UpgradeToWSStructSpeaker() *WSStructSpeaker

type WSConn

+ func (c *WSConn) GetClientProtocol() string

type WSConnStatus

+ ClientProtocol string

type WSSpeaker

+ GetClientProtocol func() string

+ type WSSpeakerStructMessageDispatcher interface

+ AddStructMessageHandler func(h WSSpeakerStructMessageHandler, namespaces []string)

+ type WSSpeakerStructMessageHandler interface

+ OnWSStructMessage func(c WSSpeaker, m *WSStructMessage)

+ type WSStructClientPool struct

+ func NewWSStructClientPool(name string) *WSStructClientPool

+ func (a *WSStructClientPool) AddClient(c WSSpeaker) error

+ func (d WSStructClientPool) AddStructMessageHandler(h WSSpeakerStructMessageHandler, namespaces []string)

+ func (d WSStructClientPool) AddStructSpeaker(c *WSStructSpeaker)

+ func (s *WSStructClientPool) Request(host string, request *WSStructMessage, timeout time.Duration) (*WSStructMessage, error)

+ type WSStructMessage struct

+ JsonObj *json.RawMessage

+ Namespace string

+ ProtobufObj []byte

+ Protocol string

+ Status int64

+ Type string

+ UUID string

+ func NewWSStructMessage(ns string, tp string, v interface{}, uuids ...string) *WSStructMessage

+ func (g *WSStructMessage) Debug() string

+ func (g *WSStructMessage) DecodeObj(obj interface{}) error

+ func (g *WSStructMessage) Reply(v interface{}, kind string, status int) *WSStructMessage

+ func (g *WSStructMessage) UnmarshalObj(obj interface{}) error

+ func (g WSStructMessage) Bytes(protocol string) []byte

+ type WSStructMessageJSON struct

+ Namespace string

+ Obj *json.RawMessage

+ Status int64

+ Type string

+ UUID string

+ func (g *WSStructMessageJSON) Marshal() []byte

+ type WSStructServer struct

+ func NewWSStructServer(server *WSServer) *WSStructServer

+ func (d WSStructServer) AddStructMessageHandler(h WSSpeakerStructMessageHandler, namespaces []string)

+ func (d WSStructServer) AddStructSpeaker(c *WSStructSpeaker)

+ func (s *WSStructServer) OnConnected(c WSSpeaker)

+ func (s *WSStructServer) OnDisconnected(c WSSpeaker)

+ func (s *WSStructServer) OnMessage(c WSSpeaker, m WSMessage)

+ func (s *WSStructServer) Request(host string, request *WSStructMessage, timeout time.Duration) (*WSStructMessage, error)

+ func (s WSStructServer) AddClient(c WSSpeaker) error

+ type WSStructSpeaker struct

+ func (a WSStructSpeaker) AddStructMessageHandler(h WSSpeakerStructMessageHandler, namespaces []string)

+ func (p WSStructSpeaker) OnConnected(c WSSpeaker)

+ func (p WSStructSpeaker) OnDisconnected(c WSSpeaker)

+ func (s *WSStructSpeaker) OnMessage(c WSSpeaker, m WSMessage)

+ func (s *WSStructSpeaker) Request(m *WSStructMessage, timeout time.Duration) (*WSStructMessage, error)

+ func (s *WSStructSpeaker) Send(m WSMessage)

+ type WSStructSpeakerPool interface

+ Request func(host string, request *WSStructMessage, timeout time.Duration) (*WSStructMessage, error)

v0.16.0

Jan 29, 2018

Changes in this version

+ const BulkMsgType

+ const WilcardNamespace

+ var DefaultRequestTimeout = 10 * time.Second

+ var ErrWrongCredentials = errors.New("Wrong credentials")

type AuthenticationClient

+ Url *url.URL

+ func (c *AuthenticationClient) AuthCookies() []*http.Cookie

+ type ConnectionType int

+ const ExtraAssetPrefix

+ const TCP

+ const TLS

+ type DefaultWSSpeakerEventHandler struct

+ func (d *DefaultWSSpeakerEventHandler) OnConnected(c WSSpeaker)

+ func (d *DefaultWSSpeakerEventHandler) OnDisconnected(c WSSpeaker)

+ func (d *DefaultWSSpeakerEventHandler) OnMessage(c WSSpeaker, m WSMessage)

+ type ExtraAsset struct

+ Content []byte

+ Ext string

+ Filename string

type Server

+ CnxType ConnectionType

+ Host string

+ ServiceType common.ServiceType

+ func (s *Server) Listen() error

+ func (s *Server) Serve()

+ type WSBulkMessage []json.RawMessage

type WSClient

+ AuthClient *AuthenticationClient

+ Path string

+ func NewWSClient(host string, clientType common.ServiceType, url *url.URL, ...) *WSClient

+ func NewWSClientFromConfig(clientType common.ServiceType, url *url.URL, authClient *AuthenticationClient, ...) *WSClient

+ func (c *WSClient) Connect()

+ func (c *WSClient) UpgradeToWSJSONSpeaker() *WSJSONSpeaker

+ type WSClientPool struct

+ func NewWSClientPool(name string) *WSClientPool

+ func (s *WSClientPool) ConnectAll()

+ type WSConn struct

+ func (c *WSConn) AddEventHandler(h WSSpeakerEventHandler)

+ func (c *WSConn) Connect()

+ func (c *WSConn) Disconnect()

+ func (c *WSConn) GetAddrPort() (string, int)

+ func (c *WSConn) GetHeaders() http.Header

+ func (c *WSConn) GetHost() string

+ func (c *WSConn) GetServiceType() common.ServiceType

+ func (c *WSConn) GetStatus() WSConnStatus

+ func (c *WSConn) GetURL() *url.URL

+ func (c *WSConn) IsConnected() bool

+ func (c *WSConn) SendMessage(m WSMessage) error

+ func (c *WSConn) SendRaw(b []byte) error

+ type WSConnState int32

+ func (s *WSConnState) MarshalJSON() ([]byte, error)

+ func (s *WSConnState) UnmarshalJSON(b []byte) error

+ type WSConnStatus struct

+ Addr string

+ ConnectTime time.Time

+ Host string

+ Port int

+ ServiceType common.ServiceType

+ State *WSConnState

+ Url *url.URL

+ type WSIncomerHandler func(*websocket.Conn, *auth.AuthenticatedRequest) WSSpeaker

+ type WSJSONClientPool struct

+ func NewWSJSONClientPool(name string) *WSJSONClientPool

+ func (a *WSJSONClientPool) AddClient(c WSSpeaker) error

+ func (d WSJSONClientPool) AddJSONMessageHandler(h WSSpeakerJSONMessageHandler, namespaces []string)

+ func (d WSJSONClientPool) AddJSONSpeaker(c *WSJSONSpeaker)

+ func (s *WSJSONClientPool) Request(host string, request *WSJSONMessage, timeout time.Duration) (*WSJSONMessage, error)

+ type WSJSONMessage struct

+ Namespace string

+ Obj *json.RawMessage

+ Status int

+ Type string

+ UUID string

+ func NewWSJSONMessage(ns string, tp string, v interface{}, uuids ...string) *WSJSONMessage

+ func (g *WSJSONMessage) Reply(v interface{}, kind string, status int) *WSJSONMessage

+ func (g WSJSONMessage) Bytes() []byte

+ func (g WSJSONMessage) Marshal() []byte

+ type WSJSONServer struct

+ func NewWSJSONServer(server *WSServer) *WSJSONServer

+ func (d WSJSONServer) AddJSONMessageHandler(h WSSpeakerJSONMessageHandler, namespaces []string)

+ func (d WSJSONServer) AddJSONSpeaker(c *WSJSONSpeaker)

+ func (s *WSJSONServer) OnConnected(c WSSpeaker)

+ func (s *WSJSONServer) OnDisconnected(c WSSpeaker)

+ func (s *WSJSONServer) OnMessage(c WSSpeaker, m WSMessage)

+ func (s *WSJSONServer) Request(host string, request *WSJSONMessage, timeout time.Duration) (*WSJSONMessage, error)

+ func (s WSJSONServer) AddClient(c WSSpeaker) error

+ type WSJSONSpeaker struct

+ func (a WSJSONSpeaker) AddJSONMessageHandler(h WSSpeakerJSONMessageHandler, namespaces []string)

+ func (p WSJSONSpeaker) OnConnected(c WSSpeaker)

+ func (p WSJSONSpeaker) OnDisconnected(c WSSpeaker)

+ func (s *WSJSONSpeaker) OnMessage(c WSSpeaker, m WSMessage)

+ func (s *WSJSONSpeaker) Request(m *WSJSONMessage, timeout time.Duration) (*WSJSONMessage, error)

+ func (s *WSJSONSpeaker) Send(m WSMessage)

+ type WSJSONSpeakerPool interface

+ Request func(host string, request *WSJSONMessage, timeout time.Duration) (*WSJSONMessage, error)

+ type WSMasterElection struct

+ func NewWSMasterElection(pool WSSpeakerPool) *WSMasterElection

+ func (a *WSMasterElection) AddEventHandler(eventHandler WSMasterEventHandler)

+ func (a *WSMasterElection) GetMaster() WSSpeaker

+ func (a *WSMasterElection) OnConnected(c WSSpeaker)

+ func (a *WSMasterElection) OnDisconnected(c WSSpeaker)

+ func (a *WSMasterElection) SendMessageToMaster(m WSMessage)

+ type WSMasterEventHandler interface

+ OnNewMaster func(c WSSpeaker)

type WSMessage

+ Bytes func() []byte

+ type WSPool struct

+ func (s *WSPool) AddClient(c WSSpeaker) error

+ func (s *WSPool) AddEventHandler(h WSSpeakerEventHandler)

+ func (s *WSPool) BroadcastMessage(m WSMessage)

+ func (s *WSPool) DisconnectAll()

+ func (s *WSPool) GetName() string

+ func (s *WSPool) GetSpeakerByHost(host string) WSSpeaker

+ func (s *WSPool) GetSpeakers() (speakers []WSSpeaker)

+ func (s *WSPool) GetSpeakersByType(serviceType common.ServiceType) (speakers []WSSpeaker)

+ func (s *WSPool) GetStatus() map[string]WSConnStatus

+ func (s *WSPool) OnConnected(c WSSpeaker)

+ func (s *WSPool) OnDisconnected(c WSSpeaker)

+ func (s *WSPool) OnMessage(c WSSpeaker, m WSMessage)

+ func (s *WSPool) PickConnectedSpeaker() WSSpeaker

+ func (s *WSPool) QueueBroadcastMessage(m WSMessage)

+ func (s *WSPool) RemoveClient(c WSSpeaker)

+ func (s *WSPool) Run()

+ func (s *WSPool) SendMessageTo(m WSMessage, host string) error

+ func (s *WSPool) Start()

+ func (s *WSPool) Stop()

+ type WSRawMessage []byte

+ func (m WSRawMessage) Bytes() []byte

type WSServer

+ func (s WSServer) AddClient(c WSSpeaker) error

+ func (s WSServer) OnDisconnected(c WSSpeaker)

+ type WSSpeaker interface

+ AddEventHandler func(WSSpeakerEventHandler)

+ Connect func()

+ Disconnect func()

+ GetAddrPort func() (string, int)

+ GetHeaders func() http.Header

+ GetHost func() string

+ GetServiceType func() common.ServiceType

+ GetStatus func() WSConnStatus

+ GetURL func() *url.URL

+ IsConnected func() bool

+ SendMessage func(m WSMessage) error

+ type WSSpeakerEventHandler interface

+ OnConnected func(c WSSpeaker)

+ OnDisconnected func(c WSSpeaker)

+ OnMessage func(c WSSpeaker, m WSMessage)

+ type WSSpeakerJSONMessageDispatcher interface

+ AddJSONMessageHandler func(h WSSpeakerJSONMessageHandler, namespaces []string)

+ type WSSpeakerJSONMessageHandler interface

+ OnWSJSONMessage func(c WSSpeaker, m *WSJSONMessage)

+ type WSSpeakerPool interface

+ AddClient func(c WSSpeaker) error

+ AddEventHandler func(h WSSpeakerEventHandler)

+ BroadcastMessage func(m WSMessage)

+ GetSpeakers func() []WSSpeaker

+ PickConnectedSpeaker func() WSSpeaker

+ QueueBroadcastMessage func(m WSMessage)

+ RemoveClient func(c WSSpeaker)

+ SendMessageTo func(m WSMessage, host string) error

v0.9.0

Jan 27, 2017

Changes in this version

type KeystoneAuthenticationBackend

+ Domain string

+ type User struct

+ ID string

+ Name string

type WSMessage

+ Status int

type WSServer

+ func (s *WSServer) GetClients() (clients []*WSClient)

v0.5.0

Sep 15, 2016

Changes in this version

+ const Namespace

+ var WrongCredentials error = errors.New("Wrong credentials")

+ type AuthenticationBackend interface

+ Authenticate func(username string, password string) (string, error)

+ Wrap func(wrapped auth.AuthenticatedHandlerFunc) http.HandlerFunc

+ func NewAuthenticationBackendFromConfig() (AuthenticationBackend, error)

+ type AuthenticationClient struct

+ Addr string

+ AuthToken string

+ Port int

+ func NewAuthenticationClient(addr string, port int, authOptions *AuthenticationOpts) *AuthenticationClient

+ func (c *AuthenticationClient) Authenticate() error

+ func (c *AuthenticationClient) Authenticated() bool

+ func (c *AuthenticationClient) Cookie() *http.Cookie

+ func (c *AuthenticationClient) SetHeaders(headers http.Header)

+ type AuthenticationOpts struct

+ Password string

+ Username string

+ type BasicAuthenticationBackend struct

+ func NewBasicAuthenticationBackend(file string) (*BasicAuthenticationBackend, error)

+ func NewBasicAuthenticationBackendFromConfig() (*BasicAuthenticationBackend, error)

+ func (b *BasicAuthenticationBackend) Authenticate(username string, password string) (string, error)

+ func (b *BasicAuthenticationBackend) Wrap(wrapped auth.AuthenticatedHandlerFunc) http.HandlerFunc

+ type CrudClient struct

+ Root string

+ func NewCrudClient(addr string, port int, authOpts *AuthenticationOpts, root string) *CrudClient

+ func NewCrudClientFromConfig(authOpts *AuthenticationOpts, root string) *CrudClient

+ func (c *CrudClient) Create(resource string, value interface{}) error

+ func (c *CrudClient) Delete(resource string, id string) error

+ func (c *CrudClient) Get(resource string, id string, value interface{}) error

+ func (c *CrudClient) List(resource string, values interface{}) error

+ func (c *CrudClient) Update(resource string, id string, value interface{}) error

+ type DefaultWSClientEventHandler struct

+ func (d *DefaultWSClientEventHandler) OnConnected()

+ func (d *DefaultWSClientEventHandler) OnDisconnected()

+ func (d *DefaultWSClientEventHandler) OnMessage(m WSMessage)

+ type DefaultWSServerEventHandler struct

+ func (d *DefaultWSServerEventHandler) OnMessage(c *WSClient, m WSMessage)

+ func (d *DefaultWSServerEventHandler) OnRegisterClient(c *WSClient)

+ func (d *DefaultWSServerEventHandler) OnUnregisterClient(c *WSClient)

+ type KeystoneAuthenticationBackend struct

+ AuthURL string

+ Tenant string

+ func NewKeystoneAuthenticationBackendFromConfig() *KeystoneAuthenticationBackend

+ func NewKeystoneBackend(authURL string, tenant string) *KeystoneAuthenticationBackend

+ func (b *KeystoneAuthenticationBackend) Authenticate(username string, password string) (string, error)

+ func (b *KeystoneAuthenticationBackend) CheckUser(r *http.Request) (string, error)

+ func (b *KeystoneAuthenticationBackend) Wrap(wrapped auth.AuthenticatedHandlerFunc) http.HandlerFunc

+ type NoAuthenticationBackend struct

+ func NewNoAuthenticationBackend() *NoAuthenticationBackend

+ func (h *NoAuthenticationBackend) Authenticate(username string, password string) (string, error)

+ func (h *NoAuthenticationBackend) Wrap(wrapped auth.AuthenticatedHandlerFunc) http.HandlerFunc

+ type PathPrefix string

+ type RestClient struct

+ func NewRestClient(addr string, port int, authOptions *AuthenticationOpts) *RestClient

+ func NewRestClientFromConfig(authOptions *AuthenticationOpts) *RestClient

+ func (c *RestClient) Request(method, path string, body io.Reader) (*http.Response, error)

+ type Route struct

+ HandlerFunc auth.AuthenticatedHandlerFunc

+ Method string

+ Name string

+ Path interface{}

+ type Server struct

+ Addr string

+ Auth AuthenticationBackend

+ Port int

+ Router *mux.Router

+ Service string

+ func NewServer(s string, a string, p int, auth AuthenticationBackend) *Server

+ func NewServerFromConfig(s string) (*Server, error)

+ func (s *Server) HandleFunc(path string, f auth.AuthenticatedHandlerFunc)

+ func (s *Server) ListenAndServe()

+ func (s *Server) RegisterRoutes(routes []Route)

+ func (s *Server) Stop()

+ type WSAsyncClient struct

+ Addr string

+ AuthClient *AuthenticationClient

+ Path string

+ Port int

+ func NewWSAsyncClient(hostID string, clientType string, addr string, port int, path string, ...) (*WSAsyncClient, error)

+ func NewWSAsyncClientFromConfig(clientType string, addr string, port int, path string, ...) (*WSAsyncClient, error)

+ func (c *WSAsyncClient) AddEventHandler(h WSClientEventHandler)

+ func (c *WSAsyncClient) Connect()

+ func (c *WSAsyncClient) Disconnect()

+ func (c *WSAsyncClient) IsConnected() bool

+ func (c *WSAsyncClient) SendWSMessage(m *WSMessage)

+ type WSClient struct

+ func (c *WSClient) GetHostInfo() (string, string)

+ func (c *WSClient) SendWSMessage(msg *WSMessage)

+ type WSClientEventHandler interface

+ OnConnected func()

+ OnDisconnected func()

+ OnMessage func(m WSMessage)

+ type WSMessage struct

+ Namespace string

+ Obj *json.RawMessage

+ Type string

+ UUID string

+ func NewWSMessage(ns string, tp string, v interface{}, uuids ...string) *WSMessage

+ func (g *WSMessage) Reply(v interface{}) *WSMessage

+ func (g WSMessage) Marshal() []byte

+ func (g WSMessage) String() string

+ type WSServer struct

+ Server *Server

+ func NewWSServer(server *Server, pongWait time.Duration, endpoint string) *WSServer

+ func NewWSServerFromConfig(server *Server, endpoint string) *WSServer

+ func (s *WSServer) AddEventHandler(h WSServerEventHandler)

+ func (s *WSServer) BroadcastWSMessage(msg *WSMessage)

+ func (s *WSServer) GetClientsByType(kind string) (clients []*WSClient)

+ func (s *WSServer) ListenAndServe()

+ func (s *WSServer) SendWSMessageTo(msg *WSMessage, host string) bool

+ func (s *WSServer) Stop()

+ type WSServerEventHandler interface

+ OnMessage func(c *WSClient, m WSMessage)

+ OnRegisterClient func(c *WSClient)

+ OnUnregisterClient func(c *WSClient)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL