diff --git a/client/options.go b/client/options.go index b1ebeadb..49c83955 100644 --- a/client/options.go +++ b/client/options.go @@ -50,7 +50,7 @@ type Options struct { Wrappers []Wrapper // PoolSize connection pool size PoolSize int - // PoolTTL conection pool ttl + // PoolTTL connection pool ttl PoolTTL time.Duration } diff --git a/runtime/runtime.go b/runtime/runtime.go index b54d7b93..37e49d6b 100644 --- a/runtime/runtime.go +++ b/runtime/runtime.go @@ -37,7 +37,7 @@ type Runtime interface { // Logs returns a log stream type Logs interface { - // Error retuns error + // Error returns error Error() error // Chan return chan log Chan() chan Log diff --git a/server/options.go b/server/options.go index 23cb72d4..b85a43de 100644 --- a/server/options.go +++ b/server/options.go @@ -61,7 +61,7 @@ type Options struct { Name string // Address holds the server address Address string - // Advertise holds the advertie addres + // Advertise holds the advertise address Advertise string // Version holds the server version Version string @@ -344,7 +344,7 @@ type SubscriberOption func(*SubscriberOptions) type SubscriberOptions struct { // Context holds the external options Context context.Context - // Queue holds the subscribtion queue + // Queue holds the subscription queue Queue string // AutoAck flag for auto ack messages after processing AutoAck bool