Merge pull request #530 from DefangLabs/lio-follow

rename Tail to Follow in CLI

Author: lionello

src/pkg/cli/client/byoc/aws/byoc.go

@@ -445,7 +445,7 @@ func (b *ByocAws) CreateUploadURL(ctx context.Context, req *defangv1.UploadURLRe
 	}, nil
 }
 
-func (b *ByocAws) Tail(ctx context.Context, req *defangv1.TailRequest) (client.ServerStream[defangv1.TailResponse], error) {
+func (b *ByocAws) Follow(ctx context.Context, req *defangv1.TailRequest) (client.ServerStream[defangv1.TailResponse], error) {
 	if err := b.setUp(ctx); err != nil {
 		return nil, err
 	}

src/pkg/cli/client/byoc/aws/byoc_integration_test.go

@@ -45,7 +45,7 @@ func TestTail(t *testing.T) {
 	b.PulumiProject = "byoc_integration_test"
 	b.ProjectDomain = "example.com" // avoid rpc call
 
-	ss, err := b.Tail(context.Background(), &defangv1.TailRequest{})
+	ss, err := b.Follow(context.Background(), &defangv1.TailRequest{})
 	if err != nil {
 		// the only acceptable error is "unauthorized"
 		if connect.CodeOf(err) != connect.CodeUnauthenticated {

src/pkg/cli/client/byoc/do/byoc.go

@@ -190,7 +190,7 @@ func (b *ByocDo) Subscribe(ctx context.Context, req *defangv1.SubscribeRequest)
 	return nil, client.ErrNotImplemented("not implemented for ByocDo")
 }
 
-func (b *ByocDo) Tail(ctx context.Context, req *defangv1.TailRequest) (client.ServerStream[defangv1.TailResponse], error) {
+func (b *ByocDo) Follow(ctx context.Context, req *defangv1.TailRequest) (client.ServerStream[defangv1.TailResponse], error) {
 	return nil, nil
 }
 

src/pkg/cli/client/client.go

@@ -52,7 +52,7 @@ type Client interface {
 	Restart(context.Context, ...string) (types.ETag, error)
 	ServiceDNS(name string) string
 	Subscribe(context.Context, *defangv1.SubscribeRequest) (ServerStream[defangv1.SubscribeResponse], error)
-	Tail(context.Context, *defangv1.TailRequest) (ServerStream[defangv1.TailResponse], error)
+	Follow(context.Context, *defangv1.TailRequest) (ServerStream[defangv1.TailResponse], error)
 	TearDown(context.Context) error
 	WhoAmI(context.Context) (*defangv1.WhoAmIResponse, error)
 

src/pkg/cli/client/mock.go

@@ -36,7 +36,7 @@ func (m MockClient) LoadProjectName(ctx context.Context) (string, error) {
 	return m.Project.Name, nil
 }
 
-func (m MockClient) Tail(ctx context.Context, req *defangv1.TailRequest) (ServerStream[defangv1.TailResponse], error) {
+func (m MockClient) Follow(ctx context.Context, req *defangv1.TailRequest) (ServerStream[defangv1.TailResponse], error) {
 	if m.ServerStream != nil {
 		return m.ServerStream, nil
 	}

src/pkg/cli/client/playground.go

@@ -59,7 +59,7 @@ func (g *PlaygroundClient) Subscribe(ctx context.Context, req *defangv1.Subscrib
 	return g.client.Subscribe(ctx, connect.NewRequest(req))
 }
 
-func (g *PlaygroundClient) Tail(ctx context.Context, req *defangv1.TailRequest) (ServerStream[defangv1.TailResponse], error) {
+func (g *PlaygroundClient) Follow(ctx context.Context, req *defangv1.TailRequest) (ServerStream[defangv1.TailResponse], error) {
 	return g.client.Tail(ctx, connect.NewRequest(req))
 }
 

src/pkg/cli/tail.go

@@ -185,7 +185,7 @@ func tail(ctx context.Context, client client.Client, params TailOptions) error {
 	} else {
 		since = timestamppb.New(params.Since)
 	}
-	serverStream, err := client.Tail(ctx, &defangv1.TailRequest{Services: params.Services, Etag: params.Etag, Since: since})
+	serverStream, err := client.Follow(ctx, &defangv1.TailRequest{Services: params.Services, Etag: params.Etag, Since: since})
 	if err != nil {
 		return err
 	}
@@ -252,7 +252,7 @@ func tail(ctx context.Context, client client.Client, params TailOptions) error {
 					spaces, _ = term.Warnf("Reconnecting...\r") // overwritten below
 				}
 				pkg.SleepWithContext(ctx, 1*time.Second)
-				serverStream, err = client.Tail(ctx, &defangv1.TailRequest{Services: params.Services, Etag: params.Etag, Since: timestamppb.New(params.Since)})
+				serverStream, err = client.Follow(ctx, &defangv1.TailRequest{Services: params.Services, Etag: params.Etag, Since: timestamppb.New(params.Since)})
 				if err != nil {
 					term.Debug("Reconnect failed:", err)
 					return err