@@ -66,7 +66,7 @@ func myTranslator(config consulClient.ConsulConfig) ([]kitexclient.Option, error
66
66
return opts , nil
67
67
}
68
68
69
- func myStreamTranslators (config consulClient.ConsulConfig ) ([]streamclient.Option , error ) {
69
+ func myStreamTranslator (config consulClient.ConsulConfig ) ([]streamclient.Option , error ) {
70
70
c := config .MyConfig
71
71
if c == nil {
72
72
return nil , nil
@@ -78,7 +78,7 @@ func myStreamTranslators(config consulClient.ConsulConfig) ([]streamclient.Optio
78
78
return opts , nil
79
79
}
80
80
81
- func myCallOptionMapTranslators (config consulClient.ConsulConfig ) * map [string ]callopt.Option {
81
+ func myCallOptionMapTranslator (config consulClient.ConsulConfig ) * map [string ]callopt.Option {
82
82
c := config .MyConfig
83
83
if c == nil {
84
84
return nil
@@ -88,7 +88,7 @@ func myCallOptionMapTranslators(config consulClient.ConsulConfig) *map[string]ca
88
88
return & res
89
89
}
90
90
91
- func myCallOptionTranslators (config consulClient.ConsulConfig ) * callopt.Option {
91
+ func myCallOptionTranslator (config consulClient.ConsulConfig ) * callopt.Option {
92
92
c := config .MyConfig
93
93
if c == nil {
94
94
return nil
@@ -98,7 +98,7 @@ func myCallOptionTranslators(config consulClient.ConsulConfig) *callopt.Option {
98
98
return & res
99
99
}
100
100
101
- func myStreamCallOptionMapTranslators (config consulClient.ConsulConfig ) * map [string ]streamcall.Option {
101
+ func myStreamCallOptionMapTranslator (config consulClient.ConsulConfig ) * map [string ]streamcall.Option {
102
102
c := config .MyConfig
103
103
if c == nil {
104
104
return nil
@@ -108,7 +108,7 @@ func myStreamCallOptionMapTranslators(config consulClient.ConsulConfig) *map[str
108
108
return & res
109
109
}
110
110
111
- func myStreamCallOptionTranslators (config consulClient.ConsulConfig ) * streamcall.Option {
111
+ func myStreamCallOptionTranslator (config consulClient.ConsulConfig ) * streamcall.Option {
112
112
c := config .MyConfig
113
113
if c == nil {
114
114
return nil
@@ -131,7 +131,12 @@ func main() {
131
131
return
132
132
}
133
133
loaderOptions := consulClient.LoaderOptions {
134
- MyTranslators : map [string ]consulClient.Translator {"myTranslator" : myTranslator },
134
+ MyTranslators : map [string ]consulClient.Translator {"name1" : myTranslator },
135
+ MyStreamTranslators : map [string ]consulClient.StreamTranslator {"name2" : myStreamTranslator },
136
+ MyCallOptionMapTranslators : map [string ]consulClient.CallOptionMapTranslator {"name3" : myCallOptionMapTranslator },
137
+ MyCallOptionTranslators : map [string ]consulClient.CallOptionTranslator {"name4" : myCallOptionTranslator },
138
+ MyStreamCallOptionMapTranslators : map [string ]consulClient.StreamCallOptionMapTranslator {"name5" : myStreamCallOptionMapTranslator },
139
+ MyStreamCallOptionTranslators : map [string ]consulClient.StreamCallOptionTranslator {"name6" : myStreamCallOptionTranslator },
135
140
}
136
141
loader , err := consulClient .NewLoader (clientServiceName , serverServiceName , reader , loaderOptions )
137
142
if err != nil {
0 commit comments