Merge branch 'master' into noinputguard

Author: akokhanovskyi

.golangci.yml

@@ -247,9 +247,9 @@ linters-settings:
   lll:
     # max line length, lines longer will be reported. Default is 120.
     # '\t' is counted as 1 character by default, and can be changed with the tab-width option
-    line-length: 120
+    line-length: 160
     # tab width in spaces. Default to 1.
-    tab-width: 1
+    tab-width: 4
   maligned:
     # print struct with more effective memory layout or not, false by default
     suggest-new: true
@@ -370,6 +370,7 @@ linters:
     - goprintffuncname
     - ineffassign
     - interfacer
+    - lll
     - maligned
     - misspell
     - nakedret
@@ -379,6 +380,8 @@ linters:
     - rowserrcheck
     - scopelint
     - sqlclosecheck
+    - staticcheck
+    - stylecheck
     - unconvert
     - unparam
     - whitespace
@@ -392,12 +395,9 @@ linters:
     - godox
     - goerr113
     - gomnd
-    - lll
     - nestif
     - nlreturn
-    - staticcheck
     - structcheck
-    - stylecheck
     - testpackage
     - unused
 

factory.go

@@ -54,7 +54,7 @@ func NewFactory(config ...FactoryConfig) *Factory {
 // Register registers a component so that it can be instantiated at run-time
 func (f *Factory) Register(componentName string, constructor Constructor) error {
 	if _, exists := f.registry[componentName]; exists {
-		return fmt.Errorf("Registry error: component '%s' already registered", componentName)
+		return fmt.Errorf("registry error: component '%s' already registered", componentName)
 	}
 
 	f.registry[componentName] = registryEntry{
@@ -70,7 +70,7 @@ func (f *Factory) Register(componentName string, constructor Constructor) error
 // Annotate adds human-readable documentation for a component to the runtime
 func (f *Factory) Annotate(componentName string, annotation Annotation) error {
 	if _, exists := f.registry[componentName]; !exists {
-		return fmt.Errorf("Registry annotation error: component '%s' is not registered", componentName)
+		return fmt.Errorf("registry annotation error: component '%s' is not registered", componentName)
 	}
 
 	entry := f.registry[componentName]
@@ -89,7 +89,7 @@ func (f *Factory) Unregister(componentName string) error {
 		return nil
 	}
 
-	return fmt.Errorf("Registry error: component '%s' is not registered", componentName)
+	return fmt.Errorf("registry error: component '%s' is not registered", componentName)
 }
 
 // Create creates a new instance of a component registered under a specific name.
@@ -98,7 +98,7 @@ func (f *Factory) Create(componentName string) (interface{}, error) {
 		return info.Constructor()
 	}
 
-	return nil, fmt.Errorf("Factory error: component '%s' does not exist", componentName)
+	return nil, fmt.Errorf("factory error: component '%s' does not exist", componentName)
 }
 
 // // UpdateComponentInfo extracts run-time information about a

graph.go

@@ -1,3 +1,4 @@
+// Package goflow implements a dataflow and flow-based programming library for Go.
 package goflow
 
 import (
@@ -83,7 +84,7 @@ func (n *Graph) Add(name string, c interface{}) error {
 	_, isGraph := c.(Graph)
 
 	if !isComponent && !isGraph {
-		return fmt.Errorf("Could not add process '%s': instance is neither Component nor Graph", name)
+		return fmt.Errorf("could not add process '%s': instance is neither Component nor Graph", name)
 	}
 	// Add to the map of processes
 	n.procs[name] = c
@@ -112,7 +113,7 @@ func (n *Graph) AddNew(processName string, componentName string, f *Factory) err
 // the graph. Then it drops the process itself.
 func (n *Graph) Remove(processName string) error {
 	if _, exists := n.procs[processName]; !exists {
-		return fmt.Errorf("Could not remove process: '%s' does not exist", processName)
+		return fmt.Errorf("could not remove process: '%s' does not exist", processName)
 	}
 
 	delete(n.procs, processName)

graph_connect.go

@@ -31,7 +31,7 @@ type connection struct {
 	buffer  int
 }
 
-// Connect connects a sender to a receiver and creates a channel between them using BufferSize configuratio nof the graph.
+// Connect a sender to a receiver and create a channel between them using BufferSize graph configuration.
 // Normally such a connection is unbuffered but you can change by setting flow.DefaultBufferSize > 0 or
 // by using ConnectBuf() function instead.
 // It returns true on success or panics and returns false if error occurs.