chore!: prune deprecated client workflow methods (#763)

Signed-off-by: Mike Nguyen <[email protected]>

Author: mikeee

client/client.go

@@ -229,41 +229,6 @@ type Client interface {
 	// ImplActorClientStub is to impl user defined actor client stub
 	ImplActorClientStub(actorClientStub actor.Client, opt ...config.Option)
 
-	// StartWorkflowBeta1 starts a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	StartWorkflowBeta1(ctx context.Context, req *StartWorkflowRequest) (*StartWorkflowResponse, error)
-
-	// GetWorkflowBeta1 gets a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	GetWorkflowBeta1(ctx context.Context, req *GetWorkflowRequest) (*GetWorkflowResponse, error)
-
-	// PurgeWorkflowBeta1 purges a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	PurgeWorkflowBeta1(ctx context.Context, req *PurgeWorkflowRequest) error
-
-	// TerminateWorkflowBeta1 terminates a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	TerminateWorkflowBeta1(ctx context.Context, req *TerminateWorkflowRequest) error
-
-	// PauseWorkflowBeta1 pauses a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	PauseWorkflowBeta1(ctx context.Context, req *PauseWorkflowRequest) error
-
-	// ResumeWorkflowBeta1 resumes a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	ResumeWorkflowBeta1(ctx context.Context, req *ResumeWorkflowRequest) error
-
-	// RaiseEventWorkflowBeta1 raises an event for a workflow.
-	// Deprecated: Please use the workflow client (github.com/dapr/go-sdk/workflow).
-	// These methods for managing workflows are no longer supported and will be removed in the 1.16 release.
-	RaiseEventWorkflowBeta1(ctx context.Context, req *RaiseEventWorkflowRequest) error
-
 	// ScheduleJobAlpha1 creates and schedules a job.
 	ScheduleJobAlpha1(ctx context.Context, req *Job) error
 

client/client_test.go

@@ -502,62 +502,6 @@ func (s *testDaprServer) UnsubscribeConfiguration(ctx context.Context, in *pb.Un
 	return &pb.UnsubscribeConfigurationResponse{Ok: true}, nil
 }
 
-func (s *testDaprServer) StartWorkflowBeta1(ctx context.Context, in *pb.StartWorkflowRequest) (*pb.StartWorkflowResponse, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &pb.StartWorkflowResponse{
-		InstanceId: in.GetInstanceId(),
-	}, nil
-}
-
-func (s *testDaprServer) GetWorkflowBeta1(ctx context.Context, in *pb.GetWorkflowRequest) (*pb.GetWorkflowResponse, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &pb.GetWorkflowResponse{
-		InstanceId:    in.GetInstanceId(),
-		WorkflowName:  "TestWorkflowName",
-		RuntimeStatus: "Running",
-		Properties:    make(map[string]string),
-	}, nil
-}
-
-func (s *testDaprServer) PurgeWorkflowBeta1(ctx context.Context, in *pb.PurgeWorkflowRequest) (*emptypb.Empty, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &emptypb.Empty{}, nil
-}
-
-func (s *testDaprServer) TerminateWorkflowBeta1(ctx context.Context, in *pb.TerminateWorkflowRequest) (*emptypb.Empty, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &emptypb.Empty{}, nil
-}
-
-func (s *testDaprServer) PauseWorkflowBeta1(ctx context.Context, in *pb.PauseWorkflowRequest) (*emptypb.Empty, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &emptypb.Empty{}, nil
-}
-
-func (s *testDaprServer) ResumeWorkflowBeta1(ctx context.Context, in *pb.ResumeWorkflowRequest) (*emptypb.Empty, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &emptypb.Empty{}, nil
-}
-
-func (s *testDaprServer) RaiseEventWorkflowBeta1(ctx context.Context, in *pb.RaiseEventWorkflowRequest) (*emptypb.Empty, error) {
-	if in.GetInstanceId() == testWorkflowFailureID {
-		return nil, errors.New("test failure")
-	}
-	return &emptypb.Empty{}, nil
-}
-
 func (s *testDaprServer) ScheduleJobAlpha1(ctx context.Context, in *pb.ScheduleJobRequest) (*pb.ScheduleJobResponse, error) {
 	return &pb.ScheduleJobResponse{}, nil
 }