Prepare release 2.0.5

Fixed providers args visibility
vseinstrumentiru · Nov 12, 2020 · 09c807e · 09c807e
1 parent 8511189
commit 09c807e
Show file tree

Hide file tree

Showing 12 changed files with 30 additions and 26 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -9,6 +9,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ## [Unreleased]
 
 
+## [2.0.5] - 2020-11-12
+
+
 ## [2.0.4] - 2020-11-12
 
 
@@ -27,7 +30,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## 1.0.0 - 2020-09-28
 
-[Unreleased]: https://github.com/vseinstrumentiru/lego/compare/v2.0.4...HEAD
+[Unreleased]: https://github.com/vseinstrumentiru/lego/compare/v2.0.5...HEAD
+[2.0.5]: https://github.com/vseinstrumentiru/lego/compare/v2.0.4...v2.0.5
 [2.0.4]: https://github.com/vseinstrumentiru/lego/compare/v2.0.3...v2.0.4
 [2.0.3]: https://github.com/vseinstrumentiru/lego/compare/v2.0.2...v2.0.3
 [2.0.2]: https://github.com/vseinstrumentiru/lego/compare/v2.0.1...v2.0.2

diff --git a/transport/events/channelprovider.go b/transport/events/channelprovider.go
@@ -8,13 +8,13 @@ import (
 	"github.com/vseinstrumentiru/lego/v2/multilog"
 )
 
