Skip to content

Commit e1280db

Browse files
committed
Fix typos for SUBSCRIBE/UNSUBSCRIBE in tunnel.proto/tunnel.go
- Regenerate golang stubs
1 parent cad4b3d commit e1280db

File tree

6 files changed

+47
-43
lines changed

6 files changed

+47
-43
lines changed

cmd/target/proto/config/target_config.pb.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/tunnel/tunnel.pb.go

Lines changed: 34 additions & 34 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/tunnel/tunnel.proto

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,8 +106,8 @@ message Session {
106106
message Subscription {
107107
enum SubscriptionOp {
108108
UNKNOWN = 0;
109-
SUBCRIBE = 1;
110-
UNSUBCRIBE = 2;
109+
SUBSCRIBE = 1;
110+
UNSUBSCRIBE = 2;
111111
}
112112
SubscriptionOp op = 1;
113113
// Used to ack the registration of (un)subscription.

proto/tunnel/tunnel_grpc.pb.go

Lines changed: 4 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/types/types.pb.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

tunnel/tunnel.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -489,9 +489,9 @@ func (s *Server) addTarget(addr net.Addr, target *tpb.Target) error {
489489

490490
func (s *Server) handleSubscription(addr net.Addr, sub *tpb.Subscription) error {
491491
switch op := sub.GetOp(); op {
492-
case tpb.Subscription_SUBCRIBE:
492+
case tpb.Subscription_SUBSCRIBE:
493493
return s.subscribe(addr, sub)
494-
case tpb.Subscription_UNSUBCRIBE:
494+
case tpb.Subscription_UNSUBSCRIBE:
495495
return s.unsubscribe(addr, sub)
496496
default:
497497
return fmt.Errorf("invalid subcription op: %d", op)
@@ -932,7 +932,7 @@ func (c *Client) Subscribe(typ string) error {
932932
}
933933

934934
return c.rs.Send(&tpb.RegisterOp{Registration: &tpb.RegisterOp_Subscription{Subscription: &tpb.Subscription{
935-
Op: tpb.Subscription_SUBCRIBE,
935+
Op: tpb.Subscription_SUBSCRIBE,
936936
TargetType: typ,
937937
}}})
938938
}
@@ -947,7 +947,7 @@ func (c *Client) Unsubscribe(typ string) error {
947947
}
948948

949949
return c.rs.Send(&tpb.RegisterOp{Registration: &tpb.RegisterOp_Subscription{Subscription: &tpb.Subscription{
950-
Op: tpb.Subscription_UNSUBCRIBE,
950+
Op: tpb.Subscription_UNSUBSCRIBE,
951951
TargetType: typ,
952952
}}})
953953
}
@@ -1302,7 +1302,7 @@ func (c *Client) Start(ctx context.Context) {
13021302
case *tpb.RegisterOp_Subscription:
13031303
sub := reg.GetSubscription()
13041304
op := sub.GetOp()
1305-
if op == tpb.Subscription_SUBCRIBE || op == tpb.Subscription_UNSUBCRIBE {
1305+
if op == tpb.Subscription_SUBSCRIBE || op == tpb.Subscription_UNSUBSCRIBE {
13061306
if !sub.GetAccept() {
13071307
err = fmt.Errorf("subscription request (%s) not accepted by server", sub.TargetType)
13081308
return

0 commit comments

Comments
 (0)