Documentation ¶
Index ¶
- Constants
- func NewMemberlistConfig(ctx context.Context) *memberlist.Config
- func WrapAccessLog(next http.Handler, logger HttpLogger) http.Handler
- type Config
- type DefDelegate
- func (d *DefDelegate) GetBroadcasts(overhead, limit int) [][]byte
- func (d *DefDelegate) Init() error
- func (d *DefDelegate) LocalState(join bool) []byte
- func (d *DefDelegate) MergeRemoteState(buf []byte, join bool)
- func (d *DefDelegate) NodeMeta(limit int) []byte
- func (d *DefDelegate) NotifyMsg(msg []byte)
- type DefLogger
- type Dyn_o_mite
- type DynomiteYaml
- type HttpController
- type HttpLogger
- type HttpServer
- type Member
- type MemberLogger
- type SeedAdvertise
- type WrapWriter
Constants ¶
View Source
const ( DEFAULT_MEMBERLIST_JOIN_ADDR string = "127.0.0.1:3101" DEFAULT_MEMBERLIST_BIND_IP string = "0.0.0.0" DEFAULT_MEMBERLIST_BIND_PORT int = 3101 DEFAULT_FLORIDA_API_IP string = "0.0.0.0" DEFAULT_FLORIDA_API_PORT int = 8080 DEFAULT_FLORIDA_API_REQUEST string = "/REST/v1/admin/get_seeds" DEFAULT_HTTP_READ_TIMEOUT string = "500ms" DEFAULT_HTTP_WRITE_TIMEOUT string = "500ms" DEFAULT_MEMBERLIST_LEAVE_TIMEOUT string = "30s" )
View Source
const ( AppName string = "dynomite-floridalist" Version string = "1.1.3" UA string = AppName + "/" + Version )
View Source
const DYNOMITE_YML_TMPL = `` /* 1238-byte string literal not displayed */
View Source
const TAB string = "\t"
Variables ¶
This section is empty.
Functions ¶
func NewMemberlistConfig ¶
func NewMemberlistConfig(ctx context.Context) *memberlist.Config
func WrapAccessLog ¶
func WrapAccessLog(next http.Handler, logger HttpLogger) http.Handler
Types ¶
type Config ¶
type Config struct { DebugMode bool VerboseMode bool Procs int MemberlistNodeName string MemberlistJoinAddress string MemberlistBindIp string MemberlistBindPort int FloridaBindIP string FloridaBindPort int FloridaEndpoint string HttpReadTimeout time.Duration HttpWriteTimeout time.Duration MemberlistLeaveTimeout time.Duration UseWANConfig bool }
type DefDelegate ¶
type DefDelegate struct {
// contains filtered or unexported fields
}
func NewMemberlistDelegate ¶
func NewMemberlistDelegate(ctx context.Context) *DefDelegate
func (*DefDelegate) GetBroadcasts ¶
func (d *DefDelegate) GetBroadcasts(overhead, limit int) [][]byte
func (*DefDelegate) Init ¶
func (d *DefDelegate) Init() error
func (*DefDelegate) LocalState ¶
func (d *DefDelegate) LocalState(join bool) []byte
func (*DefDelegate) MergeRemoteState ¶
func (d *DefDelegate) MergeRemoteState(buf []byte, join bool)
func (*DefDelegate) NodeMeta ¶
func (d *DefDelegate) NodeMeta(limit int) []byte
func (*DefDelegate) NotifyMsg ¶
func (d *DefDelegate) NotifyMsg(msg []byte)
type Dyn_o_mite ¶
type DynomiteYaml ¶
type DynomiteYaml struct {
DynomiteConf Dyn_o_mite `yaml:"dyn_o_mite"`
}
type HttpController ¶
type HttpController struct {
// contains filtered or unexported fields
}
func NewHttpController ¶
func NewHttpController(config Config, member *Member) *HttpController
func (*HttpController) CheckStatus ¶
func (c *HttpController) CheckStatus(res http.ResponseWriter, req *http.Request)
func (*HttpController) GetSeeds ¶
func (c *HttpController) GetSeeds(res http.ResponseWriter, req *http.Request)
func (*HttpController) HttpHandler ¶
func (c *HttpController) HttpHandler() http.Handler
func (*HttpController) Version ¶
func (c *HttpController) Version(res http.ResponseWriter, req *http.Request)
type HttpLogger ¶
func NewHttpLogger ¶
func NewHttpLogger(c Config) HttpLogger
type HttpServer ¶
type HttpServer struct { Server *http.Server Controller *HttpController // contains filtered or unexported fields }
func NewHttpServer ¶
func NewHttpServer(ctx context.Context, m *Member) *HttpServer
type MemberLogger ¶
type MemberLogger struct {
// contains filtered or unexported fields
}
func NewMemberLogger ¶
func NewMemberLogger(config Config) *MemberLogger
func (*MemberLogger) NewLogger ¶
func (ml *MemberLogger) NewLogger() *log.Logger
type SeedAdvertise ¶
type WrapWriter ¶
type WrapWriter struct { Writer http.ResponseWriter LastStatus int }
func (*WrapWriter) Header ¶
func (w *WrapWriter) Header() http.Header
func (*WrapWriter) WriteHeader ¶
func (w *WrapWriter) WriteHeader(status int)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.