-type channelArgs struct {
+type ChannelArgs struct {
 	dig.In
 	Config *gochannel.Config `optional:"true"`
 	Logger multilog.Logger
 }
 
-func ProvideChannel(in channelArgs) (*gochannel.GoChannel, error) {
+func ProvideChannel(in ChannelArgs) (*gochannel.GoChannel, error) {
 	cfg := gochannel.Config{}
 
 	if in.Config != nil {

diff --git a/transport/events/channelprovider_test.go b/transport/events/channelprovider_test.go
@@ -17,7 +17,7 @@ import (
 func TestPubSub(t *testing.T) {
 	ass := assert.New(t)
 
-	c, err := ProvideChannel(channelArgs{
+	c, err := ProvideChannel(ChannelArgs{
 		Logger: multilog.New(0),
 	})
 	ass.NoError(err)

diff --git a/transport/events/eventrouter/provider.go b/transport/events/eventrouter/provider.go
@@ -15,14 +15,14 @@ import (
 	"github.com/vseinstrumentiru/lego/v2/multilog"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	RouterConfig *events.RouterConfig `optional:"true"`
 	Logger       multilog.Logger
 	Pipeline     *run.Group
 }
 
-func Provide(in args) (*message.Router, error) {
+func Provide(in Args) (*message.Router, error) {
 	cfg := message.RouterConfig{}
 	logger := in.Logger.WithFields(map[string]interface{}{"component": "events.router"})
 

diff --git a/transport/events/kafkaprovider.go b/transport/events/kafkaprovider.go
@@ -9,21 +9,21 @@ import (
 	kafkatransport "github.com/vseinstrumentiru/lego/v2/transport/kafka"
 )
 
-type kafkaPubArgs struct {
+type KafkaPubArgs struct {
 	dig.In
 	Broker  *kafkatransport.Config
 	Logger  multilog.Logger
 	Encoder kafka.Marshaler
 }
 
-type kafkaSubArgs struct {
+type KafkaSubArgs struct {
 	dig.In
 	Broker  *kafkatransport.Config
 	Logger  multilog.Logger
 	Decoder kafka.Unmarshaler
 }
 
-func ProvideKafkaPublisher(in kafkaPubArgs) (*kafka.Publisher, error) {
+func ProvideKafkaPublisher(in KafkaPubArgs) (*kafka.Publisher, error) {
 	pub, err := kafka.NewPublisher(
 		in.Broker.Addr,
 		in.Encoder,
@@ -34,7 +34,7 @@ func ProvideKafkaPublisher(in kafkaPubArgs) (*kafka.Publisher, error) {
 	return pub.(*kafka.Publisher), err
 }
 
-func ProvideKafkaSubscriber(in kafkaSubArgs) (*kafka.Subscriber, error) {
+func ProvideKafkaSubscriber(in KafkaSubArgs) (*kafka.Subscriber, error) {
 	subCfg := kafka.SubscriberConfig{
 		Brokers:                in.Broker.Addr,
 		ConsumerGroup:          in.Broker.GroupName,

diff --git a/transport/events/natsprovider.go b/transport/events/natsprovider.go
@@ -10,22 +10,22 @@ import (
 	lestan "github.com/vseinstrumentiru/lego/v2/transport/stan"
 )
 
-type natsPubArgs struct {
+type NatsPubArgs struct {
 	dig.In
 	Stan    stan.Conn
 	Logger  multilog.Logger
 	Encoder nats.Marshaler
 }
 
-type natsSubArgs struct {
+type NatsSubArgs struct {
 	dig.In
 	Config  *lestan.Config
 	Stan    stan.Conn
 	Logger  multilog.Logger
 	Decoder nats.Unmarshaler
 }
 
-func ProvideNatsPublisher(in natsPubArgs) (*nats.StreamingPublisher, error) {
+func ProvideNatsPublisher(in NatsPubArgs) (*nats.StreamingPublisher, error) {
 	return nats.NewStreamingPublisherWithStanConn(
 		in.Stan,
 		nats.StreamingPublisherPublishConfig{
@@ -35,7 +35,7 @@ func ProvideNatsPublisher(in natsPubArgs) (*nats.StreamingPublisher, error) {
 	)
 }
 
-func ProvideNatsSubscriber(in natsSubArgs) (*nats.StreamingSubscriber, error) {
+func ProvideNatsSubscriber(in NatsSubArgs) (*nats.StreamingSubscriber, error) {
 	subCfg := nats.StreamingSubscriberSubscriptionConfig{
 		DurableName: in.Config.DurableName,
 		QueueGroup:  in.Config.GroupName,

diff --git a/transport/grpc/provider.go b/transport/grpc/provider.go
@@ -20,7 +20,7 @@ import (
 	"github.com/vseinstrumentiru/lego/v2/version"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	Config      *Config                              `optional:"true"`
 	TraceTags   middleware.TraceTagsMiddlewareConfig `optional:"true"`
@@ -34,7 +34,7 @@ type args struct {
 	Upg      *tableflip.Upgrader
 }
 
-func Provide(in args) *grpc.Server {
+func Provide(in Args) *grpc.Server {
 	if in.Config == nil {
 		in.Config = NewDefaultConfig()
 	}

diff --git a/transport/http/httpserver/provider.go b/transport/http/httpserver/provider.go
@@ -25,7 +25,7 @@ import (
 	"github.com/vseinstrumentiru/lego/v2/version"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	Config      *httpcfg.Config                      `optional:"true"`
 	TraceTags   middleware.TraceTagsMiddlewareConfig `optional:"true"`
@@ -40,7 +40,7 @@ type args struct {
 	Upg      *tableflip.Upgrader
 }
 
-func Provide(in args) (*http.Server, *mux.Router) {
+func Provide(in Args) (*http.Server, *mux.Router) {
 	if in.Config == nil {
 		in.Config = httpcfg.NewDefaultConfig()
 	}

diff --git a/transport/mysql/provider.go b/transport/mysql/provider.go
@@ -10,13 +10,13 @@ import (
 	"github.com/vseinstrumentiru/lego/v2/multilog"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	Config *Config
 	Logger multilog.Logger
 }
 
-func Provide(in args) (*Connector, error) {
+func Provide(in Args) (*Connector, error) {
 	connector, err := mysql.NewConnector(&in.Config.Config)
 
 	if err != nil {

diff --git a/transport/nats/provider.go b/transport/nats/provider.go
@@ -8,13 +8,13 @@ import (
 	lestan "github.com/vseinstrumentiru/lego/v2/transport/stan"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	Config     *Config
 	StanConfig *lestan.Config `optional:"true"`
 }
 
-func Provide(in args) (*nats.Conn, error) {
+func Provide(in Args) (*nats.Conn, error) {
 	if in.Config == nil {
 		return nil, errors.New("nats config not found")
 	}

diff --git a/transport/sql/provider.go b/transport/sql/provider.go
@@ -15,15 +15,15 @@ import (
 	"github.com/vseinstrumentiru/lego/v2/transport/mysql"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	MySQL *mysql.Connector `optional:"true"`
 
 	Closer *shutdown.CloseGroup
 	Health health.Health
 }
 
-func Provide(in args) (*sql.DB, error) {
+func Provide(in Args) (*sql.DB, error) {
 	var connector driver.Connector
 
 	if in.MySQL != nil {

diff --git a/transport/stan/provider.go b/transport/stan/provider.go
@@ -7,13 +7,13 @@ import (
 	"go.uber.org/dig"
 )
 
-type args struct {
+type Args struct {
 	dig.In
 	Stan *Config
 	Nats *nats.Conn
 }
 
-func Provide(in args) (stan.Conn, error) {
+func Provide(in Args) (stan.Conn, error) {
 	if in.Stan == nil {
 		return nil, errors.New("stan config not found")
 	}