provider/mesh: add doc comments

This commit is contained in:
Fabian Reinartz 2016-07-05 16:31:02 +02:00
parent fdf09b6ae6
commit 37eb2127b7
1 changed files with 5 additions and 0 deletions

View File

@ -13,6 +13,7 @@ import (
"github.com/weaveworks/mesh" "github.com/weaveworks/mesh"
) )
// replaceFile wraps a file that is moved to another filename on closing.
type replaceFile struct { type replaceFile struct {
*os.File *os.File
filename string filename string
@ -28,6 +29,7 @@ func (f *replaceFile) Close() error {
return os.Rename(f.File.Name(), f.filename) return os.Rename(f.File.Name(), f.filename)
} }
// openReplace opens a new temporary file that is moved to filename on closing.
func openReplace(filename string) (*replaceFile, error) { func openReplace(filename string) (*replaceFile, error) {
tmpFilename := fmt.Sprintf("%s.%s", filename, utcNow().Format(time.RFC3339Nano)) tmpFilename := fmt.Sprintf("%s.%s", filename, utcNow().Format(time.RFC3339Nano))
@ -54,6 +56,7 @@ type NotificationInfos struct {
stopc chan struct{} stopc chan struct{}
} }
// NewNotificationInfos returns a new NotificationInfos object.
func NewNotificationInfos(logger log.Logger, retention time.Duration, snapfile string) (*NotificationInfos, error) { func NewNotificationInfos(logger log.Logger, retention time.Duration, snapfile string) (*NotificationInfos, error) {
ni := &NotificationInfos{ ni := &NotificationInfos{
logger: logger, logger: logger,
@ -79,6 +82,7 @@ func (ni *NotificationInfos) Register(g mesh.Gossip) {
ni.send = g ni.send = g
} }
// TODO(fabxc): consider making this a flag.
const maintenanceInterval = 15 * time.Minute const maintenanceInterval = 15 * time.Minute
// Run starts blocking background processing of the NotificationInfos. // Run starts blocking background processing of the NotificationInfos.
@ -204,6 +208,7 @@ type Silences struct {
snapfile string snapfile string
} }
// NewSilences creates a new Silences object.
func NewSilences(mk types.Marker, logger log.Logger, retention time.Duration, snapfile string) (*Silences, error) { func NewSilences(mk types.Marker, logger log.Logger, retention time.Duration, snapfile string) (*Silences, error) {
s := &Silences{ s := &Silences{
st: newSilenceState(), st: newSilenceState(),