rest

package

Go to main page

Versions in this module

v0

v0.9.0

Jan 8, 2022

v0.8.4

Oct 12, 2021

v0.8.3

Sep 3, 2021

v0.8.2

Jul 27, 2021

v0.8.1

Jul 27, 2021

v0.8.0

Jun 24, 2021

v0.7.0

Jun 23, 2021

Changes in this version

type HTTPServer

+ func (server *HTTPServer) WithIdentityProvider(provider identity.ProviderFromRequest) *HTTPServer

v0.6.0

May 20, 2021

v0.5.0

Apr 26, 2021

Changes in this version

type HTTPServer

+ func (server *HTTPServer) WithAuditor(auditor Auditor) *HTTPServer

+ func (server *HTTPServer) WithAuthz(authz Authz) *HTTPServer

+ func (server *HTTPServer) WithScheduler(scheduler tasks.Scheduler) *HTTPServer

+ func (server *HTTPServer) WithShutdownTimeout(timeout time.Duration) *HTTPServer

type ServerEvent

+ const ServerStoppingEvent

v0.4.0

Jul 8, 2020

v0.3.0

Jul 3, 2020

v0.2.0

Jun 18, 2020

Changes in this version

+ const EvtServiceStarted

+ const EvtServiceStopped

+ const EvtSourceStatus

+ const MaxRequestSize

+ func GetHostName(bindAddr string) string

+ func GetNodeListenPeerURLs(c ClusterInfo, nodeID string) ([]*url.URL, error)

+ func GetPort(bindAddr string) string

+ func GetServerBaseURL(s Server) *url.URL

+ func GetServerURL(s Server, r *http.Request, relativeEndpoint string) *url.URL

+ type Auditor interface

+ Audit func(source string, eventType string, identity string, contextID string, ...)

+ type Authz interface

+ NewHandler func(delegate http.Handler) (http.Handler, error)

+ SetRoleMapper func(func(*http.Request) string)

+ type CORSOptions struct

+ AllowCredentials bool

+ AllowOriginFunc func(origin string) bool

+ AllowOriginRequestFunc func(r *http.Request, origin string) bool

+ AllowedHeaders []string

+ AllowedMethods []string

+ AllowedOrigins []string

+ Debug bool

+ ExposedHeaders []string

+ MaxAge int

+ OptionsPassthrough bool

+ type ClusterInfo interface

+ ClusterMembers func() ([]*ClusterMember, error)

+ LeaderID func() string

+ NodeID func() string

+ NodeName func() string

+ type ClusterManager interface

+ AddNode func(ctx context.Context, peerAddrs []string) (member *ClusterMember, peers []*ClusterMember, err error)

+ RemoveNode func(ctx context.Context, nodeID string) (peers []*ClusterMember, err error)

+ type ClusterMember struct

+ ID string

+ ListenPeerURLs []string

+ Name string

+ type HTTPServer struct

+ func New(version string, ipaddr string, httpConfig HTTPServerConfig, ...) (*HTTPServer, error)

+ func (server *HTTPServer) AddNode(ctx context.Context, peerAddrs []string) (*ClusterMember, []*ClusterMember, error)

+ func (server *HTTPServer) AddService(s Service)

+ func (server *HTTPServer) Audit(source string, eventType string, identity string, contextID string, ...)

+ func (server *HTTPServer) ClusterMembers() ([]*ClusterMember, error)

+ func (server *HTTPServer) HTTPConfig() HTTPServerConfig

+ func (server *HTTPServer) HostName() string

+ func (server *HTTPServer) IsReady() bool

+ func (server *HTTPServer) LeaderID() string

+ func (server *HTTPServer) LocalIP() string

+ func (server *HTTPServer) Name() string

+ func (server *HTTPServer) NewMux() http.Handler

+ func (server *HTTPServer) NodeID() string

+ func (server *HTTPServer) NodeName() string

+ func (server *HTTPServer) OnEvent(evt ServerEvent, handler ServerEventFunc)

+ func (server *HTTPServer) Port() string

+ func (server *HTTPServer) Protocol() string

+ func (server *HTTPServer) RemoveNode(ctx context.Context, nodeID string) (peers []*ClusterMember, err error)

+ func (server *HTTPServer) Scheduler() tasks.Scheduler

+ func (server *HTTPServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (server *HTTPServer) Service(name string) Service

+ func (server *HTTPServer) StartHTTP() error

+ func (server *HTTPServer) StartedAt() time.Time

+ func (server *HTTPServer) StopHTTP()

+ func (server *HTTPServer) TLSConfig() *tls.Config

+ func (server *HTTPServer) Uptime() time.Duration

+ func (server *HTTPServer) Version() string

+ func (server *HTTPServer) WithCORS(cors *CORSOptions) *HTTPServer

+ func (server *HTTPServer) WithMuxFactory(muxFactory MuxFactory)

+ type HTTPServerConfig interface

+ GetAllowProfiling func() bool

+ GetBindAddr func() string

+ GetDisabled func() bool

+ GetHeartbeatSecs func() int

+ GetPackageLogger func() string

+ GetProfilerDir func() string

+ GetServiceName func() string

+ GetServices func() []string

+ GetVIPName func() string

+ type Handle func(http.ResponseWriter, *http.Request, Params)

+ type MuxFactory interface

+ NewMux func() http.Handler

+ type Params httprouter.Params

+ func (ps Params) ByName(name string) string

+ type Router interface

+ CONNECT func(path string, handle Handle)

+ DELETE func(path string, handle Handle)

+ GET func(path string, handle Handle)

+ HEAD func(path string, handle Handle)

+ Handler func() http.Handler

+ OPTIONS func(path string, handle Handle)

+ PATCH func(path string, handle Handle)

+ POST func(path string, handle Handle)

+ PUT func(path string, handle Handle)

+ func NewRouter(notfoundhandler http.HandlerFunc) Router

+ func NewRouterWithCORS(notfoundhandler http.HandlerFunc, opt *CORSOptions) Router

+ type Server interface

+ AddService func(s Service)

+ Audit func(source string, eventType string, identity string, contextID string, ...)

+ HTTPConfig func() HTTPServerConfig

+ HostName func() string

+ IsReady func() bool

+ LocalIP func() string

+ Name func() string

+ OnEvent func(evt ServerEvent, handler ServerEventFunc)

+ Port func() string

+ Protocol func() string

+ Scheduler func() tasks.Scheduler

+ Service func(name string) Service

+ StartHTTP func() error

+ StartedAt func() time.Time

+ StopHTTP func()

+ TLSConfig func() *tls.Config

+ Uptime func() time.Duration

+ Version func() string

+ type ServerEvent int

+ const ServerStartedEvent

+ const ServerStoppedEvent

+ type ServerEventFunc func(evt ServerEvent)

+ type Service interface

+ Close func()

+ IsReady func() bool

+ Name func() string

+ Register func(Router)

+ type TLSInfoConfig interface

+ GetCertFile func() string

+ GetClientCertAuth func() *bool

+ GetKeyFile func() string

+ GetTrustedCAFile func() string

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