Skip to content

Commit

Permalink
fix some typos (#31969)
Browse files Browse the repository at this point in the history
Signed-off-by: cuishuang <imcusg@gmail.com>
  • Loading branch information
cuishuang authored Jun 22, 2022
1 parent 76eec5b commit cab8871
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion filebeat/beater/channels.go
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ type eventCounter struct {
wg sync.WaitGroup
}

// countingClient adds and substracts from a counter when events have been
// countingClient adds and subtracts from a counter when events have been
// published, dropped or ACKed. The countingClient can be used to keep track of
// inflight events for a beat.Client instance. The counter is updated after the
// client has been disconnected from the publisher pipeline via 'Closed'.
Expand Down
4 changes: 2 additions & 2 deletions filebeat/input/journald/pkg/journalread/reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ func NewReader(log *logp.Logger, journal journal, backoff backoff.Backoff) *Read
}

// Open opens a journal and creates a reader for it.
// Additonal settings can be applied to the journal by passing functions to with.
// Additional settings can be applied to the journal by passing functions to with.
// Open returns an error if the journal can not be opened, or if one with-function failed.
//
// Open will opend the systems journal if the path is empty or matches LOCAL_SYSTEM_JOURNAL.
Expand Down Expand Up @@ -148,7 +148,7 @@ func (r *Reader) Seek(mode SeekMode, cursor string) (err error) {
}

// Next reads a new journald entry from the journal. It blocks if there is
// currently no entry available in the journal, or until an error has occured.
// currently no entry available in the journal, or until an error has occurred.
func (r *Reader) Next(cancel canceler) (*sdjournal.JournalEntry, error) {
for cancel.Err() == nil {
c, err := r.journal.Next()
Expand Down

0 comments on commit cab8871

Please sign in to comment.