Update comments.

pull/4876/head
Edd Robinson 2015-11-23 17:39:52 +00:00
parent ffbd6037e2
commit 8384ba3e84
5 changed files with 11 additions and 11 deletions

View File

@ -159,7 +159,7 @@ func (p *Parser) Parse(line string) (models.Point, error) {
return models.NewPoint(measurement, tags, fieldValues, timestamp)
}
// ApplyTemplate extracts the template fields form the given line and
// ApplyTemplate extracts the template fields from the given line and
// returns the measurement name and tags.
func (p *Parser) ApplyTemplate(line string) (string, map[string]string, string, error) {
// Break line into fields (name, value, timestamp), only name is used
@ -210,7 +210,7 @@ func NewTemplate(pattern string, defaultTags models.Tags, separator string) (*te
return template, nil
}
// Apply extracts the template fields form the given line and returns the measurement
// Apply extracts the template fields from the given line and returns the measurement
// name and tags
func (t *template) Apply(line string) (string, map[string]string, string, error) {
fields := strings.Split(line, ".")

View File

@ -379,7 +379,7 @@ func (s *Service) processBatches(batcher *tsdb.PointBatcher) {
}
}
// Diagnostics returns diagnositics of the graphite service.
// Diagnostics returns diagnostics of the graphite service.
func (s *Service) Diagnostics() (*monitor.Diagnostic, error) {
s.tcpConnectionsMu.Lock()
defer s.tcpConnectionsMu.Unlock()

View File

@ -18,8 +18,8 @@ import (
"github.com/influxdb/influxdb/monitor"
)
// ErrHintedHandoffDisabled is returned when attempted to write to a
// shard with hinted handoff disabled.
// ErrHintedHandoffDisabled is returned when attempting to use a
// disabled hinted handoff service.
var ErrHintedHandoffDisabled = fmt.Errorf("hinted handoff disabled")
const (
@ -75,7 +75,7 @@ func NewService(c Config, w shardWriter, m metaStore) *Service {
}
}
// Open attempts to start the hinted handoff service.
// Open opens the hinted handoff service.
func (s *Service) Open() error {
s.mu.Lock()
defer s.mu.Unlock()
@ -123,7 +123,7 @@ func (s *Service) Open() error {
return nil
}
// Close attempts to gracefully shutdown the hinted handoff service.
// Close closes the hinted handoff service.
func (s *Service) Close() error {
s.Logger.Println("shutting down hh service")
s.mu.Lock()

View File

@ -29,7 +29,7 @@ import (
)
const (
// DefaultChunkSize specified the amount of data mappers will read
// DefaultChunkSize specifies the amount of data mappers will read
// up to, before sending results back to the engine. This is the
// default size in the number of values returned in a raw query.
//
@ -621,7 +621,7 @@ func MarshalJSON(v interface{}, pretty bool) []byte {
return b
}
// Point represents an influx point.
// Point represents an InfluxDB point.
type Point struct {
Name string `json:"name"`
Time time.Time `json:"time"`
@ -629,7 +629,7 @@ type Point struct {
Fields map[string]interface{} `json:"fields"`
}
// Batch is a collection of points belonging to a database, with a
// Batch is a collection of points associated with a database, having a
// certain retention policy.
type Batch struct {
Database string `json:"database"`

View File

@ -29,7 +29,7 @@ const (
DefaultBatchPending = 5
)
// Config represents the configuration of the opentstb service.
// Config represents the configuration of the OpenTSDB service.
type Config struct {
Enabled bool `toml:"enabled"`
BindAddress string `toml:"bind-address"`