Documentation
¶
Index ¶
- Constants
- Variables
- func CreatePeerUrl() (types.URLs, error)
- func NewServer(ctx context.Context, mux *http.ServeMux) (*_Server, error)
- func WriteError(w http.ResponseWriter, r *http.Request, err error)
- type Build
- type Etcd
- type ILeaderStateHandler
- type Info
- type KV
- type KValue
- type Logger
- func (l *Logger) Check(ent zapcore.Entry, ce *zapcore.CheckedEntry) *zapcore.CheckedEntry
- func (l *Logger) Enabled(level zapcore.Level) bool
- func (l *Logger) Sync() error
- func (l *Logger) With(fields []zapcore.Field) zapcore.Core
- func (l *Logger) Write(ent zapcore.Entry, fields []zapcore.Field) error
- type Response
- type ServiceHandler
Constants ¶
View Source
const ( DefaultMaxSnapshots = 5 DefaultMaxWALs = 5 DefaultWarningApplyDuration = 100 * time.Millisecond DefaultDowngradeCheckTime = 5 * time.Second DefaultStrictReconfigCheck = true // DefaultEnableV2 is the default value for "--enable-v2" flag. // v2 API is disabled by default. DefaultEnableV2 = false )
Variables ¶
View Source
var (
ErrorAlreadyInCluster = errors.New("already in cluster")
)
Functions ¶
func CreatePeerUrl ¶
func WriteError ¶
func WriteError(w http.ResponseWriter, r *http.Request, err error)
Types ¶
type Build ¶
type Build struct {
// contains filtered or unexported fields
}
func (*Build) Check ¶
func (b *Build) Check(ent zapcore.Entry, ce *zapcore.CheckedEntry) *zapcore.CheckedEntry
type ILeaderStateHandler ¶
type ILeaderStateHandler interface {
LeaderChange(isLeader bool)
}
type Info ¶
type Info *membership.Member
type Logger ¶
type Logger struct {
// contains filtered or unexported fields
}
func (*Logger) Check ¶
func (l *Logger) Check(ent zapcore.Entry, ce *zapcore.CheckedEntry) *zapcore.CheckedEntry
type ServiceHandler ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.